Searched refs:conn (Results 1 - 25 of 221) sorted by relevance

123456789

/dovecot/src/lib-smtp/
H A D	smtp-server-connection.c	36 void smtp_server_connection_debug(struct smtp_server_connection *conn, argument 41 if (conn->set.debug) { 43 i_debug("%s-server: conn %s: %s", 44 smtp_protocol_name(conn->set.protocol), 45 smtp_server_connection_label(conn), 51 void smtp_server_connection_error(struct smtp_server_connection *conn, argument 57 i_error("%s-server: conn %s: %s", 58 smtp_protocol_name(conn->set.protocol), 59 smtp_server_connection_label(conn), 71 smtp_server_connection_output(struct smtp_server_connection *conn); 77 smtp_server_connection_update_stats(struct smtp_server_connection *conn) argument 86 smtp_server_connection_get_stats(struct smtp_server_connection *conn) argument 92 smtp_server_connection_input_halt(struct smtp_server_connection *conn) argument 97 smtp_server_connection_input_resume(struct smtp_server_connection *conn) argument 133 smtp_server_connection_input_lock(struct smtp_server_connection *conn) argument 139 smtp_server_connection_input_unlock(struct smtp_server_connection *conn) argument 146 smtp_server_connection_input_capture(struct smtp_server_connection *conn, smtp_server_input_callback_t *callback, void *context) argument 155 smtp_server_connection_update_rawlog(struct smtp_server_connection *conn) argument 174 smtp_server_connection_streams_changed(struct smtp_server_connection *conn) argument 184 smtp_server_connection_set_streams(struct smtp_server_connection *conn, struct istream *input, struct ostream *output) argument 205 smtp_server_connection_set_ssl_streams(struct smtp_server_connection *conn, struct istream *input, struct ostream *output) argument 215 smtp_server_connection_idle_timeout(struct smtp_server_connection *conn) argument 221 smtp_server_connection_timeout_stop(struct smtp_server_connection *conn) argument 230 smtp_server_connection_timeout_start(struct smtp_server_connection *conn) argument 245 smtp_server_connection_timeout_reset(struct smtp_server_connection *conn) argument 252 smtp_server_connection_timeout_update(struct smtp_server_connection *conn) argument 283 smtp_server_connection_ready(struct smtp_server_connection *conn) argument 313 struct smtp_server_connection *conn = local 321 smtp_server_connection_handle_command(struct smtp_server_connection *conn, const char *cmd_name, const char *cmd_params) argument 342 smtp_server_connection_ssl_init(struct smtp_server_connection *conn) argument 387 smtp_server_connection_handle_input(struct smtp_server_connection *conn) argument 538 struct smtp_server_connection *conn = local 583 smtp_server_connection_pending_command_data( struct smtp_server_connection *conn) argument 595 smtp_server_connection_handle_output_error( struct smtp_server_connection *conn) argument 617 smtp_server_connection_next_reply(struct smtp_server_connection *conn) argument 663 smtp_server_connection_cork(struct smtp_server_connection *conn) argument 670 smtp_server_connection_uncork(struct smtp_server_connection *conn) argument 683 smtp_server_connection_send_replies(struct smtp_server_connection *conn) argument 695 smtp_server_connection_flush(struct smtp_server_connection *conn) argument 709 smtp_server_connection_output(struct smtp_server_connection *conn) argument 730 smtp_server_connection_trigger_output( struct smtp_server_connection *conn) argument 770 struct smtp_server_connection *conn; local 887 smtp_server_connection_get_name(struct smtp_server_connection *conn) argument 929 struct smtp_server_connection *conn; local 958 struct smtp_server_connection *conn; local 983 smtp_server_connection_ref(struct smtp_server_connection *conn) argument 989 smtp_server_connection_get_disconnect_reason( struct smtp_server_connection *conn) argument 1008 smtp_server_connection_disconnect(struct smtp_server_connection *conn, const char *reason) argument 1050 struct smtp_server_connection *conn = *_conn; local 1088 smtp_server_connection_send_line(struct smtp_server_connection *conn, const char *fmt, ...) argument 1105 smtp_server_connection_reply_immediate( struct smtp_server_connection *conn, unsigned int status, const char *fmt, ...) argument 1130 smtp_server_connection_login(struct smtp_server_connection *conn, const char *username, const char *helo, const unsigned char *pdata, unsigned int pdata_len, bool ssl_secured) argument 1150 smtp_server_connection_start_pending(struct smtp_server_connection *conn) argument 1164 smtp_server_connection_start(struct smtp_server_connection *conn) argument 1170 smtp_server_connection_halt(struct smtp_server_connection *conn) argument 1178 smtp_server_connection_resume(struct smtp_server_connection *conn) argument 1188 struct smtp_server_connection *conn = *_conn; local 1203 struct smtp_server_connection *conn = *_conn; local 1219 smtp_server_connection_get_helo_data(struct smtp_server_connection *conn) argument 1225 smtp_server_connection_get_state(struct smtp_server_connection *conn) argument 1230 smtp_server_connection_set_state(struct smtp_server_connection *conn, enum smtp_server_state state) argument 1244 smtp_server_connection_get_security_string(struct smtp_server_connection *conn) argument 1251 smtp_server_connection_reset_state(struct smtp_server_connection *conn) argument 1278 smtp_server_connection_clear(struct smtp_server_connection *conn) argument 1288 smtp_server_connection_set_capabilities( struct smtp_server_connection *conn, enum smtp_capability capabilities) argument 1294 smtp_server_connection_get_context(struct smtp_server_connection *conn) argument 1299 smtp_server_connection_is_ssl_secured(struct smtp_server_connection *conn) argument 1304 smtp_server_connection_is_trusted(struct smtp_server_connection *conn) argument 1312 smtp_server_connection_get_protocol(struct smtp_server_connection *conn) argument 1318 smtp_server_connection_get_protocol_name(struct smtp_server_connection *conn) argument 1343 smtp_server_connection_get_transaction(struct smtp_server_connection *conn) argument 1349 smtp_server_connection_get_transaction_id(struct smtp_server_connection *conn) argument 1356 smtp_server_connection_get_proxy_data(struct smtp_server_connection *conn, struct smtp_proxy_data *proxy_data) argument 1379 smtp_server_connection_set_proxy_data(struct smtp_server_connection *conn, const struct smtp_proxy_data *proxy_data) argument 1411 smtp_server_connection_switch_ioloop(struct smtp_server_connection *conn) argument [all...]
H A D	smtp-client-connection.c	34 smtp_client_connection_ssl_init(struct smtp_client_connection *conn, 37 smtp_client_connection_handshake(struct smtp_client_connection *conn); 39 smtp_client_connection_established(struct smtp_client_connection *conn); 41 smtp_client_connection_start_transaction(struct smtp_client_connection *conn); 48 smtp_client_connection_get_capabilities(struct smtp_client_connection *conn) argument 50 return conn->capabilities; 54 struct smtp_client_connection *conn) 56 return conn->cap_size; 64 smpt_client_connection_label(struct smtp_client_connection *conn) argument 66 if (conn 53 smtp_client_connection_get_size_capability( struct smtp_client_connection *conn) argument 74 smtp_client_connection_debug(struct smtp_client_connection *conn, const char *format, ...) argument 90 smtp_client_connection_warning(struct smtp_client_connection *conn, const char *format, ...) argument 105 smtp_client_connection_error(struct smtp_client_connection *conn, const char *format, ...) argument 123 smtp_client_connection_commands_abort(struct smtp_client_connection *conn) argument 132 smtp_client_connection_commands_fail_reply(struct smtp_client_connection *conn, const struct smtp_reply *reply) argument 142 smtp_client_connection_commands_fail(struct smtp_client_connection *conn, unsigned int status, const char *error) argument 154 smtp_client_connection_login_callback(struct smtp_client_connection *conn, const struct smtp_reply *reply) argument 170 smtp_client_connection_login_fail(struct smtp_client_connection *conn, unsigned int status, const char *error) argument 182 smtp_client_connection_set_state(struct smtp_client_connection *conn, enum smtp_client_connection_state state) argument 188 smtp_client_connection_cork(struct smtp_client_connection *conn) argument 195 smtp_client_connection_uncork(struct smtp_client_connection *conn) argument 208 smtp_client_connection_get_state(struct smtp_client_connection *conn) argument 214 smtp_client_command_timeout(struct smtp_client_connection *conn) argument 226 smtp_client_connection_start_cmd_timeout( struct smtp_client_connection *conn) argument 254 smtp_client_connection_update_cmd_timeout( struct smtp_client_connection *conn) argument 286 smtp_client_connection_fail_reply(struct smtp_client_connection *conn, const struct smtp_reply *reply) argument 310 smtp_client_connection_fail(struct smtp_client_connection *conn, unsigned int status, const char *error) argument 324 smtp_client_connection_handle_output_error( struct smtp_client_connection *conn) argument 349 stmp_client_connection_ready(struct smtp_client_connection *conn, const struct smtp_reply *reply) argument 368 smtp_client_connection_clear_password(struct smtp_client_connection *conn) argument 380 smtp_client_connection_auth_cb(const struct smtp_reply *reply, struct smtp_client_connection *conn) argument 457 smtp_client_connection_get_sasl_mech(struct smtp_client_connection *conn, const struct dsasl_client_mech **mech_r, const char **error_r) argument 505 smtp_client_connection_authenticate(struct smtp_client_connection *conn) argument 600 smtp_client_connection_xclient_cb(const struct smtp_reply *reply, struct smtp_client_connection *conn) argument 622 smtp_client_connection_send_xclient(struct smtp_client_connection *conn, struct smtp_proxy_data *xclient) argument 706 smtp_client_connection_init_xclient(struct smtp_client_connection *conn) argument 718 smtp_client_connection_starttls_cb(const struct smtp_reply *reply, struct smtp_client_connection *conn) argument 745 smtp_client_connection_starttls(struct smtp_client_connection *conn) argument 775 smtp_client_connection_handshake_cb(const struct smtp_reply *reply, struct smtp_client_connection *conn) argument 883 smtp_client_connection_handshake(struct smtp_client_connection *conn) argument 917 smtp_client_connection_input_reply(struct smtp_client_connection *conn, const struct smtp_reply *reply) argument 971 struct smtp_client_connection *conn = local 1070 smtp_client_connection_output(struct smtp_client_connection *conn) argument 1095 smtp_client_connection_trigger_output(struct smtp_client_connection *conn) argument 1103 struct smtp_client_connection *conn = local 1138 smtp_client_connection_established(struct smtp_client_connection *conn) argument 1151 struct smtp_client_connection *conn = context; local 1170 smtp_client_connection_streams_changed(struct smtp_client_connection *conn) argument 1192 smtp_client_connection_init_ssl_ctx(struct smtp_client_connection *conn, const char **error_r) argument 1223 smtp_client_connection_ssl_init(struct smtp_client_connection *conn, const char **error_r) argument 1281 smtp_client_connection_delayed_connect_failure( struct smtp_client_connection *conn) argument 1296 struct smtp_client_connection *conn = local 1347 smtp_client_connection_connect_timeout(struct smtp_client_connection *conn) argument 1382 smtp_client_connection_do_connect(struct smtp_client_connection *conn) argument 1406 smtp_client_connection_connect_next_ip(struct smtp_client_connection *conn) argument 1432 smtp_client_connection_delayed_host_lookup_failure( struct smtp_client_connection *conn) argument 1446 smtp_client_connection_dns_callback(const struct dns_lookup_result *result, struct smtp_client_connection *conn) argument 1474 smtp_client_connection_connect(struct smtp_client_connection *conn, smtp_client_command_callback_t login_callback, void *login_context) argument 1565 smtp_client_connection_disconnect(struct smtp_client_connection *conn) argument 1615 struct smtp_client_connection *conn; local 1704 smtp_client_connection_ref(struct smtp_client_connection *conn) argument 1712 struct smtp_client_connection *conn = *_conn; local 1745 struct smtp_client_connection *conn = *_conn; local 1761 smtp_client_connection_switch_ioloop(struct smtp_client_connection *conn) argument 1789 smtp_client_connection_reset(struct smtp_client_connection *conn) argument 1802 smtp_client_connection_start_transaction(struct smtp_client_connection *conn) argument 1825 smtp_client_connection_add_transaction( struct smtp_client_connection *conn, struct smtp_client_transaction *trans) argument 1840 smtp_client_connection_abort_transaction( struct smtp_client_connection *conn, struct smtp_client_transaction *trans) argument 1865 smtp_client_connection_next_transaction( struct smtp_client_connection *conn, struct smtp_client_transaction *trans) argument [all...]
H A D	smtp-server-cmd-starttls.c	15 static int cmd_starttls_start(struct smtp_server_connection *conn) argument 17 const struct smtp_server_callbacks *callbacks = conn->callbacks; 19 smtp_server_connection_debug(conn, "Starting TLS"); 22 struct smtp_server_connection *tmp_conn = conn; 23 struct istream *input = conn->conn.input; 24 struct ostream *output = conn->conn.output; 33 smtp_server_connection_set_ssl_streams(conn, input, output); 34 } else if (smtp_server_connection_ssl_init(conn) < 54 cmd_starttls_output(struct smtp_server_connection *conn) argument 71 struct smtp_server_connection *conn = cmd->conn; local 103 struct smtp_server_connection *conn = cmd->conn; local 134 struct smtp_server_connection *conn = cmd->conn; local [all...]
/dovecot/src/imap-hibernate/
H A D	imap-master-connection.c	11 struct connection conn; member in struct:imap_master_connection 21 static void imap_master_connection_timeout(struct imap_master_connection *conn) argument 24 conn->conn.name, conn->conn.version_received ? "" : "not "); 25 imap_master_connection_deinit(&conn); 35 struct imap_master_connection *conn; local 37 conn = i_new(struct imap_master_connection, 1); 38 conn 59 struct imap_master_connection *conn = *_conn; local 73 struct imap_master_connection *conn = local 82 struct imap_master_connection *conn = local [all...]
/dovecot/src/lib-http/
H A D	http-server-connection.c	22 http_server_connection_disconnect(struct http_server_connection *conn, 26 http_server_connection_unref_is_closed(struct http_server_connection *conn); 33 http_server_connection_debug(struct http_server_connection *conn, 37 http_server_connection_debug(struct http_server_connection *conn, argument 42 if (conn->server->set.debug) { 45 i_debug("http-server: conn %s: %s", 46 http_server_connection_label(conn), t_strdup_vprintf(format, args)); 52 http_server_connection_error(struct http_server_connection *conn, 56 http_server_connection_error(struct http_server_connection *conn, argument 62 i_error("http-server: conn 72 http_server_connection_client_error(struct http_server_connection *conn, const char *format, ...) argument 92 http_server_connection_update_stats(struct http_server_connection *conn) argument 101 http_server_connection_get_stats(struct http_server_connection *conn) argument 108 http_server_connection_input_halt(struct http_server_connection *conn) argument 114 http_server_connection_input_resume(struct http_server_connection *conn) argument 123 http_server_connection_idle_timeout(struct http_server_connection *conn) argument 130 http_server_connection_timeout_stop(struct http_server_connection *conn) argument 136 http_server_connection_timeout_start(struct http_server_connection *conn) argument 145 http_server_connection_timeout_reset(struct http_server_connection *conn) argument 151 http_server_connection_shut_down(struct http_server_connection *conn) argument 161 http_server_connection_ready(struct http_server_connection *conn) argument 180 struct http_server_connection *conn = local 187 http_server_payload_finished(struct http_server_connection *conn) argument 194 http_server_payload_destroyed_timeout(struct http_server_connection *conn) argument 201 struct http_server_connection *conn = req->conn; local 280 http_server_connection_request_callback( struct http_server_connection *conn, struct http_server_request *req) argument 307 http_server_connection_handle_request(struct http_server_connection *conn, struct http_server_request *req) argument 397 http_server_connection_ssl_init(struct http_server_connection *conn) argument 425 http_server_connection_pipeline_is_full(struct http_server_connection *conn) argument 433 http_server_connection_pipeline_handle_full( struct http_server_connection *conn) argument 450 http_server_connection_check_input(struct http_server_connection *conn) argument 494 http_server_connection_finish_request(struct http_server_connection *conn) argument 541 struct http_server_connection *conn = local 728 http_server_connection_discard_input(struct http_server_connection *conn) argument 771 http_server_connection_discard_payload( struct http_server_connection *conn) argument 821 http_server_connection_handle_output_error( struct http_server_connection *conn) argument 846 http_server_connection_next_response(struct http_server_connection *conn) argument 912 http_server_connection_send_responses( struct http_server_connection *conn) argument 934 http_server_connection_flush(struct http_server_connection *conn) argument 949 http_server_connection_output(struct http_server_connection *conn) argument 1005 http_server_connection_trigger_responses( struct http_server_connection *conn) argument 1012 http_server_connection_pending_payload(struct http_server_connection *conn) argument 1041 struct http_server_connection *conn; local 1108 http_server_connection_ref(struct http_server_connection *conn) argument 1115 http_server_connection_disconnect(struct http_server_connection *conn, const char *reason) argument 1163 struct http_server_connection *conn = *_conn; local 1191 http_server_connection_unref_is_closed(struct http_server_connection *conn) argument 1203 struct http_server_connection *conn = *_conn; local 1212 struct http_server_connection *conn = *_conn; local 1232 http_server_connection_switch_ioloop(struct http_server_connection *conn) argument [all...]
H A D	http-client-connection.c	25 static void http_client_connection_ready(struct http_client_connection *conn); 29 http_client_connection_ref_request(struct http_client_connection *conn, argument 32 i_assert(req->conn == NULL); 33 req->conn = conn; 38 http_client_connection_unref_request(struct http_client_connection *conn, argument 43 i_assert(req->conn == conn); 44 req->conn = NULL; 49 http_client_connection_failure(struct http_client_connection *conn, argument 59 http_client_connection_count_pending(struct http_client_connection *conn) argument 68 http_client_connection_is_idle(struct http_client_connection *conn) argument 73 http_client_connection_is_active(struct http_client_connection *conn) argument 86 http_client_connection_retry_requests(struct http_client_connection *conn, unsigned int status, const char *error) argument 120 struct http_client_connection *conn = *_conn; local 148 struct http_client_connection *conn = *_conn; local 167 http_client_connection_abort_any_requests(struct http_client_connection *conn) argument 198 http_client_connection_get_timing_info(struct http_client_connection *conn) argument 226 struct http_client_connection *conn = *_conn; local 241 struct http_client_connection *conn = *_conn; local 272 http_client_connection_handle_output_error( struct http_client_connection *conn) argument 289 http_client_connection_check_ready(struct http_client_connection *conn) argument 335 http_client_connection_detach_peer(struct http_client_connection *conn) argument 366 http_client_connection_idle_timeout(struct http_client_connection *conn) argument 376 http_client_connection_lost_peer(struct http_client_connection *conn) argument 424 http_client_connection_check_idle(struct http_client_connection *conn) argument 488 http_client_connection_stop_idle(struct http_client_connection *conn) argument 505 http_client_connection_claim_idle(struct http_client_connection *conn, struct http_client_peer *peer) argument 523 http_client_connection_request_timeout(struct http_client_connection *conn) argument 530 http_client_connection_start_request_timeout( struct http_client_connection *conn) argument 560 http_client_connection_reset_request_timeout( struct http_client_connection *conn) argument 567 http_client_connection_stop_request_timeout( struct http_client_connection *conn) argument 574 http_client_connection_continue_timeout(struct http_client_connection *conn) argument 597 http_client_connection_next_request(struct http_client_connection *conn) argument 667 struct http_client_connection *conn = local 707 http_client_payload_finished(struct http_client_connection *conn) argument 716 http_client_payload_destroyed_timeout(struct http_client_connection *conn) argument 727 struct http_client_connection *conn = req->conn; local 769 http_client_connection_request_destroyed( struct http_client_connection *conn, struct http_client_request *req) argument 805 http_client_connection_return_response( struct http_client_connection *conn, struct http_client_request *req, struct http_response *response) argument 896 struct http_client_connection *conn = local 1202 http_client_connection_continue_request(struct http_client_connection *conn) argument 1255 http_client_connection_output(struct http_client_connection *conn) argument 1284 struct http_client_connection *conn = *_conn; local 1308 http_client_connection_ready(struct http_client_connection *conn) argument 1379 struct http_client_connection *conn = context; local 1398 http_client_connection_ssl_init(struct http_client_connection *conn, const char **error_r) argument 1451 struct http_client_connection *conn = local 1512 http_client_connection_delayed_connect_error(struct http_client_connection *conn) argument 1520 http_client_connect_timeout(struct http_client_connection *conn) argument 1527 http_client_connection_connect(struct http_client_connection *conn, unsigned int timeout_msecs) argument 1551 http_client_connect_tunnel_timeout(struct http_client_connection *conn) argument 1570 http_client_connection_tunnel_response(const struct http_response *response, struct http_client_connection *conn) argument 1599 http_client_connection_connect_tunnel(struct http_client_connection *conn, const struct ip_addr *ip, in_port_t port, unsigned int timeout_msecs) argument 1630 struct http_client_connection *conn; local 1707 http_client_connection_ref(struct http_client_connection *conn) argument 1714 http_client_connection_disconnect(struct http_client_connection *conn) argument 1776 struct http_client_connection *conn = *_conn; local 1816 struct http_client_connection *conn = *_conn; local 1825 http_client_connection_switch_ioloop(struct http_client_connection *conn) argument [all...]
/dovecot/src/director/
H A D	auth-connection.c	30 static void auth_connection_disconnected(struct auth_connection **conn); 32 static void auth_connection_input(struct auth_connection *conn) argument 36 switch (i_stream_read(conn->input)) { 42 auth_connection_disconnected(&conn); 48 auth_connection_disconnected(&conn); 52 while ((line = i_stream_next_line(conn->input)) != NULL) { 54 conn->callback(line, conn->context); 62 struct auth_connection *conn; local 64 conn 71 auth_connection_set_callback(struct auth_connection *conn, auth_input_callback *callback, void *context) argument 78 auth_connection_connect(struct auth_connection *conn) argument 97 struct auth_connection *conn = *_conn; local 116 struct auth_connection *conn = *_conn; local 123 auth_connection_get_output(struct auth_connection *conn) argument 132 struct auth_connection *conn = auth_connections; local [all...]
H A D	director-connection.h	23 void director_connection_deinit(struct director_connection **conn, 26 void director_connection_send(struct director_connection *conn, 28 void director_connection_set_synced(struct director_connection *conn, 30 void director_connection_ping(struct director_connection *conn); 32 const char *director_connection_get_name(struct director_connection *conn); 34 director_connection_get_host(struct director_connection *conn); 35 bool director_connection_is_handshaked(struct director_connection *conn); 36 bool director_connection_is_synced(struct director_connection *conn); 37 bool director_connection_is_incoming(struct director_connection *conn); 39 director_connection_get_minor_version(struct director_connection *conn); [all...]
/dovecot/src/lib-old-stats/
H A D	stats-connection.c	24 static bool stats_connection_open(struct stats_connection *conn) argument 26 if (conn->open_failed) 29 conn->fd = open(conn->path, O_WRONLY | O_NONBLOCK); 30 if (conn->fd == -1) { 31 i_error("stats: open(%s) failed: %m", conn->path); 32 conn->open_failed = TRUE; 41 struct stats_connection *conn; local 43 conn = i_new(struct stats_connection, 1); 44 conn 50 stats_connection_ref(struct stats_connection *conn) argument 57 struct stats_connection *conn = *_conn; local 69 stats_connection_send(struct stats_connection *conn, const string_t *str) argument [all...]
H A D	stats-connection.h	5 void stats_connection_ref(struct stats_connection *conn); 6 void stats_connection_unref(struct stats_connection **conn); 9 int stats_connection_send(struct stats_connection *conn, const string_t *str);
/dovecot/src/replication/aggregator/
H A D	notify-connection.c	17 #define CONNECTION_IS_FIFO(conn) \ 18 ((conn)->output == NULL) 32 static void notify_connection_unref(struct notify_connection *conn); 33 static void notify_connection_destroy(struct notify_connection *conn); 35 static bool notify_input_error(struct notify_connection *conn) argument 37 if (CONNECTION_IS_FIFO(conn)) 39 notify_connection_destroy(conn); 45 struct notify_connection *conn = context; local 47 o_stream_nsend_str(conn->output, success ? "+\n" : "-\n"); 48 notify_connection_unref(conn); 52 notify_input_line(struct notify_connection *conn, const char *line) argument 76 notify_input(struct notify_connection *conn) argument 106 struct notify_connection *conn; local 121 notify_connection_unref(struct notify_connection *conn) argument 132 notify_connection_destroy(struct notify_connection *conn) argument [all...]
H A D	replicator-connection.c	38 static void replicator_connection_disconnect(struct replicator_connection *conn); 41 replicator_input_line(struct replicator_connection *conn, const char *line) argument 53 context = hash_table_lookup(conn->requests, POINTER_CAST(id)); 58 hash_table_remove(conn->requests, POINTER_CAST(id)); 59 conn->callback(line[0] == '+', context); 63 static void replicator_input(struct replicator_connection *conn) argument 67 switch (i_stream_read(conn->input)) { 71 replicator_connection_disconnect(conn); 75 replicator_connection_disconnect(conn); 79 while ((line = i_stream_next_line(conn 84 replicator_send_buf(struct replicator_connection *conn, buffer_t *buf) argument 109 replicator_output(struct replicator_connection *conn) argument 136 replicator_connection_connect(struct replicator_connection *conn) argument 180 replicator_abort_all_requests(struct replicator_connection *conn) argument 192 replicator_connection_disconnect(struct replicator_connection *conn) argument 207 struct replicator_connection *conn; local 222 struct replicator_connection *conn; local 235 struct replicator_connection *conn; local 248 struct replicator_connection *conn = *_conn; local 263 replicator_send(struct replicator_connection *conn, enum replication_priority priority, const char *data) argument 283 replicator_connection_notify(struct replicator_connection *conn, const char *username, enum replication_priority priority) argument 309 replicator_connection_notify_sync(struct replicator_connection *conn, const char *username, void *context) argument [all...]
/dovecot/src/dict/
H A D	dict-connection.c	22 static int dict_connection_parse_handshake(struct dict_connection *conn, argument 37 if (str_parse_uint(line, &conn->minor_version, &line) < 0) 52 conn->value_type = (enum dict_data_type)value_type_num; 60 conn->username = i_strdup_until(username, line - 1); 70 conn->name = i_strdup(name); 74 static int dict_connection_dict_init(struct dict_connection *conn) argument 87 if (strcmp(strlist[i], conn->name) == 0) 93 conn->name); 99 dict_set.value_type = conn->value_type; 100 dict_set.username = conn 111 dict_connection_input_more(struct dict_connection *conn) argument 134 dict_connection_input(struct dict_connection *conn) argument 172 dict_connection_continue_input(struct dict_connection *conn) argument 182 dict_connection_output(struct dict_connection *conn) argument 197 struct dict_connection *conn; local 214 dict_connection_ref(struct dict_connection *conn) argument 220 dict_connection_unref(struct dict_connection *conn) argument 257 dict_connection_unref_safe_callback(struct dict_connection *conn) argument 263 dict_connection_unref_safe(struct dict_connection *conn) argument 278 dict_connection_destroy(struct dict_connection *conn) argument [all...]
/dovecot/src/auth/
H A D	auth-client-connection.c	31 static void auth_client_input(struct auth_client_connection *conn); 64 static void auth_client_send(struct auth_client_connection *conn, argument 73 o_stream_nsendv(conn->output, iov, 2); 75 if (o_stream_get_buffer_used_size(conn->output) >= 79 io_remove(&conn->io); 82 if (conn->auth->set->debug) { 84 conn->auth->set->debug_passwords ? 90 struct auth_client_connection *conn) 94 auth_client_connection_unref(&conn); 96 auth_client_send(conn, repl 89 auth_callback(const char *reply, struct auth_client_connection *conn) argument 101 auth_client_input_cpid(struct auth_client_connection *conn, const char *args) argument 153 auth_client_output(struct auth_client_connection *conn) argument 169 auth_line_hide_pass(struct auth_client_connection *conn, const char *line) argument 187 cont_line_hide_pass(struct auth_client_connection *conn, const char *line) argument 202 auth_client_cancel(struct auth_client_connection *conn, const char *line) argument 216 auth_client_handle_line(struct auth_client_connection *conn, const char *line) argument 245 auth_client_input(struct auth_client_connection *conn) argument 331 struct auth_client_connection *conn; local 373 struct auth_client_connection *conn = *_conn; local 400 struct auth_client_connection *conn = *_conn; local 425 struct auth_client_connection *conn = *_conn; local 439 struct auth_client_connection *conn; local 450 struct auth_client_connection *conn; local [all...]
H A D	db-sql.c	46 struct sql_connection *conn; local 48 for (conn = connections; conn != NULL; conn = conn->next) { 49 if (strcmp(conn->config_path, config_path) == 0) 50 return conn; 57 struct sql_connection *conn) 59 return parse_setting_from_defs(conn->pool, setting_defs, 60 &conn 56 parse_setting(const char *key, const char *value, struct sql_connection *conn) argument 65 struct sql_connection *conn; local 118 struct sql_connection *conn = *_conn; local 132 db_sql_connect(struct sql_connection *conn) argument 151 db_sql_check_userdb_warning(struct sql_connection *conn) argument [all...]
/dovecot/src/lib/
H A D	connection.c	18 static void connection_idle_timeout(struct connection *conn) argument 20 conn->disconnect_reason = CONNECTION_DISCONNECT_IDLE_TIMEOUT; 21 conn->list->v.destroy(conn); 24 static void connection_connect_timeout(struct connection *conn) argument 26 conn->disconnect_reason = CONNECTION_DISCONNECT_CONNECT_TIMEOUT; 27 conn->list->v.destroy(conn); 30 void connection_input_default(struct connection *conn) argument 37 switch (connection_input_read(conn)) { 72 connection_verify_version(struct connection *conn, const char *const *args) argument 104 connection_input_line_default(struct connection *conn, const char *line) argument 123 connection_input_halt(struct connection *conn) argument 128 connection_input_resume(struct connection *conn) argument 143 connection_init_streams(struct connection *conn) argument 189 connection_streams_changed(struct connection *conn) argument 199 connection_client_connected(struct connection *conn, bool success) argument 215 connection_init(struct connection_list *list, struct connection *conn) argument 232 connection_init_server(struct connection_list *list, struct connection *conn, const char *name, int fd_in, int fd_out) argument 247 connection_init_client_ip_from(struct connection_list *list, struct connection *conn, const struct ip_addr *ip, in_port_t port, const struct ip_addr *my_ip) argument 268 connection_init_client_ip(struct connection_list *list, struct connection *conn, const struct ip_addr *ip, in_port_t port) argument 275 connection_init_client_unix(struct connection_list *list, struct connection *conn, const char *path) argument 287 connection_init_from_streams(struct connection_list *list, struct connection *conn, const char *name, struct istream *input, struct ostream *output) argument 322 connection_socket_connected(struct connection *conn) argument 331 connection_client_connect(struct connection *conn) argument 366 connection_disconnect(struct connection *conn) argument 379 connection_deinit(struct connection *conn) argument 390 connection_input_read(struct connection *conn) argument 425 connection_disconnect_reason(struct connection *conn) argument 449 connection_input_timeout_reason(struct connection *conn) argument 467 connection_switch_ioloop_to(struct connection *conn, struct ioloop *ioloop) argument 481 connection_switch_ioloop(struct connection *conn) argument 514 struct connection *conn; local [all...]
/dovecot/src/indexer/
H A D	worker-connection.c	46 struct worker_connection *conn; local 48 conn = i_new(struct worker_connection, 1); 49 conn->refcount = 1; 50 conn->socket_path = i_strdup(socket_path); 51 conn->callback = callback; 52 conn->fd = -1; 53 i_array_init(&conn->request_contexts, 32); 54 conn->request_queue = aqueue_init(&conn->request_contexts.arr); 55 return conn; 58 worker_connection_unref(struct worker_connection *conn) argument 70 worker_connection_disconnect(struct worker_connection *conn) argument 108 struct worker_connection *conn = *_conn; local 117 worker_connection_input_line(struct worker_connection *conn, const char *line) argument 147 worker_connection_input(struct worker_connection *conn) argument 189 worker_connection_connect(struct worker_connection *conn) argument 206 worker_connection_is_connected(struct worker_connection *conn) argument 211 worker_connection_get_process_limit(struct worker_connection *conn, unsigned int *limit_r) argument 221 worker_connection_request(struct worker_connection *conn, const struct indexer_request *request, void *context) argument 257 worker_connection_is_busy(struct worker_connection *conn) argument 262 worker_connection_get_username(struct worker_connection *conn) argument [all...]
H A D	worker-connection.h	11 void worker_connection_destroy(struct worker_connection **conn); 13 int worker_connection_connect(struct worker_connection *conn); 15 bool worker_connection_is_connected(struct worker_connection *conn); 20 bool worker_connection_get_process_limit(struct worker_connection *conn, 26 void worker_connection_request(struct worker_connection *conn, 30 bool worker_connection_is_busy(struct worker_connection *conn); 33 const char *worker_connection_get_username(struct worker_connection *conn);
/dovecot/src/lib-imap-client/
H A D	imapc-connection.h	29 void imapc_connection_deinit(struct imapc_connection **conn); 31 void imapc_connection_connect(struct imapc_connection *conn); 32 void imapc_connection_set_no_reconnect(struct imapc_connection *conn); 33 void imapc_connection_disconnect(struct imapc_connection *conn); 34 void imapc_connection_disconnect_full(struct imapc_connection *conn, 36 void imapc_connection_try_reconnect(struct imapc_connection *conn, 40 void imapc_connection_abort_commands(struct imapc_connection *conn, 43 void imapc_connection_ioloop_changed(struct imapc_connection *conn); 44 void imapc_connection_input_pending(struct imapc_connection *conn); 47 imapc_connection_cmd(struct imapc_connection *conn, [all...]
H A D	imapc-connection.c	51 struct imapc_connection *conn; member in struct:imapc_command 98 int (*input_callback)(struct imapc_connection *conn); 148 static int imapc_connection_output(struct imapc_connection *conn); 149 static int imapc_connection_ssl_init(struct imapc_connection *conn); 151 static void imapc_command_send_more(struct imapc_connection *conn); 153 imapc_login_callback(struct imapc_connection *conn, 157 imapc_auth_ok(struct imapc_connection *conn) argument 159 if (conn->client->set.debug) 160 i_debug("imapc(%s): Authenticated successfully", conn->name); 162 if (conn 170 imapc_auth_failed(struct imapc_connection *conn, const struct imapc_command_reply *_reply, const char *error) argument 195 struct imapc_connection *conn; local 219 imapc_connection_ref(struct imapc_connection *conn) argument 228 struct imapc_connection *conn = *_conn; local 256 imapc_connection_ioloop_changed(struct imapc_connection *conn) argument 320 imapc_connection_abort_commands(struct imapc_connection *conn, struct imapc_client_mailbox *only_box, bool keep_retriable) argument 370 imapc_login_callback(struct imapc_connection *conn, const struct imapc_command_reply *reply) argument 377 imapc_connection_set_state(struct imapc_connection *conn, enum imapc_connection_state state) argument 420 imapc_connection_lfiles_free(struct imapc_connection *conn) argument 441 imapc_connection_disconnect_full(struct imapc_connection *conn, bool reconnecting) argument 490 imapc_connection_set_no_reconnect(struct imapc_connection *conn) argument 495 imapc_connection_disconnect(struct imapc_connection *conn) argument 500 imapc_connection_set_disconnected(struct imapc_connection *conn) argument 506 imapc_connection_can_reconnect(struct imapc_connection *conn) argument 523 imapc_connection_reconnect(struct imapc_connection *conn) argument 540 imapc_connection_try_reconnect(struct imapc_connection *conn, const char *errstr, unsigned int delay_msecs, bool connect_error) argument 572 imapc_connection_input_error(struct imapc_connection *conn, const char *fmt, ...) argument 606 imapc_connection_read_literal_init(struct imapc_connection *conn, uoff_t size, const struct imap_arg *args) argument 631 imapc_connection_read_literal(struct imapc_connection *conn) argument 668 imapc_connection_read_line_more(struct imapc_connection *conn, const struct imap_arg **imap_args_r) argument 708 imapc_connection_read_line(struct imapc_connection *conn, const struct imap_arg **imap_args_r) argument 736 imapc_connection_parse_capability(struct imapc_connection *conn, const char *value) argument 773 imapc_connection_handle_resp_text_code(struct imapc_connection *conn, const char *key, const char *value) argument 791 imapc_connection_handle_resp_text(struct imapc_connection *conn, const char *text, const char **key_r, const char **value_r) argument 817 imapc_connection_handle_imap_resp_text(struct imapc_connection *conn, const struct imap_arg *args, const char **key_r, const char **value_r) argument 851 imapc_connection_input_reset(struct imapc_connection *conn) argument 862 imapc_connection_auth_finish(struct imapc_connection *conn, const struct imapc_command_reply *reply) argument 883 struct imapc_connection *conn = context; local 892 struct imapc_connection *conn = context; local 911 struct imapc_connection *conn = context; local 946 imapc_connection_have_auth(struct imapc_connection *conn, const char *mech_name) argument 960 imapc_connection_get_sasl_mech(struct imapc_connection *conn, const struct dsasl_client_mech **mech_r, const char **error_r) argument 985 imapc_connection_authenticate(struct imapc_connection *conn) argument 1083 struct imapc_connection *conn = context; local 1109 imapc_connection_send_id(struct imapc_connection *conn) argument 1125 imapc_connection_starttls(struct imapc_connection *conn) argument 1152 struct imapc_connection *conn = context; local 1165 imapc_connection_input_banner(struct imapc_connection *conn) argument 1197 imapc_connection_input_untagged(struct imapc_connection *conn) argument 1281 imapc_connection_input_plus(struct imapc_connection *conn) argument 1323 imapc_connection_throttle_shrink_timeout(struct imapc_connection *conn) argument 1344 imapc_connection_throttle(struct imapc_connection *conn, const struct imapc_command_reply *reply) argument 1395 imapc_connection_input_tagged(struct imapc_connection *conn) argument 1525 imapc_connection_input_one(struct imapc_connection *conn) argument 1572 imapc_connection_input(struct imapc_connection *conn) argument 1618 struct imapc_connection *conn = context; local 1641 imapc_connection_ssl_init(struct imapc_connection *conn) argument 1699 imapc_connection_connected(struct imapc_connection *conn) argument 1728 imapc_connection_timeout(struct imapc_connection *conn) argument 1761 struct imapc_connection *conn = context; local 1766 imapc_connection_reset_idle(struct imapc_connection *conn) argument 1781 imapc_connection_connect_next_ip(struct imapc_connection *conn) argument 1838 imapc_connection_dns_callback(const struct dns_lookup_result *result, struct imapc_connection *conn) argument 1859 imapc_connection_connect(struct imapc_connection *conn) argument 1924 imapc_connection_input_pending(struct imapc_connection *conn) argument 1991 imapc_command_timeout(struct imapc_connection *conn) argument 2028 imapc_command_send_finished(struct imapc_connection *conn, struct imapc_command *cmd) argument 2061 imapc_command_try_send_stream(struct imapc_connection *conn, struct imapc_command *cmd) argument 2105 struct imapc_connection *conn = box->conn; local 2122 imapc_connection_is_throttled(struct imapc_connection *conn) argument 2147 imapc_command_send_more(struct imapc_connection *conn) argument 2269 imapc_connection_send_idle_done(struct imapc_connection *conn) argument 2283 struct imapc_connection *conn = cmd->conn; local 2309 imapc_connection_output(struct imapc_connection *conn) argument 2335 imapc_connection_cmd(struct imapc_connection *conn, imapc_command_callback_t *callback, void *context) argument 2453 imapc_connection_get_state(struct imapc_connection *conn) argument 2459 imapc_connection_get_capabilities(struct imapc_connection *conn) argument 2466 struct imapc_connection *conn = box->conn; local 2480 imapc_connection_get_mailbox(struct imapc_connection *conn) argument 2491 struct imapc_connection *conn = context; local 2498 imapc_connection_idle(struct imapc_connection *conn) argument [all...]
/dovecot/src/replication/replicator/
H A D	notify-connection.c	34 struct notify_connection *conn; member in struct:notify_sync_request 40 static void notify_connection_destroy(struct notify_connection *conn); 46 o_stream_nsend_str(request->conn->output, t_strdup_printf( 49 notify_connection_unref(&request->conn); 54 notify_connection_input_line(struct notify_connection *conn, const char *line) argument 76 (void)replicator_queue_add(conn->queue, args[1], priority); 82 request->conn = conn; 84 notify_connection_ref(conn); 85 replicator_queue_add_sync(conn 91 notify_connection_input(struct notify_connection *conn) argument 134 struct notify_connection *conn; local 152 notify_connection_destroy(struct notify_connection *conn) argument 171 notify_connection_ref(struct notify_connection *conn) argument 180 struct notify_connection *conn = *_conn; local [all...]
/dovecot/src/log/
H A D	doveadm-connection.c	22 static int doveadm_connection_send_errors(struct doveadm_connection *conn) argument 29 iter = log_error_buffer_iter_init(conn->errorbuf); 39 if (o_stream_send(conn->output, 49 static int doveadm_output(struct doveadm_connection *conn) argument 53 if ((ret = o_stream_flush(conn->output)) != 0) { 55 doveadm_connection_destroy(&conn); 62 struct doveadm_connection *conn; local 64 conn = i_new(struct doveadm_connection, 1); 65 conn->errorbuf = errorbuf; 66 conn 78 struct doveadm_connection *conn = *_conn; local [all...]
/dovecot/src/doveadm/
H A D	server-connection.c	72 static void server_connection_input(struct server_connection *conn); 73 static bool server_connection_input_one(struct server_connection *conn); 118 static int server_connection_send_cmd_input_more(struct server_connection *conn) argument 124 o_stream_set_max_buffer_size(conn->cmd_output, IO_BLOCK_SIZE); 125 res = o_stream_send_istream(conn->cmd_output, conn->cmd_input); 126 o_stream_set_max_buffer_size(conn->cmd_output, (size_t)-1); 137 i_stream_get_name(conn->cmd_input), 138 i_stream_get_error(conn->cmd_input)); 142 o_stream_get_name(conn 161 server_connection_send_cmd_input(struct server_connection *conn) argument 170 server_connection_output(struct server_connection *conn) argument 183 server_connection_callback(struct server_connection *conn, int exit_code, const char *error) argument 199 server_flush_field(struct server_connection *conn, string_t *str, const unsigned char *data, size_t size) argument 215 server_handle_input(struct server_connection *conn, const unsigned char *data, size_t size) argument 264 server_connection_authenticated(struct server_connection *conn) argument 275 server_connection_authenticate(struct server_connection *conn) argument 300 server_log_disconnect_error(struct server_connection *conn) argument 313 server_connection_print_log(struct server_connection *conn) argument 331 server_connection_start_multiplex(struct server_connection *conn) argument 343 server_connection_input(struct server_connection *conn) argument 405 server_connection_input_one(struct server_connection *conn) argument 462 server_connection_read_settings(struct server_connection *conn) argument 493 struct server_connection *conn = context; local 504 server_connection_init_ssl(struct server_connection *conn) argument 536 struct server_connection *conn; local 572 struct server_connection *conn = *_conn; local 619 server_connection_get_server(struct server_connection *conn) argument 624 server_connection_cmd(struct server_connection *conn, const char *line, struct istream *cmd_input, server_cmd_callback_t *callback, void *context) argument 646 server_connection_is_idle(struct server_connection *conn) argument 651 server_connection_extract(struct server_connection *conn, struct istream **istream_r, struct ostream **ostream_r, struct ssl_iostream **ssl_iostream_r) argument [all...]
H A D	client-connection.c	34 static int client_connection_read_settings(struct client_connection *conn) argument 48 input.local_ip = conn->local_ip; 49 input.remote_ip = conn->remote_ip; 57 conn->set = settings_dup(&doveadm_setting_parser_info, set, conn->pool); 61 int client_connection_init(struct client_connection *conn, argument 68 conn->type = type; 69 conn->pool = pool; 71 (void)net_getsockname(fd, &conn->local_ip, &conn 86 struct client_connection *conn = *_conn; local 102 client_connection_set_proctitle(struct client_connection *conn, const char *text) argument [all...]
/dovecot/src/lib-auth/
H A D	auth-server-connection.c	24 auth_server_connection_reconnect(struct auth_server_connection *conn, 28 auth_server_input_mech(struct auth_server_connection *conn, argument 33 if (conn->handshake_received) { 43 mech_desc.name = p_strdup(conn->pool, args[0]); 46 conn->has_plain_mech = TRUE; 64 array_append(&conn->available_auth_mechs, &mech_desc, 1); 69 auth_server_input_spid(struct auth_server_connection *conn, argument 72 if (conn->handshake_received) { 77 if (str_to_uint(args[0], &conn->server_pid) < 0) { 85 auth_server_input_cuid(struct auth_server_connection *conn, argument 101 auth_server_input_cookie(struct auth_server_connection *conn, const char *const *args) argument 112 auth_server_input_done(struct auth_server_connection *conn) argument 134 auth_server_lookup_request(struct auth_server_connection *conn, const char *id_arg, bool remove, struct auth_client_request **request_r) argument 159 auth_server_input_ok(struct auth_server_connection *conn, const char *const *args) argument 171 auth_server_input_cont(struct auth_server_connection *conn, const char *const *args) argument 188 auth_server_input_fail(struct auth_server_connection *conn, const char *const *args) argument 201 auth_server_connection_input_line(struct auth_server_connection *conn, const char *line) argument 236 auth_server_connection_input(struct auth_server_connection *conn) argument 296 struct auth_server_connection *conn; local 311 auth_server_connection_remove_requests(struct auth_server_connection *conn, const char *disconnect_reason) argument 348 auth_server_connection_disconnect(struct auth_server_connection *conn, const char *reason) argument 381 auth_server_reconnect_timeout(struct auth_server_connection *conn) argument 387 auth_server_connection_reconnect(struct auth_server_connection *conn, const char *disconnect_reason) argument 402 struct auth_server_connection *conn = *_conn; local 413 auth_client_handshake_timeout(struct auth_server_connection *conn) argument 421 auth_server_connection_connect(struct auth_server_connection *conn) argument 470 auth_server_connection_add_request(struct auth_server_connection *conn, struct auth_client_request *request) argument 487 auth_server_connection_remove_request(struct auth_server_connection *conn, unsigned int id) argument [all...]

Completed in 63 milliseconds

123456789

Indexes created Tue Jul 24 14:28:13 CEST 2018