]> git.ipfire.org Git - thirdparty/unbound.git/commitdiff
pending_tcp_query: cleaner comments.
authorW.C.A. Wijngaards <wouter@nlnetlabs.nl>
Thu, 25 Jun 2020 14:22:43 +0000 (16:22 +0200)
committerW.C.A. Wijngaards <wouter@nlnetlabs.nl>
Thu, 25 Jun 2020 14:22:43 +0000 (16:22 +0200)
services/outside_network.c

index a010e3323924856eba6ae3b438a17db0fbf9c044..dad448b522fdf34d905f8b51f170d05c84631583 100644 (file)
@@ -1957,9 +1957,9 @@ pending_tcp_query(struct serviced_query* sq, sldns_buffer* packet,
        if(pend) {
                /* we have a buffer available right now */
                if(reuse) {
-                       verbose(5, "pending_tcp_query: reuse, store");
                        /* reuse existing fd, write query and continue */
                        /* store query in tree by id */
+                       verbose(5, "pending_tcp_query: reuse, store");
                        w->next_waiting = (void*)pend;
                        reuse_tree_by_id_insert(&pend->reuse, w);
                        /* can we write right now? */
@@ -1974,9 +1974,9 @@ pending_tcp_query(struct serviced_query* sq, sldns_buffer* packet,
                                reuse_write_wait_push_back(&pend->reuse, w);
                        }
                } else {
-                       verbose(5, "pending_tcp_query: new fd, connect");
                        /* create new fd and connect to addr, setup to
                         * write query */
+                       verbose(5, "pending_tcp_query: new fd, connect");
                        rbtree_init(&pend->reuse.tree_by_id, reuse_id_cmp);
                        pend->reuse.pending = pend;
                        memcpy(&pend->reuse.addr, &sq->addr, sq->addrlen);
@@ -1987,8 +1987,10 @@ pending_tcp_query(struct serviced_query* sq, sldns_buffer* packet,
                        }
                }
        } else {
-               struct timeval tv;
                /* queue up */
+               /* waiting for a buffer on the outside network buffer wait
+                * list */
+               struct timeval tv;
                verbose(5, "pending_tcp_query: queue to wait");
                w->next_waiting = NULL;
                if(sq->outnet->tcp_wait_last)