Home
last modified time | relevance | path

Searched refs:handle (Results 1 – 14 of 14) sorted by path

/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties143 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…
/unit/src/nodejs/unit-http/
H A Dunit.cpp26 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/
H A Dnxt_dyld.c15 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 Dnxt_dyld.h12 void *handle; member
21 ((dyld)->handle != NULL)
H A Dnxt_lib.c71 thread->handle = nxt_thread_handle(); in nxt_lib_start()
H A Dnxt_php_sapi.c111 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 Dnxt_router.c3473 nxt_thread_handle_t handle; in nxt_router_thread_create() local
3489 ret = nxt_thread_create(&handle, link); in nxt_router_thread_create()
4010 nxt_thread_handle_t handle; in nxt_router_thread_exit_handler() local
4012 handle = (nxt_thread_handle_t) (uintptr_t) obj; in nxt_router_thread_exit_handler()
4015 nxt_thread_wait(handle); in nxt_router_thread_exit_handler()
H A Dnxt_runtime.c735 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 Dnxt_thread.c85 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 Dnxt_thread.h89 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 Dnxt_thread_pool.c63 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 Dnxt_thread_time.c86 nxt_thread_handle_t handle; in nxt_time_thread_start() local
94 (void) nxt_thread_create(&handle, link); in nxt_time_thread_start()
/unit/src/test/
H A Dnxt_cq_test.c125 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/wasm-wasi-component/src/
H A Dlib.rs234 state.handle(msg).await.expect("failed to handle request") in run()
240 async fn handle(&'static self, mut info: NxtRequestInfo) -> Result<()> { in handle() method