}
}
-static uv_stream_t *handle_alloc(uv_loop_t *loop)
-{
- uv_stream_t *handle = calloc(1, sizeof(uv_handles_t));
- if (!handle) {
- return NULL;
- }
-
- return handle;
-}
-
static uv_stream_t *handle_borrow(uv_loop_t *loop)
{
struct worker_ctx *worker = loop->data;
static void tcp_timeout_trigger(uv_timer_t *timer)
{
struct session *session = timer->data;
- struct worker_ctx *worker = timer->loop->data;
assert(session->outgoing == false);
if (session->tasks.len > 0) {
if (!handle) {
return;
}
- struct session *session = handle->data;
uv_loop_t *loop = handle->loop;
if (loop && loop->data) {
struct worker_ctx *worker = loop->data;
{
assert(h);
- const size_t size = sizeof(uv_handles_t);
if (worker->pool_iohandles.len < MP_FREELIST_SIZE) {
array_push(worker->pool_iohandles, h);
- kr_asan_poison(h, size);
+ kr_asan_poison(h, sizeof(uv_handles_t));
} else {
free(h);
}
{
assert(r);
- const size_t size = sizeof(uv_reqs_t);
if (worker->pool_ioreqs.len < MP_FREELIST_SIZE) {
array_push(worker->pool_ioreqs, r);
- kr_asan_poison(r, size);
+ kr_asan_poison(r, sizeof(uv_reqs_t));
} else {
free(r);
}
qry->secret = leader_qry->secret;
leader_qry->secret = 0; /* Next will be already decoded */
}
- struct session *follower_source_session = follower->ctx->source.session;
qr_task_step(follower, packet_source, pkt);
qr_task_unref(follower);
}