X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=server.h;fp=server.h;h=4134638dd6fd88d5dae95d787f9bf1142d4c076c;hb=927f8b06fe3550f45c8d7b119acaa77d9b22888c;hp=f1a15fc9efc4e8ed2c4535f37ceeb2a439f51b81;hpb=4de18a7015ed77eac277bee669d4c8d9dae60b89;p=catta

diff --git a/server.h b/server.h
index f1a15fc..4134638 100644
--- a/server.h
+++ b/server.h
@@ -3,6 +3,7 @@
 
 #include "flx.h"
 #include "iface.h"
+#include "prioq.h"
 
 struct _flxEntry;
 typedef struct _flxEntry flxEntry;
@@ -21,31 +22,29 @@ struct _flxEntry {
 
 typedef struct _flxQueryJob {
     gint ref;
+    GTimeVal time;
     flxQuery query;
 } flxQueryJob;
 
-struct _flxQueryJobInstance;
-typedef struct _flxQueryJobInstance flxQueryJobInstance;
-struct _flxQueryJobInstance {
+typedef struct _flxQueryJobInstance {
+    flxPrioQueueNode *node;
     flxQueryJob *job;
     gint interface;
     guchar protocol;
-    flxQueryJobInstance *next, *prev;
-};
+} flxQueryJobInstance;
 
 typedef struct _flxResponseJob {
     gint ref;
+    GTimeVal time;
     flxRecord response;
 } flxResponseJob;
 
-struct _flxResponseJobInstance;
-typedef struct _flxResponseJobInstance flxResponseJobInstance;
-struct _flxResponseJobInstance {
+typedef struct _flxResponseJobInstance {
+    flxPrioQueueNode *node;
     flxResponseJob *job;
     gint interface;
     guchar protocol;
-    flxResponseJob *next, *prev;
-};
+} flxResponseJobInstance;
 
 struct _flxServer {
     GMainContext *context;
@@ -58,20 +57,19 @@ struct _flxServer {
 
     flxEntry *entries;
 
-    flxResponseJobInstance *first_response_job, *last_response_job;
-    flxQueryJobInstance *first_query_job, *last_query_job;
+    flxPrioQueue *query_job_queue;
+    flxPrioQueue *response_job_queue;
 };
 
 flxQueryJob* flx_query_job_new(void);
 flxQueryJob* flx_query_job_ref(flxQueryJob *job);
 void flx_query_job_unref(flxQueryJob *job);
 
-void flx_server_post_query_job(flxServer *s, gint interface, guchar protocol, const flxQuery *q);
+void flx_server_post_query_job(flxServer *s, gint interface, guchar protocol, const GTimeVal *tv, const flxQuery *q);
 void flx_server_drop_query_job(flxServer *s, gint interface, guchar protocol, const flxQuery *q);
 
 void flx_server_remove_query_job_instance(flxServer *s, flxQueryJobInstance *i);
 
 gboolean flx_query_equal(const flxQuery *a, const flxQuery *b);
 
-
 #endif