Home
last modified time | relevance | path

Searched refs:handler (Results 1 – 25 of 104) sorted by relevance

12345

/unit/src/
H A Dnxt_job.c90 mpcl->handler = nxt_job_destroy;
125 handler = job->abort_handler; in nxt_job_start()
128 handler(job->task, job, job->data); in nxt_job_start()
138 nxt_work_handler_t handler; in nxt_job_thread_trampoline() local
141 handler = (nxt_work_handler_t) data; in nxt_job_thread_trampoline()
149 handler(job->task, job, job->data); in nxt_job_thread_trampoline()
172 handler = job->abort_handler; in nxt_job_return()
184 nxt_work_handler_t handler; in nxt_job_thread_return_handler() local
187 handler = (nxt_work_handler_t) data; in nxt_job_thread_return_handler()
193 handler = job->abort_handler; in nxt_job_thread_return_handler()
[all …]
H A Dnxt_conn_connect.c17 nxt_work_handler_t handler; in nxt_conn_sys_socket() local
23 handler = c->io->connect; in nxt_conn_sys_socket()
26 handler = c->write_state->error_handler; in nxt_conn_sys_socket()
30 handler, task, c, data); in nxt_conn_sys_socket()
38 nxt_work_handler_t handler; in nxt_conn_io_connect() local
50 handler = state->ready_handler; in nxt_conn_io_connect()
65 handler = state->close_handler; in nxt_conn_io_connect()
69 handler = state->error_handler; in nxt_conn_io_connect()
153 nxt_work_handler_t handler; in nxt_conn_connect_error() local
175 handler = state->close_handler; in nxt_conn_connect_error()
[all …]
H A Dnxt_log.h30 nxt_log_handler_t handler; member
38 nxt_log_ctx_handler_t handler, void *ctx);
52 _log->handler(NXT_LOG_ALERT, _log, __VA_ARGS__); \
62 _log->handler(_level_, _log, __VA_ARGS__); \
72 _log->handler(NXT_LOG_NOTICE, _log, __VA_ARGS__); \
81 _log_->handler(NXT_LOG_ALERT, _log_, __VA_ARGS__); \
91 _log_->handler(_level_, _log_, __VA_ARGS__); \
103 _log->handler(NXT_LOG_DEBUG, _log, __VA_ARGS__); \
113 _log_->handler(NXT_LOG_DEBUG, _log_, __VA_ARGS__); \
H A Dnxt_signal.h13 nxt_work_handler_t handler; member
17 #define nxt_event_signal(sig, handler) \ argument
18 { sig, handler, #sig }
26 nxt_work_handler_t handler; member
H A Dnxt_file_cache.c71 nxt_work_handler_t handler; in nxt_file_cache_query() local
89 handler(q); in nxt_file_cache_query()
99 nxt_work_handler_t handler; in nxt_file_cache_query_locked() local
144 if (handler == NULL) { in nxt_file_cache_query_locked()
156 if (handler != NULL) { in nxt_file_cache_query_locked()
158 return handler; in nxt_file_cache_query_locked()
176 return handler; in nxt_file_cache_query_locked()
278 nxt_work_handler_t handler; in nxt_cache_wake_handler() local
290 if (handler == NULL) { in nxt_cache_wake_handler()
298 if (handler != NULL) { in nxt_cache_wake_handler()
[all …]
H A Dnxt_work_queue.c160 nxt_work_queue_add(nxt_work_queue_t *wq, nxt_work_handler_t handler, in nxt_work_queue_add() argument
174 work->handler = handler; in nxt_work_queue_add()
223 return work->handler; in nxt_work_queue_pop()
254 nxt_work_handler_t handler; in nxt_locked_work_queue_pop() local
256 handler = NULL; in nxt_locked_work_queue_pop()
277 handler = work->handler; in nxt_locked_work_queue_pop()
282 return handler; in nxt_locked_work_queue_pop()
306 nxt_work_queue_add(wq, work->handler, work->task, in nxt_locked_work_queue_move()
H A Dnxt_cache.c134 nxt_work_handler_t handler; in nxt_cache_query() local
158 handler(thr, q, NULL); in nxt_cache_query()
207 nxt_work_handler_t handler; in nxt_cache_node_hold() local
249 if (handler != NULL) { in nxt_cache_node_hold()
250 return handler; in nxt_cache_node_hold()
264 if (handler != NULL) { in nxt_cache_node_hold()
266 return handler; in nxt_cache_node_hold()
276 qw->handler = nxt_cache_wake_handler; in nxt_cache_node_hold()
382 nxt_work_handler_t handler; in nxt_cache_wake_handler() local
394 if (handler != NULL) { in nxt_cache_wake_handler()
[all …]
H A Dnxt_log.c47 nxt_log_set_ctx(nxt_log_t *log, nxt_log_ctx_handler_t handler, void *ctx) in nxt_log_set_ctx() argument
56 log->handler = old->handler; in nxt_log_set_ctx()
57 log->ctx_handler = handler; in nxt_log_set_ctx()
H A Dnxt_conn_close.c23 nxt_work_handler_t handler; in nxt_conn_close() local
63 handler = nxt_conn_shutdown_handler; in nxt_conn_close()
67 handler = nxt_conn_close_handler; in nxt_conn_close()
70 nxt_work_queue_add(wq, handler, c->socket.task, c, engine); in nxt_conn_close()
130 c->write_timer.handler = nxt_conn_close_timer_handler; in nxt_conn_close_handler()
/unit/src/java/nginx/unit/websocket/
H A DMessageHandlerResult.java23 private final MessageHandler handler; field in MessageHandlerResult
27 public MessageHandlerResult(MessageHandler handler, in MessageHandlerResult() argument
29 this.handler = handler; in MessageHandlerResult()
35 return handler; in getHandler()
H A DWsRemoteEndpointImplClient.java44 protected void doWrite(SendHandler handler, long blockingWriteTimeoutExpiry, in doWrite() argument
57 handler.onResult(sr); in doWrite()
64 handler.onResult(new SendResult(e)); in doWrite()
68 handler.onResult(SENDRESULT_OK); in doWrite()
H A DWsRemoteEndpointImplBase.java150 if (handler == null) { in sendBytesByCompletion()
210 if (handler == null) { in sendStringByCompletion()
301 SendHandler handler) { in startMessage() argument
385 if (handler != null) { in endMessage()
386 handler.onResult(result); in endMessage()
495 this.handler = handler; in EndMessageHandler()
758 this.handler = handler; in TextMessageSendHandler()
788 handler.onResult(sr); in onResult()
912 this.handler = handler; in OutputBufferFlushSendHandler()
920 handler.onResult(result); in onResult()
[all …]
H A DAsyncChannelWrapperNonSecure.java51 CompletionHandler<Integer,B> handler) { in read() argument
52 socketChannel.read(dst, attachment, handler); in read()
63 CompletionHandler<Long,B> handler) { in write() argument
65 srcs, offset, length, timeout, unit, attachment, handler); in write()
/unit/src/nodejs/unit-http/
H A Dwebsocket_router.js107 var handler = this.handlers[i];
108 if (handler.pathString === pathString && handler.protocol === protocol) {
140 var handler = this.handlers[j];
141 if (handler.path.test(request.resourceURL.pathname)) {
142 if (requestedProtocol === handler.protocol ||
143 handler.protocol === '*')
146 handler.callback(routerRequest);
/unit/src/java/nginx/unit/websocket/server/
H A DWsRemoteEndpointImplServer.java47 private volatile SendHandler handler = null; field in WsRemoteEndpointImplServer
64 protected void doWrite(SendHandler handler, long blockingWriteTimeoutExpiry, in doWrite() argument
70 if (handler != null) { in doClose()
93 if (handler != null) { in onTimeout()
122 SendHandler sh = handler; in clearHandler()
123 handler = null; in clearHandler()
/unit/go/
H A Dunit.go107 func set_handler(handler *http.Handler) uintptr {
117 handler_registry_.m[h] = handler
141 func ListenAndServe(addr string, handler http.Handler) error {
142 if handler == nil {
143 handler = http.DefaultServeMux
146 h := set_handler(&handler)
153 return http.ListenAndServe(addr, handler)
/unit/test/python/lifespan/empty/
H A Dasgi.py4 async def handler(prefix, scope, receive, send): function
31 return await handler('', scope, receive, send)
35 return await handler('app2_', scope, receive, send)
/unit/test/go/empty/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) {} func
11 http.HandleFunc("/", handler)
/unit/test/go/404/
H A Dapp.go10 func handler(w http.ResponseWriter, r *http.Request) { func
20 http.HandleFunc("/", handler)
/unit/test/go/mirror/
H A Dapp.go10 func handler(w http.ResponseWriter, r *http.Request) { func
19 http.HandleFunc("/", handler)
/unit/test/go/cookies/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
17 http.HandleFunc("/", handler)
/unit/test/go/post_variables/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
17 http.HandleFunc("/", handler)
/unit/test/go/get_variables/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
15 http.HandleFunc("/", handler)
/unit/test/go/command_line_arguments/
H A Dapp.go12 func handler(w http.ResponseWriter, r *http.Request) { func
21 http.HandleFunc("/", handler)
/unit/src/java/javax/websocket/
H A DSession.java50 void addMessageHandler(MessageHandler handler) throws IllegalStateException; in addMessageHandler() argument
173 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Partial<T> handler) in addMessageHandler() argument
191 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) in addMessageHandler() argument

12345