summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_event_conn_proxy.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2017-01-30 16:47:50 +0300
committerIgor Sysoev <igor@sysoev.ru>2017-01-30 16:47:50 +0300
commitbb87fa11ca65d1263a32f86d51d1daa89dc11544 (patch)
treed5e74fee091b15da7ecd058341d49dba304c9822 /src/nxt_event_conn_proxy.c
parent952291c93c96c1dc5b63576e0ee034efde998b18 (diff)
downloadunit-bb87fa11ca65d1263a32f86d51d1daa89dc11544.tar.gz
unit-bb87fa11ca65d1263a32f86d51d1daa89dc11544.tar.bz2
nxt_event_timer has been renamed to nxt_timer.
Diffstat (limited to 'src/nxt_event_conn_proxy.c')
-rw-r--r--src/nxt_event_conn_proxy.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/nxt_event_conn_proxy.c b/src/nxt_event_conn_proxy.c
index a63b18f6..ae1a1996 100644
--- a/src/nxt_event_conn_proxy.c
+++ b/src/nxt_event_conn_proxy.c
@@ -797,8 +797,8 @@ nxt_event_conn_proxy_error(nxt_task_t *task, void *obj, void *data)
static void
nxt_event_conn_proxy_read_timeout(nxt_task_t *task, void *obj, void *data)
{
- nxt_event_conn_t *c;
- nxt_event_timer_t *ev;
+ nxt_timer_t *ev;
+ nxt_event_conn_t *c;
ev = obj;
@@ -815,8 +815,8 @@ nxt_event_conn_proxy_read_timeout(nxt_task_t *task, void *obj, void *data)
static void
nxt_event_conn_proxy_write_timeout(nxt_task_t *task, void *obj, void *data)
{
- nxt_event_conn_t *c;
- nxt_event_timer_t *ev;
+ nxt_timer_t *ev;
+ nxt_event_conn_t *c;
ev = obj;
@@ -870,16 +870,16 @@ nxt_event_conn_proxy_refused(nxt_task_t *task, void *obj, void *data)
p->delayed = 1;
peer->write_timer.handler = nxt_event_conn_proxy_reconnect_handler;
- nxt_event_timer_add(task->thread->engine, &peer->write_timer,
- p->reconnect_timeout);
+ nxt_timer_add(task->thread->engine, &peer->write_timer,
+ p->reconnect_timeout);
}
static void
nxt_event_conn_proxy_reconnect_handler(nxt_task_t *task, void *obj, void *data)
{
+ nxt_timer_t *ev;
nxt_event_conn_t *peer;
- nxt_event_timer_t *ev;
nxt_event_conn_proxy_t *p;
ev = obj;
@@ -1009,7 +1009,7 @@ nxt_event_conn_proxy_complete(nxt_task_t *task, nxt_event_conn_proxy_t *p)
} else if (p->delayed) {
nxt_queue_remove(&p->peer->link);
- nxt_event_timer_delete(task->thread->engine, &p->peer->write_timer);
+ nxt_timer_delete(task->thread->engine, &p->peer->write_timer);
}
nxt_mem_free(p->client->mem_pool, p->client_buffer);