Lines Matching refs:thr

34 static void nxt_gnutls_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf,
45 static void nxt_gnutls_conn_handshake(nxt_thread_t *thr, void *obj, void *data);
46 static void nxt_gnutls_conn_io_read(nxt_thread_t *thr, void *obj, void *data);
47 static ssize_t nxt_gnutls_conn_io_write_chunk(nxt_thread_t *thr,
51 static void nxt_gnutls_conn_io_shutdown(nxt_thread_t *thr, void *obj,
53 static nxt_int_t nxt_gnutls_conn_test_error(nxt_thread_t *thr,
126 nxt_thread_t *thr; in nxt_gnutls_time() local
128 thr = nxt_thread(); in nxt_gnutls_time()
129 nxt_log_debug(thr->log, "gnutls time"); in nxt_gnutls_time()
131 t = (time_t) nxt_thread_time(thr); in nxt_gnutls_time()
148 nxt_thread_t *thr; in nxt_gnutls_server_init() local
166 thr = nxt_thread(); in nxt_gnutls_server_init()
170 nxt_gnutls_log_error(NXT_LOG_ALERT, thr->log, ret, in nxt_gnutls_server_init()
181 nxt_gnutls_log_error(NXT_LOG_ALERT, thr->log, ret, in nxt_gnutls_server_init()
198 nxt_gnutls_log_error(NXT_LOG_ALERT, thr->log, ret, in nxt_gnutls_server_init()
254 nxt_gnutls_conn_init(nxt_thread_t *thr, nxt_ssltls_conf_t *conf, in nxt_gnutls_conn_init() argument
326 nxt_gnutls_conn_handshake(thr, c, c->socket.data); in nxt_gnutls_conn_init()
331 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_gnutls_conn_init()
355 nxt_thread_t *thr; in nxt_gnutls_pull() local
359 thr = nxt_thread(); in nxt_gnutls_pull()
361 n = thr->engine->event->io->recv(c, buf, size, 0); in nxt_gnutls_pull()
376 nxt_thread_t *thr; in nxt_gnutls_push() local
380 thr = nxt_thread(); in nxt_gnutls_push()
382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push()
402 nxt_thread_t *thr; in nxt_gnutls_vec_push() local
406 thr = nxt_thread(); in nxt_gnutls_vec_push()
412 n = thr->engine->event->io->writev(c, (nxt_iobuf_t *) iov, iovcnt); in nxt_gnutls_vec_push()
426 nxt_gnutls_conn_handshake(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_handshake() argument
436 nxt_log_debug(thr->log, "gnutls conn handshake: %d", ssltls->times); in nxt_gnutls_conn_handshake()
442 nxt_thread_time_debug_update(thr); in nxt_gnutls_conn_handshake()
444 nxt_log_debug(thr->log, "gnutls_handshake(): %d", err); in nxt_gnutls_conn_handshake()
447 nxt_gnutls_conn_io_read(thr, c, data); in nxt_gnutls_conn_handshake()
451 ret = nxt_gnutls_conn_test_error(thr, c, err, nxt_gnutls_conn_handshake); in nxt_gnutls_conn_handshake()
456 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_gnutls_conn_handshake()
469 nxt_gnutls_conn_io_read(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_io_read() argument
480 nxt_log_debug(thr->log, "gnutls conn read"); in nxt_gnutls_conn_io_read()
493 nxt_log_debug(thr->log, "gnutls_record_recv(%d, %p, %uz): %z", in nxt_gnutls_conn_io_read()
505 ret = nxt_gnutls_conn_test_error(thr, c, n, in nxt_gnutls_conn_io_read()
521 nxt_event_conn_io_handle(thr, c->read_work_queue, handler, c, data); in nxt_gnutls_conn_io_read()
526 nxt_gnutls_conn_io_write_chunk(nxt_thread_t *thr, nxt_event_conn_t *c, in nxt_gnutls_conn_io_write_chunk() argument
531 nxt_log_debug(thr->log, "gnutls conn write chunk"); in nxt_gnutls_conn_io_write_chunk()
571 nxt_gnutls_conn_io_shutdown(nxt_thread_t *thr, void *obj, void *data) in nxt_gnutls_conn_io_shutdown() argument
609 ret = nxt_gnutls_conn_test_error(thr, c, err, in nxt_gnutls_conn_io_shutdown()
614 nxt_event_timer_add(thr->engine, &c->read_timer, 5000); in nxt_gnutls_conn_io_shutdown()
626 nxt_event_conn_io_handle(thr, c->write_work_queue, handler, c, data); in nxt_gnutls_conn_io_shutdown()
631 nxt_gnutls_conn_test_error(nxt_thread_t *thr, nxt_event_conn_t *c, ssize_t err, in nxt_gnutls_conn_test_error() argument
644 nxt_log_debug(thr->log, "gnutls_record_get_direction(): %d", ret); in nxt_gnutls_conn_test_error()
649 nxt_event_fd_block_write(thr->engine, &c->socket); in nxt_gnutls_conn_test_error()
655 nxt_event_fd_enable_read(thr->engine, &c->socket); in nxt_gnutls_conn_test_error()
661 nxt_event_fd_block_read(thr->engine, &c->socket); in nxt_gnutls_conn_test_error()
667 nxt_event_fd_enable_write(thr->engine, &c->socket); in nxt_gnutls_conn_test_error()