summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_stream_module.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2017-06-14 15:18:52 +0300
committerIgor Sysoev <igor@sysoev.ru>2017-06-14 15:18:52 +0300
commit7574c64992b98d3dfbc3dd101bd0f7d78bad0823 (patch)
tree3a98c46e88d9023df34be3e6cce4f762d53aad36 /src/nxt_stream_module.c
parent3e2632688f53c4cb08e7ac03c61e71facd038df4 (diff)
downloadunit-7574c64992b98d3dfbc3dd101bd0f7d78bad0823.tar.gz
unit-7574c64992b98d3dfbc3dd101bd0f7d78bad0823.tar.bz2
nxt_event_conn_... functions and structures have been renamed
to nxt_conn_...
Diffstat (limited to '')
-rw-r--r--src/nxt_stream_module.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/nxt_stream_module.c b/src/nxt_stream_module.c
index e89cd6fd..6000daaf 100644
--- a/src/nxt_stream_module.c
+++ b/src/nxt_stream_module.c
@@ -17,8 +17,8 @@ static void nxt_stream_connection_close(nxt_task_t *task, void *obj,
void
nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data)
{
+ nxt_conn_t *c;
nxt_runtime_t *rt;
- nxt_event_conn_t *c;
nxt_upstream_peer_t *up;
c = obj;
@@ -57,8 +57,8 @@ fail:
static void
nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up)
{
- nxt_event_conn_t *c;
- nxt_event_conn_proxy_t *p;
+ nxt_conn_t *c;
+ nxt_conn_proxy_t *p;
c = up->data;
@@ -67,7 +67,7 @@ nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up)
nxt_log_debug(c->socket.log, "stream connection peer %*s",
up->sockaddr->length, nxt_sockaddr_start(up->sockaddr));
- p = nxt_event_conn_proxy_create(c);
+ p = nxt_conn_proxy_create(c);
if (nxt_slow_path(p == NULL)) {
goto fail;
}
@@ -107,7 +107,7 @@ nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up)
rate->last = engine->timers.now;
}
- nxt_event_conn_proxy(task, p);
+ nxt_conn_proxy(task, p);
return;
fail: