summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_event_conn_job_sendfile.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_event_conn_job_sendfile.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 'src/nxt_event_conn_job_sendfile.c')
-rw-r--r--src/nxt_event_conn_job_sendfile.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/nxt_event_conn_job_sendfile.c b/src/nxt_event_conn_job_sendfile.c
index dae5079c..15d7fe1d 100644
--- a/src/nxt_event_conn_job_sendfile.c
+++ b/src/nxt_event_conn_job_sendfile.c
@@ -25,11 +25,11 @@ static void nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj,
static void nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj,
void *data);
static nxt_buf_t *nxt_event_conn_job_sendfile_completion(nxt_task_t *task,
- nxt_event_conn_t *c, nxt_buf_t *b);
+ nxt_conn_t *c, nxt_buf_t *b);
void
-nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_event_conn_t *c)
+nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_conn_t *c)
{
nxt_fd_event_disable(task->thread->engine, &c->socket);
@@ -41,8 +41,8 @@ nxt_event_conn_job_sendfile(nxt_task_t *task, nxt_event_conn_t *c)
static void
nxt_event_conn_job_sendfile_start(nxt_task_t *task, void *obj, void *data)
{
+ nxt_conn_t *c;
nxt_iobuf_t b;
- nxt_event_conn_t *c;
nxt_job_sendfile_t *jbs;
nxt_sendbuf_coalesce_t sb;
@@ -99,7 +99,7 @@ nxt_event_conn_job_sendfile_handler(nxt_task_t *task, void *obj, void *data)
ssize_t ret;
nxt_buf_t *b;
nxt_bool_t first;
- nxt_event_conn_t *c;
+ nxt_conn_t *c;
nxt_job_sendfile_t *jbs;
jbs = obj;
@@ -166,7 +166,7 @@ nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data)
size_t sent;
nxt_buf_t *b;
nxt_bool_t done;
- nxt_event_conn_t *c;
+ nxt_conn_t *c;
nxt_job_sendfile_t *jbs;
jbs = obj;
@@ -212,8 +212,8 @@ nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data)
if (c->socket.error == 0
&& !nxt_event_conn_write_delayed(task->thread->engine, c, sent))
{
- nxt_event_conn_timer(task->thread->engine, c, c->write_state,
- &c->write_timer);
+ nxt_conn_timer(task->thread->engine, c, c->write_state,
+ &c->write_timer);
nxt_fd_event_oneshot_write(task->thread->engine, &c->socket);
}
@@ -235,7 +235,7 @@ nxt_event_conn_job_sendfile_return(nxt_task_t *task, void *obj, void *data)
static nxt_buf_t *
-nxt_event_conn_job_sendfile_completion(nxt_task_t *task, nxt_event_conn_t *c,
+nxt_event_conn_job_sendfile_completion(nxt_task_t *task, nxt_conn_t *c,
nxt_buf_t *b)
{
while (b != NULL) {