Searched refs:qhead (Results 1 – 7 of 7) sorted by relevance
65 qhead = {0, 0}; in Init()122 Pointer head = qhead; in Dequeue()129 if (head != this->qhead) { in Dequeue()143 if (this->qhead.compare_exchange_strong(head, {next.index, head.version + 1})) { in Dequeue()153 Pointer head = qhead; in Empty()160 if (head == this->qhead && head.index == tail.index && next.index == -1) { in Empty()168 std::atomic<Pointer> qhead;
27 while (server->qhead) in ares__close_sockets()30 sendreq = server->qhead; in ares__close_sockets()31 server->qhead = sendreq->next; in ares__close_sockets()
222 if (!server->qhead || server->tcp_socket == ARES_SOCKET_BAD || in write_tcp_data()245 for (sendreq = server->qhead; sendreq; sendreq = sendreq->next) in write_tcp_data()254 for (sendreq = server->qhead; sendreq; sendreq = sendreq->next) in write_tcp_data()275 sendreq = server->qhead; in write_tcp_data()298 sendreq = server->qhead; in advance_tcp_send_queue()301 server->qhead = sendreq->next; in advance_tcp_send_queue()305 if (server->qhead == NULL) { in advance_tcp_send_queue()844 server->qhead = sendreq; in ares__send_query()1442 for (sendreq = server->qhead; sendreq; sendreq = sendreq->next) in end_query()
52 if (server->qhead) in ares_fds()
58 if (server->qhead && active_queries) in ares_getsock()
182 struct send_request *qhead; member
2648 server->qhead = NULL; in ares__init_servers_state()