diff --git a/daemon/defer.c b/daemon/defer.c index 5e596052c..78bb50e9f 100644 --- a/daemon/defer.c +++ b/daemon/defer.c @@ -56,7 +56,7 @@ #define IDLE_TIMEOUT 1000000 // ns (THREAD_CPUTIME); if exceeded, continue processing after next poll phase #define PHASE_UDP_TIMEOUT 400000 // ns (THREAD_CPUTIME); switch between udp, non-udp phases #define PHASE_NON_UDP_TIMEOUT 400000 // ns (THREAD_CPUTIME); after timeout or emptying queue -#define MAX_WAITING_REQS_SIZE 0 // bytes; if exceeded, some deferred requests are processed in poll phase +#define MAX_WAITING_REQS_SIZE 0 // XXX bytes; if exceeded, some deferred requests are processed in poll phase // single TCP allocates more than 64KiB wire buffer // TODO check whether all important allocations are counted; // different things are not counted: tasks and subsessions (not deferred after created), uv handles, queues overhead, ...; @@ -416,6 +416,8 @@ static enum protolayer_iter_cb_result pl_defer_unwrap( if (!defer || ctx->session->outgoing) return protolayer_continue(ctx); + return protolayer_continue(ctx); // XXX + defer_sample_addr((const union kr_sockaddr *)ctx->comm->comm_addr, ctx->session->stream); struct pl_defer_iter_data *data = iter_data; struct pl_defer_sess_data *sdata = sess_data; @@ -433,7 +435,7 @@ static enum protolayer_iter_cb_result pl_defer_unwrap( } int priority = classify((const union kr_sockaddr *)ctx->comm->comm_addr, ctx->session->stream); - priority = -1; + priority = -1; // XXX if (priority == -1) { VERBOSE_LOG(" CONTINUE\n");