Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 69) sorted by relevance

123

/unit/src/
H A Dnxt_lib.c38 nxt_thread_t *thread; in nxt_lib_start() local
68 thread = nxt_thread(); in nxt_lib_start()
69 thread->log = &nxt_main_log; in nxt_lib_start()
71 thread->handle = nxt_thread_handle(); in nxt_lib_start()
72 thread->time.signal = -1; in nxt_lib_start()
73 nxt_thread_time_update(thread); in nxt_lib_start()
75 nxt_main_task.thread = thread; in nxt_lib_start()
76 nxt_main_task.log = thread->log; in nxt_lib_start()
107 nxt_random_init(&thread->random); in nxt_lib_start()
H A Dnxt_signal.c142 if (nxt_thread_create(&engine->signals->thread, link) == NXT_OK) { in nxt_signal_thread_start()
186 nxt_thread_handle_t thread; in nxt_signal_thread_stop() local
188 thread = engine->signals->thread; in nxt_signal_thread_stop()
190 nxt_thread_cancel(thread); in nxt_signal_thread_stop()
191 nxt_thread_wait(thread); in nxt_signal_thread_stop()
H A Dnxt_thread_pool.c32 tp->task.thread = engine->task.thread; in nxt_thread_pool_create()
124 tp->task.thread = thr; in nxt_thread_pool_start()
153 task->thread = thr; in nxt_thread_pool_loop()
269 nxt_thread_t *thread; in nxt_thread_pool_exit() local
275 thread = task->thread; in nxt_thread_pool_exit()
290 (void *) (uintptr_t) thread->handle); in nxt_thread_pool_exit()
300 (void *) (uintptr_t) thread->handle); in nxt_thread_pool_exit()
307 nxt_thread_exit(thread); in nxt_thread_pool_exit()
H A Dnxt_work_queue.c41 nxt_thread_t *thread; in nxt_work_queue_thread_assert() local
43 thread = nxt_thread(); in nxt_work_queue_thread_assert()
44 tid = nxt_thread_tid(thread); in nxt_work_queue_thread_assert()
57 nxt_log_alert(thread->log, "work queue locked by thread %PT", wq->tid); in nxt_work_queue_thread_assert()
64 nxt_thread_t *thread; in nxt_work_queue_thread_adopt() local
66 thread = nxt_thread(); in nxt_work_queue_thread_adopt()
69 wq->tid = nxt_thread_tid(thread); in nxt_work_queue_thread_adopt()
304 work->task->thread = thr; in nxt_locked_work_queue_move()
H A Dnxt_fiber.c68 fib->task.thread = thr; in nxt_fiber_create()
92 fib->task.thread = thr; in nxt_fiber_create()
246 nxt_fiber_enqueue(task->thread, task, fib); in nxt_fiber_trampoline()
307 nxt_fiber_enqueue(task->thread, task, fib); in nxt_fiber_trampoline()
347 task->thread->fiber = fib; in nxt_fiber_switch()
367 fib = task->thread->fiber; in nxt_fiber_yield()
389 fib = task->thread->fiber; in nxt_fiber_sleep()
391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep()
397 nxt_timer_add(task->thread->engine, &fib->timer, timeout); in nxt_fiber_sleep()
435 fib = task->thread->fiber; in nxt_fiber_wait()
[all …]
H A Dnxt_event_engine.c47 nxt_thread_t *thread; in nxt_event_engine_create() local
57 thread = task->thread; in nxt_event_engine_create()
59 engine->task.thread = thread; in nxt_event_engine_create()
60 engine->task.log = thread->log; in nxt_event_engine_create()
132 thread = task->thread; in nxt_event_engine_create()
134 nxt_thread_time_update(thread); in nxt_event_engine_create()
332 nxt_thread_t *thread; in nxt_event_engine_post_handler() local
335 thread = task->thread; in nxt_event_engine_post_handler()
336 engine = thread->engine; in nxt_event_engine_post_handler()
349 engine = task->thread->engine; in nxt_event_engine_signal_pipe_error()
[all …]
H A Dnxt_process.c139 rt = task->thread->runtime; in nxt_process_init_start()
264 task->thread->tid = 0; in nxt_process_child_fixup()
272 rt = task->thread->runtime; in nxt_process_child_fixup()
377 thread = task->thread; in nxt_process_setup()
378 rt = thread->runtime; in nxt_process_setup()
384 engine = thread->engine; in nxt_process_setup()
488 rt = task->thread->runtime; in nxt_process_whoami()
559 rt = task->thread->runtime; in nxt_process_whoami_ok()
595 rt = task->thread->runtime; in nxt_process_send_created()
744 rt = task->thread->runtime; in nxt_process_apply_creds()
[all …]
H A Dnxt_event_conn_job_sendfile.c32 nxt_fd_event_disable(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile()
144 if (first && task->thread->thread_pool->work_queue.head != NULL) { in nxt_event_conn_job_sendfile_handler()
158 nxt_thread_pool_post(task->thread->thread_pool, &jbs->job.work); in nxt_event_conn_job_sendfile_handler()
209 nxt_timer_disable(task->thread->engine, &c->write_timer); in nxt_event_conn_job_sendfile_return()
213 && !nxt_event_conn_write_delayed(task->thread->engine, c, sent)) in nxt_event_conn_job_sendfile_return()
215 nxt_conn_timer(task->thread->engine, c, c->write_state, in nxt_event_conn_job_sendfile_return()
218 nxt_fd_event_oneshot_write(task->thread->engine, &c->socket); in nxt_event_conn_job_sendfile_return()
H A Dnxt_stream_source.c106 if (task->thread->engine->batch != 0) { in nxt_stream_source_connected()
111 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_connected()
112 &task->thread->engine->read_work_queue, in nxt_stream_source_connected()
202 nxt_event_fd_block_read(task->thread->engine, &c->socket); in nxt_stream_source_read_ready()
204 nxt_source_filter(task->thread, c->write_work_queue, task, in nxt_stream_source_read_ready()
261 batch = (task->thread->engine->batch != 0); in nxt_stream_source_read_done()
264 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_read_done()
272 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_read_done()
382 nxt_thread_work_queue_add(task->thread, in nxt_stream_source_buf_completion()
438 nxt_source_filter(task->thread, c->write_work_queue, task, stream->next, b); in nxt_stream_source_closed()
H A Dnxt_conn_accept.c48 engine = task->thread->engine; in nxt_listen_event()
66 lev->task.thread = task->thread; in nxt_listen_event()
92 engine = task->thread->engine; in nxt_conn_accept_alloc()
198 nxt_queue_insert_head(&task->thread->engine->idle_connections, &c->link); in nxt_conn_accept()
253 engine = task->thread->engine; in nxt_conn_accept_close_idle()
280 engine = task->thread->engine; in nxt_conn_accept_close_idle_handler()
367 nxt_fd_event_enable_accept(task->thread->engine, &lev->socket); in nxt_conn_listen_timer_handler()
H A Dnxt_job.c114 job->engine = task->thread->engine; in nxt_job_start()
175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
189 job->task->thread = task->thread; in nxt_job_thread_return_handler()
H A Dnxt_conn_connect.c29 nxt_work_queue_add(&task->thread->engine->connect_work_queue, in nxt_conn_sys_socket()
57 engine = task->thread->engine; in nxt_conn_io_connect()
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()
H A Dnxt_buf_filter.c142 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter()
168 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter()
217 nxt_thread_work_queue_add(task->thread, f->work_queue, nxt_buf_filter, in nxt_buf_filter_enqueue()
232 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_file_read_start()
320 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read()
394 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_job_completion()
431 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_buf_completion()
447 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read_error()
H A Dnxt_port.c235 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_send_port()
266 rt = task->thread->runtime; in nxt_port_new_port_handler()
316 rt = task->thread->runtime; in nxt_port_process_ready_handler()
350 rt = task->thread->runtime; in nxt_port_mmap_handler()
392 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, in nxt_port_change_log_file()
415 rt = task->thread->runtime; in nxt_port_change_log_file_handler()
468 rt = task->thread->runtime; in nxt_port_remove_notify_others()
485 buf = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_remove_notify_others()
528 rt = task->thread->runtime; in nxt_port_remove_pid()
579 if (task->thread->engine == port->engine) { in nxt_port_post()
[all …]
H A Dnxt_http_websocket.c92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
104 task->thread->engine->port->id, out); in nxt_http_websocket_client()
150 task->thread->engine->port->id, NULL); in nxt_http_websocket_error_handler()
H A Dnxt_runtime.c65 task->thread->runtime = rt; in nxt_runtime_create()
299 thread = task->thread; in nxt_runtime_event_engines()
300 thread->engine = engine; in nxt_runtime_event_engines()
349 task->thread->log->ctx = NULL; in nxt_runtime_start()
382 thr = task->thread; in nxt_runtime_initial_start()
437 rt = task->thread->runtime; in nxt_runtime_quit()
439 engine = task->thread->engine; in nxt_runtime_quit()
727 rt = task->thread->runtime; in nxt_runtime_thread_pool_exit()
1553 rt = task->thread->runtime; in nxt_runtime_process_add()
1674 rt = task->thread->runtime; in nxt_runtime_port_add()
[all …]
H A Dnxt_main.c35 nxt_event_engine_start(nxt_main_task.thread->engine); in main()
H A Dnxt_router.c343 rt = task->thread->runtime; in nxt_router_start()
515 rt = task->thread->runtime; in nxt_router_start_app_process()
727 rt = task->thread->runtime; in nxt_router_new_port_handler()
1134 rt = task->thread->runtime; in nxt_router_conf_apply()
2608 rt = task->thread->runtime; in nxt_router_listen_socket_rpc_create()
2819 rt = task->thread->runtime; in nxt_router_app_rpc_create()
3377 thread = nxt_thread(); in nxt_router_thread_start()
3382 thread->runtime = engine->task.thread->runtime; in nxt_router_thread_start()
3384 engine->task.thread = thread; in nxt_router_thread_start()
3386 thread->engine = engine; in nxt_router_thread_start()
[all …]
H A Dnxt_h1proto.c229 engine = task->thread->engine; in nxt_http_conn_init()
322 engine = task->thread->engine; in nxt_http_conn_test()
1032 engine = task->thread->engine; in nxt_h1p_conn_request_body_read()
1385 nxt_conn_write(task->thread->engine, c); in nxt_h1p_request_header_send()
1723 engine = task->thread->engine; in nxt_h1p_conn_sent()
1803 engine = task->thread->engine; in nxt_h1p_keepalive()
2114 engine = task->thread->engine; in nxt_h1p_conn_free()
2386 engine = task->thread->engine; in nxt_h1p_peer_header_sent()
2416 nxt_conn_read(task->thread->engine, c); in nxt_h1p_peer_header_read()
2514 engine = task->thread->engine; in nxt_h1p_peer_header_read_done()
[all …]
H A Dnxt_signal.h33 nxt_thread_handle_t thread; member
H A Dnxt_conn_proxy.c117 nxt_conn_connect(task->thread->engine, peer); in nxt_conn_proxy()
186 nxt_conn_read(task->thread->engine, client); in nxt_conn_proxy_client_buffer_alloc()
224 nxt_conn_connect(task->thread->engine, p->peer); in nxt_conn_proxy_peer_connect()
324 nxt_conn_read(task->thread->engine, peer); in nxt_conn_proxy_peer_read()
427 nxt_conn_write(task->thread->engine, sink); in nxt_conn_proxy_read_process()
505 nxt_conn_read(task->thread->engine, source); in nxt_conn_proxy_read()
609 nxt_conn_write(task->thread->engine, sink); in nxt_conn_proxy_write_process()
815 nxt_timer_add(task->thread->engine, &peer->write_timer, in nxt_conn_proxy_refused()
846 nxt_conn_connect(task->thread->engine, peer); in nxt_conn_proxy_reconnect_handler()
921 nxt_fd_event_block_read(task->thread->engine, &source->socket); in nxt_conn_proxy_write_error()
[all …]
H A Dnxt_port_socket.c134 port->engine = task->thread->engine; in nxt_port_write_enable()
216 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_socket_write2()
355 nxt_fd_event_block_write(task->thread->engine, &port->socket); in nxt_port_fd_block_write()
362 nxt_fd_event_enable_write(task->thread->engine, &port->socket); in nxt_port_fd_enable_write()
387 wq = &task->thread->engine->fast_work_queue; in nxt_port_write_handler()
708 port->engine = task->thread->engine; in nxt_port_read_enable()
743 nxt_assert(port->engine == task->thread->engine); in nxt_port_read_handler()
804 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_read_handler()
827 nxt_assert(port->engine == task->thread->engine); in nxt_port_queue_read_handler()
1020 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_queue_read_handler()
[all …]
H A Dnxt_controller.c166 rt = task->thread->runtime; in nxt_controller_prefork()
422 rt = task->thread->runtime; in nxt_controller_send_current_conf()
441 rt = task->thread->runtime; in nxt_controller_router_ready_handler()
460 rt = task->thread->runtime; in nxt_controller_remove_pid_handler()
522 rt = task->thread->runtime; in nxt_controller_conf_init_handler()
568 rt = task->thread->runtime; in nxt_controller_conf_send()
711 engine = task->thread->engine; in nxt_controller_conn_init()
807 nxt_conn_read(task->thread->engine, c); in nxt_controller_conn_read()
1446 rt = task->thread->runtime; in nxt_controller_check_postpone_request()
1809 rt = task->thread->runtime; in nxt_controller_process_control()
[all …]
/unit/src/java/
H A Dnxt_jni_Thread.c67 jobject thread; in nxt_java_setContextClassLoader() local
69 thread = (*env)->CallStaticObjectMethod(env, nxt_java_Thread_class, in nxt_java_setContextClassLoader()
72 if (thread == NULL) { in nxt_java_setContextClassLoader()
76 (*env)->CallVoidMethod(env, thread, nxt_java_Thread_setContextClassLoader, in nxt_java_setContextClassLoader()
83 jobject thread; in nxt_java_getContextClassLoader() local
85 thread = (*env)->CallStaticObjectMethod(env, nxt_java_Thread_class, in nxt_java_getContextClassLoader()
88 if (thread == NULL) { in nxt_java_getContextClassLoader()
92 return (*env)->CallObjectMethod(env, thread, in nxt_java_getContextClassLoader()
/unit/src/ruby/
H A Dnxt_ruby.h28 VALUE thread; member

123