#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;
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;
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);
/* 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 */
continue;
/* Does the record match the probe? */
- if (k->class != pj->record->key->class || flx_domain_equal(k->name, pj->record->key->name))
+ if (k->class != pj->record->key->class || !flx_domain_equal(k->name, pj->record->key->name))
continue;
/* This job wouldn't fit in */