]> git.meshlink.io Git - catta/blobdiff - psched.c
some preliminary work for adding legacy unicast and unicast response support
[catta] / psched.c
index 6f148ca77ad72921ce2c419053384e225a2d6e81..dcad5bbcf9b5ad835252a67c179e77c00d548731 100644 (file)
--- a/psched.c
+++ b/psched.c
@@ -8,7 +8,7 @@
 #define FLX_RESPONSE_HISTORY_MSEC 700
 #define FLX_RESPONSE_DEFER_MSEC 20
 #define FLX_RESPONSE_JITTER_MSEC 100
-#define FLX_PROBE_DEFER_MSEC 20
+#define FLX_PROBE_DEFER_MSEC 70
 
 flxPacketScheduler *flx_packet_scheduler_new(flxServer *server, flxInterface *i) {
     flxPacketScheduler *s;
@@ -111,7 +111,7 @@ static guint8* packet_add_query_job(flxPacketScheduler *s, flxDnsPacket *p, flxQ
     g_assert(p);
     g_assert(qj);
 
-    if ((d = flx_dns_packet_append_key(p, qj->key))) {
+    if ((d = flx_dns_packet_append_key(p, qj->key, FALSE))) {
         GTimeVal tv;
 
         qj->done = 1;
@@ -400,8 +400,8 @@ void flx_packet_scheduler_post_response(flxPacketScheduler *s, const flxAddress
         response_job_free(s, rj);
     }
 
-    g_message("ACCEPTED NEW RESPONSE [%s]", t = flx_record_to_string(record));
-    g_free(t);
+/*     g_message("ACCEPTED NEW RESPONSE [%s]", t = flx_record_to_string(record)); */
+/*     g_free(t); */
 
     /* Create a new job and schedule it */
     rj = response_job_new(s, record);
@@ -603,7 +603,7 @@ static guint8* packet_add_probe_query(flxPacketScheduler *s, flxDnsPacket *p, fl
 
     /* Create the probe query */
     k = flx_key_new(pj->record->key->name, pj->record->key->class, FLX_DNS_TYPE_ANY);
-    ret = flx_dns_packet_append_key(p, k);
+    ret = flx_dns_packet_append_key(p, k, FALSE);
     g_assert(ret);
 
     /* Mark this job for addition to the packet */