fwp/lib/core/fwp_endpoint.h

   1 #ifndef _FWP_ENDPOINT_H
   2 #define _FWP_ENDPOINT_H
   3
   4 #define FWP_ANY_NODE INADDR_ANY
   5
   6 typedef enum {
   7         FWP_EPOINT_BESTEFFORT   = 0,
   8         FWP_EPOINT_RELIABLE     = 1,
   9 } fwp_endpoint_reliability_t;
  10
  11 struct fwp_endpoint;
  12 typedef struct fwp_endpoint fwp_endpoint_t;
  13 /** fwp endpoint descriptor type */
  14 typedef struct fwp_endpoint* fwp_endpoint_d_t;
  15
  16 /**
  17  * Endpoint attributes
  18  */
  19 typedef
  20 struct fwp_endpoint_attr {
  21         unsigned int reliability;
  22         unsigned int max_connections;
  23         /* queueing policy*/
  24 } fwp_endpoint_attr_t;
  25
  26 /*TODO: extract FWP_DEBUG from fwp_util.h */
  27 #include "fwp_util.h"
  28 #include "fwp_vres.h"
  29
  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);
  39
  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);
  42
  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);
  47
  48 int fwp_endpoint_attr_init(fwp_endpoint_attr_t *attr);
  49
  50 static inline int fwp_endpoint_attr_setreliability(fwp_endpoint_attr_t *attr,
  51                                                         int reliability)
  52 {
  53         attr->reliability = reliability;
  54         return 0;
  55 }
  56
  57 /* Sets queueing policy */
  58 /*int fwp_endpoint_attr_setqpolicy(fwp_endpoint_attr_t *attr);*/
  59 #ifdef _FWP_INTERNALS_
  60
  61 int fwp_endpoint_table_init(unsigned int nr_endpoints);
  62
  63 #endif /*_FWP_INTERNALS_*/
  64 #endif /*_FWP_ENDPOINT_H */