1 #ifndef _FWP_ENDPOINT_H
2 #define _FWP_ENDPOINT_H
4 #define FWP_ANY_NODE INADDR_ANY
7 FWP_EPOINT_BESTEFFORT = 0,
8 FWP_EPOINT_RELIABLE = 1,
9 } fwp_endpoint_reliability_t;
12 typedef struct fwp_endpoint fwp_endpoint_t;
13 /** fwp endpoint descriptor type */
14 typedef struct fwp_endpoint* fwp_endpoint_d_t;
20 struct fwp_endpoint_attr {
21 unsigned int reliability;
22 unsigned int max_connections;
24 } fwp_endpoint_attr_t;
26 /*TODO: extract FWP_DEBUG from fwp_util.h */
30 int fwp_endpoint_get_params(fwp_endpoint_d_t epointd, unsigned int *node,
31 unsigned int *port, fwp_endpoint_attr_t *attr);
32 int fwp_send_endpoint_create(unsigned int node, unsigned int port,
33 fwp_endpoint_attr_t *attr,
34 fwp_endpoint_t **epoint);
35 int fwp_receive_endpoint_create(/*unsigned int node,*/ unsigned int port,
36 fwp_endpoint_attr_t *attr,
37 fwp_endpoint_t **epoint);
38 int fwp_endpoint_destroy(fwp_endpoint_d_t epointd);
40 int fwp_send_endpoint_bind(fwp_endpoint_d_t epointd, fwp_vres_d_t vresd);
41 int fwp_send_endpoint_unbind(fwp_endpoint_d_t epointd);
43 ssize_t fwp_recv(fwp_endpoint_t *endpoint,
44 void *buffer, const size_t buffer_size,
45 unsigned int *from, int flags);
46 int fwp_send(fwp_endpoint_t *fwp_epoint, const void *msg, const size_t size, int flags);
48 int fwp_endpoint_attr_init(fwp_endpoint_attr_t *attr);
50 static inline int fwp_endpoint_attr_setreliability(fwp_endpoint_attr_t *attr,
53 attr->reliability = reliability;
57 /* Sets queueing policy */
58 /*int fwp_endpoint_attr_setqpolicy(fwp_endpoint_attr_t *attr);*/
59 #ifdef _FWP_INTERNALS_
61 int fwp_endpoint_table_init(unsigned int nr_endpoints);
63 #endif /*_FWP_INTERNALS_*/
64 #endif /*_FWP_ENDPOINT_H */