Stream: filters.

This commit is contained in:
Roman Arutyunyan
2016-09-15 14:55:46 +03:00
parent afa771140b
commit 04b9434b18
22 changed files with 738 additions and 102 deletions

View File

@@ -93,6 +93,8 @@ ngx_os_io_t ngx_iocp_io = {
NULL,
ngx_udp_overlapped_wsarecv,
NULL,
NULL,
NULL,
ngx_overlapped_wsasend_chain,
0
};

View File

@@ -430,6 +430,7 @@ extern ngx_os_io_t ngx_io;
#define ngx_send ngx_io.send
#define ngx_send_chain ngx_io.send_chain
#define ngx_udp_send ngx_io.udp_send
#define ngx_udp_send_chain ngx_io.udp_send_chain
#define NGX_EVENT_MODULE 0x544E5645 /* "EVNT" */

View File

@@ -467,6 +467,7 @@ ngx_event_recvmsg(ngx_event_t *ev)
*log = ls->log;
c->send = ngx_udp_send;
c->send_chain = ngx_udp_send_chain;
c->log = log;
c->pool->log = log;

View File

@@ -166,6 +166,7 @@ ngx_event_connect_peer(ngx_peer_connection_t *pc)
} else { /* type == SOCK_DGRAM */
c->recv = ngx_udp_recv;
c->send = ngx_send;
c->send_chain = ngx_udp_send_chain;
}
c->log_error = pc->log_error;