daemon/worker: cleanup errors; missed packet source

diff --git a/daemon/worker.c b/daemon/worker.c
index b814fe17f80248ca003e78abb625ae79d7e0f459..29e335df733901286cde750fcd24c4af2a31a7b8 100644 (file)
--- a/daemon/worker.c
+++ b/daemon/worker.c
@@ -1753,6 +1753,7 @@ int worker_submit(struct worker_ctx *worker, uv_handle_t *handle,
                        request_free(ctx);
                        return kr_error(ENOMEM);
                }
+               addr = NULL;
        } else if (query) { /* response from upstream */
                task = find_task(session, knot_wire_get_id(query->wire));
                if (task == NULL) {
@@ -1763,7 +1764,7 @@ int worker_submit(struct worker_ctx *worker, uv_handle_t *handle,
        assert(uv_is_closing(session->handle) == false);
 
        /* Consume input and produce next message */
-       return qr_task_step(task, NULL, query);
+       return qr_task_step(task, addr, query);
 }
 
 static int map_add_tcp_session(map_t *map, const struct sockaddr* addr,