dovecot/core-2.2: src/indexer/indexer-client.c annotate

annotate src/indexer/indexer-client.c @ 17130:add8c00fb3cc

Updated copyright notices to include year 2014.

author	Timo Sirainen <tss@iki.fi>
date	Tue, 04 Feb 2014 16:23:22 -0500
parents	36ef72481934
children	48d651b2e82a

rev	line source
17130 add8c00fb3cc Updated copyright notices to include year 2014. Timo Sirainen <tss@iki.fi> parents: 15715 diff changeset	1 /* Copyright (c) 2011-2014 Dovecot authors, see the included COPYING file */
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	2
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	3 #include "lib.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	4 #include "llist.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	5 #include "istream.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	6 #include "ostream.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	7 #include "strescape.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	8 #include "master-service.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	9 #include "indexer-queue.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	10 #include "indexer-client.h"
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	11
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	12 #include <stdlib.h>
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	13 #include <unistd.h>
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	14
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	15 #define MAX_INBUF_SIZE (1024*64)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	16
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	17 #define INDEXER_CLIENT_PROTOCOL_MAJOR_VERSION 1
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	18 #define INDEXER_CLIENT_PROTOCOL_MINOR_VERSION 0
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	19
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	20 struct indexer_client {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	21 struct indexer_client prev, next;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	22
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	23 int refcount;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	24 struct indexer_queue *queue;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	25
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	26 int fd;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	27 struct istream *input;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	28 struct ostream *output;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	29 struct io *io;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	30
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	31 unsigned int version_received:1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	32 unsigned int handshaked:1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	33 unsigned int destroyed:1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	34 };
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	35
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	36 struct indexer_client_request {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	37 struct indexer_client *client;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	38 unsigned int tag;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	39 };
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	40
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	41 struct indexer_client *clients = NULL;
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	42 static unsigned int clients_count = 0;
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	43
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	44 static void indexer_client_destroy(struct indexer_client *client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	45 static void indexer_client_ref(struct indexer_client *client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	46 static void indexer_client_unref(struct indexer_client *client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	47
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	48 static const char const
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	49 indexer_client_next_line(struct indexer_client *client)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	50 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	51 const char *line;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	52 char **args;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	53 unsigned int i;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	54
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	55 line = i_stream_next_line(client->input);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	56 if (line == NULL)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	57 return NULL;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	58
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	59 args = p_strsplit(pool_datastack_create(), line, "\t");
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	60 for (i = 0; args[i] != NULL; i++)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	61 args[i] = str_tabunescape(args[i]);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	62 return (void *)args;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	63 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	64
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	65 static int
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	66 indexer_client_request_queue(struct indexer_client *client, bool append,
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	67 const char const args, const char **error_r)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	68 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	69 struct indexer_client_request *ctx = NULL;
13199 8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	70 unsigned int tag, max_recent_msgs;
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	71
13261 ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	72 /* <tag> <user> <mailbox> [<max_recent_msgs>] */
13199 8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	73 if (str_array_length(args) < 3) {
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	74 *error_r = "Wrong parameter count";
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	75 return -1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	76 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	77 if (str_to_uint(args[0], &tag) < 0) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	78 *error_r = "Invalid tag";
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	79 return -1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	80 }
13199 8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	81 if (args[3] == NULL)
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	82 max_recent_msgs = 0;
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	83 else if (str_to_uint(args[3], &max_recent_msgs) < 0) {
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	84 *error_r = "Invalid max_recent_msgs";
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	85 return -1;
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	86 }
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	87
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	88 if (tag != 0) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	89 ctx = i_new(struct indexer_client_request, 1);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	90 ctx->client = client;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	91 ctx->tag = tag;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	92 indexer_client_ref(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	93 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	94
13199 8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	95 indexer_queue_append(client->queue, append, args[1], args[2],
8dcb7c7f66d5 doveadm index: Added -n parameter to specify max number of recent msgs to perform indexing. Timo Sirainen <tss@iki.fi> parents: 13192 diff changeset	96 max_recent_msgs, ctx);
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14133 diff changeset	97 o_stream_nsend_str(client->output, t_strdup_printf("%u\tOK\n", tag));
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	98 return 0;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	99 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	100
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	101 static int
13261 ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	102 indexer_client_request_optimize(struct indexer_client *client,
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	103 const char const args, const char **error_r)
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	104 {
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	105 struct indexer_client_request *ctx = NULL;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	106 unsigned int tag;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	107
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	108 /* <tag> <user> <mailbox> */
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	109 if (str_array_length(args) != 3) {
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	110 *error_r = "Wrong parameter count";
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	111 return -1;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	112 }
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	113 if (str_to_uint(args[0], &tag) < 0) {
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	114 *error_r = "Invalid tag";
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	115 return -1;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	116 }
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	117
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	118 if (tag != 0) {
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	119 ctx = i_new(struct indexer_client_request, 1);
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	120 ctx->client = client;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	121 ctx->tag = tag;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	122 indexer_client_ref(client);
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	123 }
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	124
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	125 indexer_queue_append_optimize(client->queue, args[1], args[2], ctx);
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14133 diff changeset	126 o_stream_nsend_str(client->output, t_strdup_printf("%u\tOK\n", tag));
13261 ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	127 return 0;
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	128 }
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	129
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	130 static int
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	131 indexer_client_request(struct indexer_client *client,
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	132 const char const args, const char **error_r)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	133 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	134 const char *cmd = args[0];
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	135
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	136 args++;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	137
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	138 if (strcmp(cmd, "APPEND") == 0)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	139 return indexer_client_request_queue(client, TRUE, args, error_r);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	140 else if (strcmp(cmd, "PREPEND") == 0)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	141 return indexer_client_request_queue(client, FALSE, args, error_r);
13261 ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	142 else if (strcmp(cmd, "OPTIMIZE") == 0)
ad429a8311f4 indexer: Added OPTIMIZE command to optimize fts index. Timo Sirainen <tss@iki.fi> parents: 13199 diff changeset	143 return indexer_client_request_optimize(client, args, error_r);
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	144 else {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	145 *error_r = t_strconcat("Unknown command: ", cmd, NULL);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	146 return -1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	147 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	148 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	149
14921 d3db2ba15d00 Removed CONTEXT_TYPE_SAFETY macro and reimplemented its functionality better. Timo Sirainen <tss@iki.fi> parents: 14681 diff changeset	150 static void indexer_client_input(struct indexer_client *client)
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	151 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	152 const char line, const args, error;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	153
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	154 switch (i_stream_read(client->input)) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	155 case -2:
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	156 i_error("BUG: Client connection sent too much data");
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	157 indexer_client_destroy(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	158 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	159 case -1:
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	160 indexer_client_destroy(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	161 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	162 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	163
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	164 if (!client->version_received) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	165 if ((line = i_stream_next_line(client->input)) == NULL)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	166 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	167
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	168 if (!version_string_verify(line, "indexer",
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	169 INDEXER_CLIENT_PROTOCOL_MAJOR_VERSION)) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	170 i_error("Client not compatible with this server "
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	171 "(mixed old and new binaries?)");
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	172 indexer_client_destroy(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	173 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	174 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	175 client->version_received = TRUE;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	176 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	177
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	178 while ((args = indexer_client_next_line(client)) != NULL) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	179 if (args[0] != NULL) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	180 if (indexer_client_request(client, args, &error) < 0) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	181 i_error("Client input error: %s", error);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	182 indexer_client_destroy(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	183 break;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	184 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	185 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	186 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	187 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	188
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	189 void indexer_client_status_callback(int percentage, void *context)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	190 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	191 struct indexer_client_request *ctx = context;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	192
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	193 T_BEGIN {
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14133 diff changeset	194 o_stream_nsend_str(ctx->client->output,
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	195 t_strdup_printf("%u\t%d\n", ctx->tag, percentage));
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	196 } T_END;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	197 if (percentage < 0 \|\| percentage == 100) {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	198 indexer_client_unref(ctx->client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	199 i_free(ctx);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	200 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	201 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	202
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	203 struct indexer_client *
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	204 indexer_client_create(int fd, struct indexer_queue *queue)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	205 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	206 struct indexer_client *client;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	207
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	208 client = i_new(struct indexer_client, 1);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	209 client->refcount = 1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	210 client->queue = queue;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	211 client->fd = fd;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	212 client->input = i_stream_create_fd(fd, MAX_INBUF_SIZE, FALSE);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	213 client->output = o_stream_create_fd(fd, (size_t)-1, FALSE);
14681 ca37d1577291 Added o_stream_nsend() and related functions to make delayed error handling safer. Timo Sirainen <tss@iki.fi>* parents: 14133 diff changeset	214 o_stream_set_no_error_handling(client->output, TRUE);
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	215 client->io = io_add(fd, IO_READ, indexer_client_input, client);
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	216
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	217 DLLIST_PREPEND(&clients, client);
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	218 clients_count++;
af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	219 indexer_refresh_proctitle();
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	220 return client;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	221 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	222
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	223 static void indexer_client_destroy(struct indexer_client *client)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	224 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	225 if (client->destroyed)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	226 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	227 client->destroyed = TRUE;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	228
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	229 DLLIST_REMOVE(&clients, client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	230
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	231 io_remove(&client->io);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	232 i_stream_close(client->input);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	233 o_stream_close(client->output);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	234 if (close(client->fd) < 0)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	235 i_error("close(client) failed: %m");
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	236 client->fd = -1;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	237 indexer_client_unref(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	238
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	239 clients_count--;
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	240 master_service_client_connection_destroyed(master_service);
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	241 indexer_refresh_proctitle();
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	242 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	243
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	244 static void indexer_client_ref(struct indexer_client *client)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	245 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	246 i_assert(client->refcount > 0);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	247
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	248 client->refcount++;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	249 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	250
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	251 static void indexer_client_unref(struct indexer_client *client)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	252 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	253 i_assert(client->refcount > 0);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	254
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	255 if (--client->refcount > 0)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	256 return;
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	257 i_stream_destroy(&client->input);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	258 o_stream_destroy(&client->output);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	259 i_free(client);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	260 }
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	261
13192 af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	262 unsigned int indexer_clients_get_count(void)
af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	263 {
af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	264 return clients_count;
af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	265 }
af8c5e56d098 indexer: If verbose_proctitle=yes, show how many clients/requests there are. Timo Sirainen <tss@iki.fi> parents: 13095 diff changeset	266
13084 0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	267 void indexer_clients_destroy_all(void)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	268 {
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	269 while (clients != NULL)
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	270 indexer_client_destroy(clients);
0faaceb2f83c Added "indexer" service, which uses worker processes to perform queued mailbox indexing. Timo Sirainen <tss@iki.fi> parents: diff changeset	271 }

Mercurial > dovecot > core-2.2

annotate src/indexer/indexer-client.c @ 17130:add8c00fb3cc