/unit/src/ |
H A D | nxt_dyld.c | 15 dyld->handle = dlopen(dyld->name, RTLD_NOW | RTLD_GLOBAL); in nxt_dyld_load() 17 if (dyld->handle != NULL) { in nxt_dyld_load() 36 void *handle, *s; in nxt_dyld_symbol() local 41 handle = RTLD_DEFAULT; in nxt_dyld_symbol() 45 handle = dyld->handle; in nxt_dyld_symbol() 49 s = dlsym(handle, symbol); in nxt_dyld_symbol() 72 if (dlclose(dyld->handle) == 0) { in nxt_dyld_unload()
|
H A D | nxt_thread.c | 85 err = pthread_create(handle, NULL, nxt_thread_trampoline, link); in nxt_thread_create() 88 nxt_thread_log_debug("pthread_create(): %PH", *handle); in nxt_thread_create() 112 nxt_log_debug(thr->log, "thread trampoline: %PH", thr->handle); in nxt_thread_trampoline() 152 thr->handle = nxt_thread_handle(); in nxt_thread_init() 199 link->work.obj = (void *) (uintptr_t) thr->handle; in nxt_thread_exit() 213 nxt_thread_cancel(nxt_thread_handle_t handle) in nxt_thread_cancel() argument 217 nxt_thread_log_debug("thread cancel: %PH", handle); in nxt_thread_cancel() 219 err = pthread_cancel(handle); in nxt_thread_cancel() 228 nxt_thread_wait(nxt_thread_handle_t handle) in nxt_thread_wait() argument 232 nxt_thread_log_debug("thread wait: %PH", handle); in nxt_thread_wait() [all …]
|
H A D | nxt_thread_pool.c | 63 nxt_thread_handle_t handle; in nxt_thread_pool_init() local 92 if (nxt_thread_create(&handle, link) == NXT_OK) { in nxt_thread_pool_init() 123 tp->main = thr->handle; in nxt_thread_pool_start() 172 nxt_thread_handle_t handle; in nxt_thread_pool_wait() local 189 if (nxt_thread_handle_equal(thr->handle, tp->main)) { in nxt_thread_pool_wait() 222 if (nxt_thread_create(&handle, link) != NXT_OK) { in nxt_thread_pool_wait() 272 nxt_thread_handle_t handle; in nxt_thread_pool_exit() local 280 handle = (nxt_thread_handle_t) (uintptr_t) data; in nxt_thread_pool_exit() 281 nxt_thread_wait(handle); in nxt_thread_pool_exit() 290 (void *) (uintptr_t) thread->handle); in nxt_thread_pool_exit() [all …]
|
H A D | nxt_dyld.h | 12 void *handle; member 21 ((dyld)->handle != NULL)
|
H A D | nxt_thread.h | 89 NXT_EXPORT nxt_int_t nxt_thread_create(nxt_thread_handle_t *handle, 93 NXT_EXPORT void nxt_thread_cancel(nxt_thread_handle_t handle); 94 NXT_EXPORT void nxt_thread_wait(nxt_thread_handle_t handle); 141 nxt_thread_handle_t handle; member
|
H A D | nxt_lib.c | 71 thread->handle = nxt_thread_handle(); in nxt_lib_start()
|
H A D | nxt_thread_time.c | 86 nxt_thread_handle_t handle; in nxt_time_thread_start() local 94 (void) nxt_thread_create(&handle, link); in nxt_time_thread_start()
|
H A D | nxt_php_sapi.c | 111 static void nxt_zend_stream_init_fp(zend_file_handle *handle, FILE *fp, 1139 nxt_zend_stream_init_fp(zend_file_handle *handle, FILE *fp, in nxt_zend_stream_init_fp() argument 1142 nxt_memzero(handle, sizeof(zend_file_handle)); in nxt_zend_stream_init_fp() 1143 handle->type = ZEND_HANDLE_FP; in nxt_zend_stream_init_fp() 1144 handle->handle.fp = fp; in nxt_zend_stream_init_fp() 1145 handle->filename = filename; in nxt_zend_stream_init_fp()
|
H A D | nxt_runtime.c | 735 nxt_thread_handle_t handle; in nxt_runtime_thread_pool_exit() local 740 handle = (nxt_thread_handle_t) (uintptr_t) data; in nxt_runtime_thread_pool_exit() 741 nxt_thread_wait(handle); in nxt_runtime_thread_pool_exit()
|
H A D | nxt_router.c | 3477 nxt_thread_handle_t handle; in nxt_router_thread_create() local 3493 ret = nxt_thread_create(&handle, link); in nxt_router_thread_create() 4014 nxt_thread_handle_t handle; in nxt_router_thread_exit_handler() local 4016 handle = (nxt_thread_handle_t) (uintptr_t) obj; in nxt_router_thread_exit_handler() 4019 nxt_thread_wait(handle); in nxt_router_thread_exit_handler()
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 26 static port_data_t *get(T *handle); 28 static void read_callback(uv_poll_t *handle, int status, int events); 29 static void timer_callback(uv_timer_t *handle); 30 static void delete_data(uv_handle_t* handle); 108 port_data_t::get(T *handle) in get() argument 110 return (port_data_t *) handle->data; in get() 117 get(handle)->process_port_msg(); in read_callback() 122 port_data_t::timer_callback(uv_timer_t *handle) in timer_callback() argument 126 data = get(handle); in timer_callback() 138 port_data_t::delete_data(uv_handle_t* handle) in delete_data() argument [all …]
|
/unit/src/test/ |
H A D | nxt_cq_test.c | 125 nxt_thread_handle_t handle; member 308 return nxt_thread_create(&wi->handle, link); in worker_create() 330 pthread_join(wi->handle, NULL); in worker_wait()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 143 wsWebSocketContainer.missingLocationHeader=Failed to handle HTTP response code [{0}]. Missing Locat… 145 wsWebSocketContainer.unsupportedAuthScheme=Failed to handle HTTP response code [{0}]. Unsupported A… 146 wsWebSocketContainer.failedAuthentication=Failed to handle HTTP response code [{0}]. Authentication… 147 wsWebSocketContainer.missingWWWAuthenticateHeader=Failed to handle HTTP response code [{0}]. Missin…
|