code.grnet.gr Git - archipelago/blob - xseg/peers/user/mpeer.h

   1 #include <stddef.h>
   2 #include <xseg/xseg.h>
   3 /* main mpeer structs */
   4 struct peer_req {
   5         struct peerd *peer;
   6         struct xseg_request *req;
   7         ssize_t retval;
   8         xport portno;
   9         void *priv;
  10 };
  11
  12 struct peerd {
  13         struct xseg *xseg;
  14         struct xseg_port *port;
  15         xport portno_start;
  16         xport portno_end;
  17         long nr_ops;
  18         uint32_t nr_threads;
  19         uint32_t defer_portno;
  20         struct thread *thread;
  21         struct peer_req *peer_reqs;
  22         struct xq free_reqs;
  23         struct xq threads;
  24         void *priv;
  25         void (*interactive_func)(void);
  26 };
  27
  28
  29 void fail(struct peerd *peer, struct peer_req *pr);
  30 void complete(struct peerd *peer, struct peer_req *pr);
  31 void defer_request(struct peerd *peer, struct peer_req *pr);
  32 void pending(struct peerd *peer, struct peer_req *req);
  33 void log_pr(char *msg, struct peer_req *pr);
  34 int canDefer(struct peerd *peer);
  35 int submit_peer_req(struct peerd *peer, struct peer_req *pr);
  36 struct peer_req *alloc_peer_req(struct peerd *peer);
  37 void free_peer_req(struct peerd *peer, struct peer_req *pr);
  38 int thread_execute(struct peerd *peer, void (*func)(void *arg), void *arg);
  39 void get_submits_stats();
  40 void get_responds_stats();
  41
  42 static inline struct peerd * __get_peerd(void * custom_peerd)
  43 {
  44         return (struct peerd *) ((unsigned long) custom_peerd  - offsetof(struct peerd, priv));
  45 }
  46
  47 /********************************
  48  *   mandatory peer functions   *
  49  ********************************/
  50
  51 /* peer main function */
  52 int custom_peer_init(struct peerd *peer, int argc, char *argv[]);
  53
  54 /* dispatch function that cannot block
  55  * defers blocking calls to helper threads
  56  */
  57 int dispatch(struct peerd *peer, struct peer_req *pr, struct xseg_request *xseg);
  58
  59 void usage();