git.meshlink.io Git - catta/blob - psched.h

   1 #ifndef foopschedhfoo
   2 #define foopschedhfoo
   3
   4 typedef struct _flxQueryJob flxQueryJob;
   5 typedef struct _flxResponseJob flxResponseJob;
   6 typedef struct _flxPacketScheduler flxPacketScheduler;
   7
   8 #include "timeeventq.h"
   9 #include "rr.h"
  10 #include "llist.h"
  11 #include "iface.h"
  12
  13 struct _flxQueryJob {
  14     flxPacketScheduler *scheduler;
  15     flxTimeEvent *time_event;
  16     flxKey *key;
  17     gboolean done;
  18     FLX_LLIST_FIELDS(flxQueryJob, jobs);
  19 };
  20
  21 struct _flxResponseJob {
  22     flxPacketScheduler *scheduler;
  23     flxTimeEvent *time_event;
  24     flxRecord *record;
  25     gboolean done;
  26     FLX_LLIST_FIELDS(flxResponseJob, jobs);
  27 };
  28
  29 struct _flxPacketScheduler {
  30     flxServer *server;
  31
  32     flxInterface *interface;
  33
  34     FLX_LLIST_HEAD(flxQueryJob, query_jobs);
  35     FLX_LLIST_HEAD(flxResponseJob, response_jobs);
  36 };
  37
  38 flxPacketScheduler *flx_packet_scheduler_new(flxServer *server, flxInterface *i);
  39 void flx_packet_scheduler_free(flxPacketScheduler *s);
  40
  41 void flx_packet_scheduler_post_query(flxPacketScheduler *s, flxKey *key);
  42 void flx_packet_scheduler_post_response(flxPacketScheduler *s, flxRecord *record);
  43
  44 void flx_packet_scheduler_drop_query(flxPacketScheduler *s, flxKey *key);
  45 void flx_packet_scheduler_drop_response(flxPacketScheduler *s, flxRecord *record);
  46
  47 #endif