4 typedef struct _flxQueryJob flxQueryJob;
5 typedef struct _flxResponseJob flxResponseJob;
6 typedef struct _flxPacketScheduler flxPacketScheduler;
8 #include "timeeventq.h"
14 flxPacketScheduler *scheduler;
15 flxTimeEvent *time_event;
19 FLX_LLIST_FIELDS(flxQueryJob, jobs);
22 struct _flxResponseJob {
23 flxPacketScheduler *scheduler;
24 flxTimeEvent *time_event;
28 FLX_LLIST_FIELDS(flxResponseJob, jobs);
31 struct _flxPacketScheduler {
34 flxInterface *interface;
36 FLX_LLIST_HEAD(flxQueryJob, query_jobs);
37 FLX_LLIST_HEAD(flxResponseJob, response_jobs);
40 flxPacketScheduler *flx_packet_scheduler_new(flxServer *server, flxInterface *i);
41 void flx_packet_scheduler_free(flxPacketScheduler *s);
43 void flx_packet_scheduler_post_query(flxPacketScheduler *s, flxKey *key, gboolean immediately);
44 void flx_packet_scheduler_post_response(flxPacketScheduler *s, flxRecord *record, gboolean immediately);
46 void flx_packet_scheduler_incoming_query(flxPacketScheduler *s, flxKey *key);
47 void flx_packet_scheduler_incoming_response(flxPacketScheduler *s, flxRecord *record);
49 void flx_packet_scheduler_flush_responses(flxPacketScheduler *s);