Lines Matching refs:read
255 if (read(fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in proxy_event_beconn()
261 if (read(fd, buf, 1) != 1) { in proxy_event_beconn()
367 if (read(fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) { in proxy_event_handler()
380 if (read(fd, buf, 1) != 1) { in proxy_event_handler()
430 event_add(&be->write_event, &be->tunables.read); in _start_write_event()
444 event_add(&be->timeout_event, &be->tunables.read); in _start_timeout_event()
1071 struct timeval tmp_time = be->tunables.read; in proxy_bevalidate_tls_handler()
1084 int read = mcp_tls_read(be); in proxy_bevalidate_tls_handler() local
1086 if (read > 0) { in proxy_bevalidate_tls_handler()
1109 } else if (read == 0) { in proxy_bevalidate_tls_handler()
1113 } else if (read == MCP_TLS_NEEDIO) { in proxy_bevalidate_tls_handler()
1117 } else if (read == MCP_TLS_ERR) { in proxy_bevalidate_tls_handler()
1161 struct timeval tmp_time = be->tunables.read; in proxy_beconn_tls_handler()
1213 struct timeval tmp_time = be->tunables.read; in proxy_beconn_handler()
1254 … int read = recv(mcmc_fd(be->client), be->rbuf + be->rbufused, READ_BUFFER_SIZE - be->rbufused, 0); in proxy_beconn_handler() local
1255 if (read > 0) { in proxy_beconn_handler()
1257 be->rbufused += read; in proxy_beconn_handler()
1279 } else if (read == 0) { in proxy_beconn_handler()
1283 } else if (read == -1) { in proxy_beconn_handler()
1351 int read = mcp_tls_read(be); in proxy_backend_tls_handler() local
1352 if (read > 0) { in proxy_backend_tls_handler()
1358 } else if (read == 0) { in proxy_backend_tls_handler()
1362 } else if (read == MCP_TLS_NEEDIO) { in proxy_backend_tls_handler()
1365 } else if (read == MCP_TLS_ERR) { in proxy_backend_tls_handler()
1411 int read = recv(mcmc_fd(be->client), be->rbuf + be->rbufused, in proxy_backend_handler() local
1413 if (read > 0) { in proxy_backend_handler()
1414 be->rbufused += read; in proxy_backend_handler()
1420 } else if (read == 0) { in proxy_backend_handler()
1424 } else if (read == -1) { in proxy_backend_handler()