tcp.c - OpenGrok cross reference for /third

Lines Matching refs:tcp
158   handle->tcp.serv.accept_reqs = NULL;
159   handle->tcp.serv.pending_accepts = NULL;
162   handle->tcp.serv.func_acceptex = NULL;
163   handle->tcp.conn.func_connectex = NULL;
164   handle->tcp.serv.processed_accepts = 0;
236   if (!(handle->flags & UV_HANDLE_CONNECTION) && handle->tcp.serv.accept_reqs) {
239         req = &handle->tcp.serv.accept_reqs[i];
251     uv__free(handle->tcp.serv.accept_reqs);
252     handle->tcp.serv.accept_reqs = NULL;
423   success = handle->tcp.serv.func_acceptex(handle->socket,
567   if (!handle->tcp.serv.func_acceptex) {
568     if (!uv__get_acceptex_function(handle->socket, &handle->tcp.serv.func_acceptex)) {
586   if (handle->tcp.serv.accept_reqs == NULL) {
587     handle->tcp.serv.accept_reqs =
589     if (!handle->tcp.serv.accept_reqs) {
594       req = &handle->tcp.serv.accept_reqs[i];
616       req = &handle->tcp.serv.accept_reqs[i];
633   uv_tcp_accept_t* req = server->tcp.serv.pending_accepts;
664   server->tcp.serv.pending_accepts = req->next_pending;
676       server->tcp.serv.processed_accepts++;
678       if (server->tcp.serv.processed_accepts >= uv_simultaneous_server_accepts) {
679         server->tcp.serv.processed_accepts = 0;
684         uv__tcp_queue_accept(server, &server->tcp.serv.accept_reqs[0]);
790   if (!handle->tcp.conn.func_connectex) {
791     if (!uv__get_connectex_function(handle->socket, &handle->tcp.conn.func_connectex)) {
830   success = handle->tcp.conn.func_connectex(handle->socket,
987             uv_buf_init(NULL, 0) : handle->tcp.conn.read_buffer;
1009                         &handle->tcp.conn.read_buffer);
1011         if (req->u.io.overlapped.InternalHigh < handle->tcp.conn.read_buffer.len) {
1023         handle->read_cb((uv_stream_t*)handle, UV_EOF, &handle->tcp.conn.read_buffer);
1172     req->next_pending = handle->tcp.serv.pending_accepts;
1173     handle->tcp.serv.pending_accepts = req;
1268 int uv__tcp_xfer_import(uv_tcp_t* tcp,
1289       tcp->loop, tcp, socket, xfer_info->socket_info.iAddressFamily, 1);
1295   tcp->delayed_error = xfer_info->delayed_error;
1296   tcp->flags |= UV_HANDLE_BOUND | UV_HANDLE_SHARED_TCP_SOCKET;
1299     uv__connection_init((uv_stream_t*)tcp);
1300     tcp->flags |= UV_HANDLE_READABLE | UV_HANDLE_WRITABLE;
1379 static void uv__tcp_try_cancel_reqs(uv_tcp_t* tcp) {
1385   socket = tcp->socket;
1386   reading = tcp->flags & UV_HANDLE_READ_PENDING;
1387   writing = tcp->stream.conn.write_reqs_pending > 0;
1394     CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1399   non_ifs_lsp = (tcp->flags & UV_HANDLE_IPV6) ? uv_tcp_non_ifs_lsp_ipv6 :
1422   if (socket != tcp->socket) {
1424       CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1431 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp) {
1432   if (tcp->flags & UV_HANDLE_CONNECTION) {
1433     if (tcp->flags & UV_HANDLE_READING) {
1434       uv_read_stop((uv_stream_t*) tcp);
1436     uv__tcp_try_cancel_reqs(tcp);
1438     if (tcp->tcp.serv.accept_reqs != NULL) {
1443         uv_tcp_accept_t* req = &tcp->tcp.serv.accept_reqs[i];
1450     assert(!(tcp->flags & UV_HANDLE_READING));
1453   if (tcp->flags & UV_HANDLE_LISTENING) {
1454     tcp->flags &= ~UV_HANDLE_LISTENING;
1455     DECREASE_ACTIVE_COUNT(loop, tcp);
1458   tcp->flags &= ~(UV_HANDLE_READABLE | UV_HANDLE_WRITABLE);
1459   uv__handle_closing(tcp);
1466   if (!(tcp->flags & UV_HANDLE_CONNECTION) ||
1467       tcp->stream.conn.write_reqs_pending == 0) {
1468     closesocket(tcp->socket);
1469     tcp->socket = INVALID_SOCKET;
1472   if (tcp->reqs_pending == 0)
1473     uv__want_endgame(loop, (uv_handle_t*) tcp);