Lines Matching refs:thr

23 static void nxt_cyassl_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf,
28 static void nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data);
29 static void nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data);
30 static void nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj,
32 static ssize_t nxt_cyassl_conn_io_write_chunk(nxt_thread_t *thr,
36 static nxt_int_t nxt_cyassl_conn_test_error(nxt_thread_t *thr,
75 nxt_thread_t *thr; in nxt_cyassl_start() local
84 thr = nxt_thread(); in nxt_cyassl_start()
90 nxt_cyassl_log_error(NXT_LOG_ALERT, thr->log, err, in nxt_cyassl_start()
111 nxt_thread_t *thr; in nxt_cyassl_server_init() local
113 thr = nxt_thread(); in nxt_cyassl_server_init()
121 nxt_cyassl_log_error(NXT_LOG_ALERT, thr->log, 0, in nxt_cyassl_server_init()
133 nxt_cyassl_log_error(NXT_LOG_ALERT, thr->log, err, in nxt_cyassl_server_init()
143 nxt_cyassl_log_error(NXT_LOG_ALERT, thr->log, err, in nxt_cyassl_server_init()
152 nxt_cyassl_log_error(NXT_LOG_ALERT, thr->log, err, in nxt_cyassl_server_init()
175 nxt_cyassl_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf, in nxt_cyassl_conn_init() argument
217 nxt_cyassl_conn_handshake(thr, c, c->socket.data); in nxt_cyassl_conn_init()
222 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_cyassl_conn_init()
246 nxt_thread_t *thr; in nxt_cyassl_io_recv() local
250 thr = nxt_thread(); in nxt_cyassl_io_recv()
252 n = thr->engine->event->io->recv(c, (u_char *) buf, size, 0); in nxt_cyassl_io_recv()
274 nxt_thread_t *thr; in nxt_cyassl_io_send() local
278 thr = nxt_thread(); in nxt_cyassl_io_send()
280 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_cyassl_io_send()
295 nxt_cyassl_conn_handshake(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_handshake() argument
306 nxt_log_debug(thr->log, "cyassl conn handshake: %d", ssltls->times); in nxt_cyassl_conn_handshake()
314 nxt_thread_time_debug_update(thr); in nxt_cyassl_conn_handshake()
316 nxt_log_debug(thr->log, "CyaSSL_negotiate(%d): %d", c->socket.fd, ret); in nxt_cyassl_conn_handshake()
319 nxt_cyassl_conn_io_read(thr, c, data); in nxt_cyassl_conn_handshake()
323 n = nxt_cyassl_conn_test_error(thr, c, ret, nxt_cyassl_conn_handshake); in nxt_cyassl_conn_handshake()
329 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_cyassl_conn_handshake()
339 nxt_cyassl_conn_io_read(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_read() argument
351 nxt_log_debug(thr->log, "cyassl conn read"); in nxt_cyassl_conn_io_read()
366 nxt_log_debug(thr->log, "CyaSSL_read(%d, %p, %uz): %d", in nxt_cyassl_conn_io_read()
375 n = nxt_cyassl_conn_test_error(thr, c, ret, in nxt_cyassl_conn_io_read()
390 nxt_event_conn_io_handle(thr, c->read_work_queue, handler, c, data); in nxt_cyassl_conn_io_read()
395 nxt_cyassl_conn_io_write_chunk(nxt_thread_t *thr, nxt_event_conn_t *c, in nxt_cyassl_conn_io_write_chunk() argument
400 nxt_log_debug(thr->log, "cyassl conn write chunk"); in nxt_cyassl_conn_io_write_chunk()
450 nxt_cyassl_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_cyassl_conn_io_shutdown() argument
458 nxt_log_debug(thr->log, "cyassl conn shutdown"); in nxt_cyassl_conn_io_shutdown()
464 nxt_log_debug(thr->log, "CyaSSL_shutdown(%d): %d", c->socket.fd, ret); in nxt_cyassl_conn_io_shutdown()
470 nxt_event_conn_io_handle(thr, c->write_work_queue, in nxt_cyassl_conn_io_shutdown()
476 nxt_cyassl_conn_test_error(nxt_thread_t *thr, nxt_event_conn_t *c, int ret, in nxt_cyassl_conn_test_error() argument
485 nxt_log_debug(thr->log, "CyaSSL_get_error(): %d", ssltls->ssl_error); in nxt_cyassl_conn_test_error()
490 nxt_event_fd_block_write(thr->engine, &c->socket); in nxt_cyassl_conn_test_error()
496 nxt_event_fd_enable_read(thr->engine, &c->socket); in nxt_cyassl_conn_test_error()
502 nxt_event_fd_block_read(thr->engine, &c->socket); in nxt_cyassl_conn_test_error()
508 nxt_event_fd_enable_write(thr->engine, &c->socket); in nxt_cyassl_conn_test_error()
525 nxt_event_conn_io_handle(thr, wq, handler, c, c->socket.data); in nxt_cyassl_conn_test_error()