Searched refs:requests (Results 1 - 13 of 13) sorted by relevance

/dovecot/src/indexer/
H A Dindexer-queue.c14 HASH_TABLE(struct indexer_request *, struct indexer_request *) requests; member in struct:indexer_queue
38 hash_table_create(&queue->requests, default_pool, 0,
51 hash_table_destroy(&queue->requests);
69 return hash_table_lookup(queue->requests, &lookup_request);
98 hash_table_insert(queue->requests, request, request);
229 hash_table_remove(queue->requests, request);
244 /* remove all reindex-markers so when the current requests finish
247 iter = hash_table_iterate_init(queue->requests);
248 while (hash_table_iterate(iter, queue->requests, &request, &request))
265 return hash_table_count(queue->requests);
[all...]
/dovecot/src/lib-auth/
H A Dauth-server-connection.h23 HASH_TABLE(void *, struct auth_client_request *) requests; member in struct:auth_server_connection
H A Dauth-server-connection.c146 request = hash_table_lookup(conn->requests, POINTER_CAST(id));
152 hash_table_remove(conn->requests, POINTER_CAST(id));
305 hash_table_create_direct(&conn->requests, pool, 100);
321 if (hash_table_count(conn->requests) == 0)
324 iter = hash_table_iterate_init(conn->requests);
325 while (hash_table_iterate(iter, conn->requests, &key, &request)) {
338 hash_table_clear(conn->requests, FALSE);
341 i_warning("Auth connection closed with %u pending requests "
407 i_assert(hash_table_count(conn->requests) == 0);
408 hash_table_destroy(&conn->requests);
[all...]
/dovecot/src/replication/aggregator/
H A Dreplicator-connection.c33 HASH_TABLE(void *, void *) requests; member in struct:replicator_connection
53 context = hash_table_lookup(conn->requests, POINTER_CAST(id));
58 hash_table_remove(conn->requests, POINTER_CAST(id));
185 iter = hash_table_iterate_init(conn->requests);
186 while (hash_table_iterate(iter, conn->requests, &key, &value))
189 hash_table_clear(conn->requests, TRUE);
212 hash_table_create_direct(&conn->requests, default_pool, 0);
258 hash_table_destroy(&conn->requests);
318 hash_table_insert(conn->requests, POINTER_CAST(id), context);
/dovecot/src/lib-master/
H A Dmaster-login-auth.c51 HASH_TABLE(void *, struct master_login_auth_request *) requests; member in struct:master_login_auth
52 /* linked list of requests, ordered by create_stamp */
78 hash_table_create_direct(&auth->requests, pool, 0);
106 hash_table_clear(auth->requests, FALSE);
130 hash_table_destroy(&auth->requests);
163 hash_table_remove(auth->requests, POINTER_CAST(request->id));
193 hash_table_remove(auth->requests, POINTER_CAST(request->id));
208 request = hash_table_lookup(auth->requests, POINTER_CAST(id));
484 i_assert(hash_table_lookup(auth->requests, POINTER_CAST(id)) == NULL);
485 hash_table_insert(auth->requests, POINTER_CAS
[all...]
/dovecot/src/lib-http/
H A Dhttp-client-queue.c95 i_array_init(&queue->requests, 16);
140 /* abort all requests */
143 array_free(&queue->requests);
171 /* abort requests */
172 req_arr = &queue->requests;
186 /* all queues should be empty now... unless new requests were submitted
192 array_count(&queue->requests));
336 "(%u requests pending)",
339 /* handle requests; */
357 "(%u requests pendin
969 struct http_client_request *const *requests; local
[all...]
H A Dhttp-client-host.c386 unsigned int requests = 0; local
390 requests += http_client_queue_host_lookup_done(*queue_idx);
393 if (requests == 0 && client->waiting)
441 unsigned int requests = 0; local
444 requests += http_client_queue_requests_active(*queue_idx);
447 return (requests > 0);
H A Dhttp-client-peer.c467 for them before failing the requests. remember that we had
828 unsigned int num_requests = 0, num_urgent = 0, requests, urgent; local
831 requests = http_client_queue_requests_pending(*queue, &urgent);
833 num_requests += requests;
847 /* no connections or pending requests; disconnect immediately */
874 /* FIXME: limit the number of requests handled in one run to prevent
892 /* don't do anything unless we have pending requests */
896 "No requests to service for this peer "
960 "Using %u idle connections to handle %u requests "
983 /* don't continue unless we have more pending requests */
[all...]
H A Dhttp-client-private.h190 /* requests that have been sent, waiting for response */
204 bool output_broken:1; /* output is broken; no more requests */
315 /* all requests associated to this queue
317 ARRAY_TYPE(http_client_request) requests; member in struct:http_client_queue
319 /* delayed requests waiting to be released after delay */
322 /* requests pending in queue to be picked up by connections */
375 /* list of failed requests that are waiting for ioloop */
/dovecot/src/auth/
H A Dauth-request-handler.c27 HASH_TABLE(void *, struct auth_request *) requests; member in struct:auth_request_handler
59 hash_table_create_direct(&handler->requests, pool, 0);
70 return hash_table_count(handler->requests);
79 iter = hash_table_iterate_init(handler->requests);
80 while (hash_table_iterate(iter, handler->requests, &key, &auth_request)) {
87 hash_table_remove(handler->requests, key);
110 i_assert(hash_table_count(handler->requests) == 0);
112 /* notify parent that we're done with all requests */
115 hash_table_destroy(&handler->requests);
154 hash_table_remove(handler->requests, POINTER_CAS
[all...]
H A Ddb-ldap.c366 /* no non-pending requests */
370 /* wait until server has replied to some requests */
381 /* we can't do binds until all existing requests are finished */
540 struct ldap_request *const *requests, *request = NULL; local
547 requests = array_idx(&conn->request_array, 0);
549 request = requests[aqueue_idx(conn->request_queue, i)];
846 /* see if there are timed out requests */
952 /* send more requests */
1312 /* no requests left, remove this timeout handler */
1319 struct ldap_request *const *requests, *reques local
[all...]
/dovecot/src/lib-storage/index/imapc/
H A Dimapc-mail-fetch.c58 struct imapc_fetch_request *const *requests; local
74 requests = array_get(&mbox->fetch_requests, &count);
76 if (requests[i] == request) {
/dovecot/src/doveadm/dsync/
H A Ddsync-mailbox-import.c2294 const struct dsync_mail_request *requests; local
2297 requests = array_get(&importer->mail_requests, &count);
2300 return &requests[importer->mail_request_idx++];

Completed in 41 milliseconds