Lines Matching refs:task

10 static nxt_err_t nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c);
14 nxt_conn_sys_socket(nxt_task_t *task, void *obj, void *data) in nxt_conn_sys_socket() argument
21 if (nxt_conn_socket(task, c) == NXT_OK) { in nxt_conn_sys_socket()
29 nxt_work_queue_add(&task->thread->engine->connect_work_queue, in nxt_conn_sys_socket()
30 handler, task, c, data); in nxt_conn_sys_socket()
35 nxt_conn_io_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_io_connect() argument
46 switch (nxt_socket_connect(task, c->socket.fd, c->remote)) { in nxt_conn_io_connect()
57 engine = task->thread->engine; in nxt_conn_io_connect()
73 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_io_connect()
78 nxt_conn_socket(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_socket() argument
83 nxt_debug(task, "event conn socket"); in nxt_conn_socket()
87 s = nxt_socket_create(task, family, c->remote->type, 0, NXT_NONBLOCK); in nxt_conn_socket()
106 c->socket.task = task; in nxt_conn_socket()
107 c->read_timer.task = task; in nxt_conn_socket()
108 c->write_timer.task = task; in nxt_conn_socket()
111 if (nxt_slow_path(nxt_socket_bind(task, s, c->local) != NXT_OK)) { in nxt_conn_socket()
112 nxt_socket_close(task, s); in nxt_conn_socket()
122 nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_test() argument
129 nxt_debug(task, "event connect test fd:%d", c->socket.fd); in nxt_conn_connect_test()
131 nxt_fd_event_block_write(task->thread->engine, &c->socket); in nxt_conn_connect_test()
134 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_conn_connect_test()
137 err = nxt_conn_connect_test_error(task, c); in nxt_conn_connect_test()
141 task, c, data); in nxt_conn_connect_test()
143 nxt_conn_connect_error(task, c, data); in nxt_conn_connect_test()
149 nxt_conn_connect_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_connect_error() argument
160 err = nxt_conn_connect_test_error(task, c); in nxt_conn_connect_error()
183 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_connect_error()
188 nxt_conn_connect_test_error(nxt_task_t *task, nxt_conn_t *c) in nxt_conn_connect_test_error() argument
197 nxt_log(task, nxt_socket_error_level(err), "connect(%d, %*s) failed %E", in nxt_conn_connect_test_error()