| /memcached-1.6.32/ |
| D | proxy_tls.c | 110 int err = SSL_get_error(be->ssl, n); in mcp_tls_connect() local
117 if (err == SSL_ERROR_WANT_READ || in mcp_tls_connect()
118 err == SSL_ERROR_WANT_WRITE) { in mcp_tls_connect()
141 int err = SSL_get_error(be->ssl, n); in mcp_tls_handshake() local
145 if (err == SSL_ERROR_WANT_READ || in mcp_tls_handshake()
146 err == SSL_ERROR_WANT_WRITE) { in mcp_tls_handshake()
179 int err = SSL_get_error(be->ssl, n); in mcp_tls_read() local
180 if (err == SSL_ERROR_WANT_WRITE || in mcp_tls_read()
181 err == SSL_ERROR_WANT_READ) { in mcp_tls_read()
237 if (err == SSL_ERROR_WANT_WRITE || in mcp_tls_writev()
[all …]
|
| D | tls.c | 76 int err = SSL_get_error(ssl, ret); in ssl_accept() local
77 if (err == SSL_ERROR_WANT_WRITE || err == SSL_ERROR_WANT_READ) { in ssl_accept()
84 if (err == SSL_ERROR_SYSCALL) { in ssl_accept()
169 int err = SSL_get_error(c->ssl, ret); in ssl_read() local
170 if (err == SSL_ERROR_WANT_WRITE || err == SSL_ERROR_WANT_READ) { in ssl_read()
175 } else if (err == SSL_ERROR_SYSCALL) { in ssl_read()
205 int err = SSL_get_error(c->ssl, ret); in ssl_write() local
206 if (err == SSL_ERROR_WANT_WRITE || err == SSL_ERROR_WANT_READ) { in ssl_write()
272 unsigned long err; in print_ssl_error() local
273 if ((err = ERR_get_error()) != 0) { in print_ssl_error()
[all …]
|
| D | proto_bin.h | 7 void write_bin_error(conn *c, protocol_binary_response_status err,
|
| D | proxy_network.c | 55 static void _reset_bad_backend(struct mcp_backendconn_s *be, enum proxy_be_failures err);
88 int err = 0; in _proxy_beconn_checkconnect() local
90 if (mcmc_check_nonblock_connect(be->client, &err) != MCMC_OK) { in _proxy_beconn_checkconnect()
828 static void _backend_flap_check(struct mcp_backendconn_s *be, enum proxy_be_failures err) { in _backend_flap_check() argument
832 switch (err) { in _backend_flap_check()
876 static void _reset_bad_backend(struct mcp_backendconn_s *be, enum proxy_be_failures err) { in _reset_bad_backend() argument
878 … resetting bad backend: [fd: %d] %s\n", __func__, mcmc_fd(be->client), proxy_be_failure_text[err]); in _reset_bad_backend()
900 …LOGGER_LOG(NULL, LOG_PROXYEVENTS, LOGGER_PROXY_BE_ERROR, NULL, proxy_be_failure_text[err], be->be_… in _reset_bad_backend()
916 _backend_flap_check(be, err); in _reset_bad_backend()
|
| D | proto_bin.c | 132 static void add_bin_header(conn *c, uint16_t err, uint8_t hdr_len, uint16_t key_len, uint32_t body_… in add_bin_header() argument
148 header->response.status = (uint16_t)htons(err); in add_bin_header()
176 void write_bin_error(conn *c, protocol_binary_response_status err, in write_bin_error() argument
181 switch (err) { in write_bin_error()
212 fprintf(stderr, ">%d UNHANDLED ERROR: %d\n", c->sfd, err); in write_bin_error()
221 add_bin_header(c, err, 0, 0, len); in write_bin_error()
|
| D | thread.c | 728 int napi_id, err, i; in select_thread_by_napi_id() local
733 err = getsockopt(sfd, SOL_SOCKET, SO_INCOMING_NAPI_ID, &napi_id, &len); in select_thread_by_napi_id()
734 if ((err == -1) || (napi_id == 0)) { in select_thread_by_napi_id()
|
| D | testapp.c | 721 int err = SSL_get_error(c->ssl, ret); in connect_server() local
722 if (err == SSL_ERROR_SYSCALL || err == SSL_ERROR_SSL) { in connect_server()
2196 ssize_t err = conns[ii]->write(conns[ii], command, cmdlen); in test_issue_101() local
2197 if (err == -1) { in test_issue_101()
|
| /memcached-1.6.32/scripts/ |
| D | memcached-automove | 235 err = sys.exc_info() variable
236 print("disconnected:", err[0], err[1])
|
| D | memcached-automove-extstore | 316 err = sys.exc_info() variable
317 print("disconnected:", err[0], err[1])
|
| /memcached-1.6.32/vendor/mcmc/ |
| D | mcmc.c | 779 int mcmc_check_nonblock_connect(void *c, int *err) { in mcmc_check_nonblock_connect() argument
781 socklen_t errsize = sizeof(*err); in mcmc_check_nonblock_connect()
782 if (getsockopt(ctx->fd, SOL_SOCKET, SO_ERROR, err, &errsize) == 0) { in mcmc_check_nonblock_connect()
783 if (*err == 0) { in mcmc_check_nonblock_connect()
788 *err = errno; in mcmc_check_nonblock_connect()
|
| D | mcmc.h | 127 int mcmc_check_nonblock_connect(void *c, int *err);
|