Cross Reference: /dovecot/src/plugins/replication/replication-plugin.c

Lines Matching defs:ruser
106 	struct replication_user *ruser = REPLICATION_USER_CONTEXT(user);
109 	i_assert(ruser != NULL);
110 	i_assert(ruser->priority != REPLICATION_PRIORITY_NONE);
111 	i_assert(ruser->priority != REPLICATION_PRIORITY_SYNC);
113 	if ((ret = replication_fifo_notify(user, ruser->priority)) < 0 &&
116 		ret = replication_fifo_notify(user, ruser->priority);
119 		timeout_remove(&ruser->to);
120 		ruser->priority = REPLICATION_PRIORITY_NONE;
126 	struct replication_user *ruser = REPLICATION_USER_CONTEXT(user);
133 	i_assert(ruser != NULL);
135 	fd = net_connect_unix(ruser->socket_path);
137 		i_error("net_connect_unix(%s) failed: %m", ruser->socket_path);
146 	alarm(ruser->sync_secs);
148 		i_error("write(%s) failed: %m", ruser->socket_path);
155 					ruser->socket_path);
159 					  user->username, ruser->sync_secs);
162 			i_error("read(%s) failed: EOF", ruser->socket_path);
178 		i_error("close(%s) failed: %m", ruser->socket_path);
186 	struct replication_user *ruser;
188 	ruser = REPLICATION_USER_CONTEXT(ns->user);
189 	if (ruser == NULL)
199 			timeout_remove(&ruser->to);
200 			ruser->priority = REPLICATION_PRIORITY_NONE;
207 	if (ruser->priority < priority)
208 		ruser->priority = priority;
209 	if (ruser->to == NULL) {
210 		ruser->to = timeout_add_short(REPLICATION_NOTIFY_DELAY_MSECS,
269 	struct replication_user *ruser =
273 	if (ruser != NULL && !ctx->sync_trans &&
276 			ruser->sync_secs == 0 ? REPLICATION_PRIORITY_HIGH :
315 	struct replication_user *ruser = REPLICATION_USER_CONTEXT(user);
317 	i_assert(ruser != NULL);
319 	if (ruser->to != NULL) {
321 		if (ruser->to != NULL) {
324 			timeout_remove(&ruser->to);
328 	ruser->module_ctx.super.deinit(user);
334 	struct replication_user *ruser;
352 	ruser = p_new(user->pool, struct replication_user, 1);
353 	ruser->module_ctx.super = *v;
354 	user->vlast = &ruser->module_ctx.super;
356 	MODULE_CONTEXT_SET(user, replication_user_module, ruser);
364 	ruser->socket_path = p_strconcat(user->pool, user->set->base_dir,
367 	if (value != NULL && str_to_uint(value, &ruser->sync_secs) < 0) {