Searched refs:request_queue (Results 1 - 5 of 5) sorted by relevance

/dovecot/src/indexer/
H A Dworker-connection.c36 struct aqueue *request_queue; member in struct:worker_connection
54 conn->request_queue = aqueue_init(&conn->request_contexts.arr);
64 aqueue_deinit(&conn->request_queue);
72 unsigned int i, count = aqueue_count(conn->request_queue);
96 aqueue_idx(conn->request_queue, 0));
99 aqueue_delete_tail(conn->request_queue);
122 if (aqueue_count(conn->request_queue) == 0) {
134 aqueue_idx(conn->request_queue, 0));
138 aqueue_delete_tail(conn->request_queue);
139 if (aqueue_count(conn->request_queue)
[all...]
/dovecot/src/lib-ldap/
H A Dldap-connection.c30 unsigned int n = aqueue_count(conn->request_queue);
34 aqueue_idx(conn->request_queue, i));
183 conn->request_queue = aqueue_init(&conn->request_array.arr);
197 unsigned int n = aqueue_count(conn->request_queue);
202 aqueue_idx(conn->request_queue, i));
259 n = aqueue_count(conn->request_queue);
264 aqueue_idx(conn->request_queue, i));
290 aqueue_delete(conn->request_queue, i);
309 aqueue_append(conn->request_queue, &req);
423 unsigned int n = aqueue_count(req->conn->request_queue);
[all...]
H A Dldap-private.h68 struct aqueue *request_queue; member in struct:ldap_connection
/dovecot/src/auth/
H A Ddb-ldap.c365 if (conn->pending_count == aqueue_count(conn->request_queue)) {
375 aqueue_idx(conn->request_queue,
422 aqueue_delete_tail(conn->request_queue);
435 count = aqueue_count(conn->request_queue);
440 aqueue_idx(conn->request_queue, 0));
459 aqueue_append(conn->request_queue, &request);
508 while (aqueue_count(conn->request_queue) > 0 && max_count > 0) {
510 aqueue_idx(conn->request_queue, 0));
518 aqueue_delete_tail(conn->request_queue);
543 count = aqueue_count(conn->request_queue);
[all...]
H A Ddb-ldap.h172 struct aqueue *request_queue; member in struct:ldap_connection

Completed in 12 milliseconds