psrdada-sys 0.2.0

Bindgen wrappers for psrdada
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

#ifndef __DADA_UDP_H
#define __DADA_UDP_H

/*
 * UDP library functions
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>

#include "multilog.h"

#define KERNEL_BUFFER_SIZE_MAX     67108864
#define KERNEL_BUFFER_SIZE_DEFAULT 131071
#define STATS_INIT = {0, 0, 0, 0}

/* statistics on received and dropped */
typedef struct {
  uint64_t received;
  uint64_t dropped;
  uint64_t received_per_sec;
  uint64_t dropped_per_sec;
} stats_t;

stats_t * init_stats_t();

void reset_stats_t (stats_t * s);

size_t dada_sock_recv(int fd, char* buffer, size_t size, int flags);

size_t dada_sock_send(int fd, struct sockaddr_in addr, char *data, size_t size);

struct in_addr *atoaddr (char *address);

int dada_udp_sock_in(multilog_t* log, const char* iface, int port, int verbose);

int dada_udp_sock_out(int *fd, struct sockaddr_in * dagram, char *client, 
                      int port, int bcast, const char * bcast_addr);

int dada_udp_sock_set_buffer_size (multilog_t* log, int fd, int verbose, int pref_size);

int dada_udp_sock_set_size (multilog_t* log, int fd, int verbose, int pref_size, int buf);

size_t dada_sock_clear_buffered_packets(int fd, size_t size);
#endif /* __DADA_UDP_H */