Home
last modified time | relevance | path

Searched defs:handler (Results 1 – 25 of 57) sorted by relevance

123

/unit/src/java/nginx/unit/websocket/
H A DMessageHandlerResult.java23 private final MessageHandler handler; field in MessageHandlerResult
27 public MessageHandlerResult(MessageHandler handler, in MessageHandlerResult()
H A DAsyncChannelWrapper.java36 CompletionHandler<Integer,B> handler); in read()
42 CompletionHandler<Long,B> handler); in write()
H A DWsRemoteEndpointImplBase.java146 public void sendBytesByCompletion(ByteBuffer data, SendHandler handler) { in sendBytesByCompletion()
206 public void sendStringByCompletion(String text, SendHandler handler) { in sendStringByCompletion()
301 SendHandler handler) { in startMessage()
355 void endMessage(SendHandler handler, SendResult result) { in endMessage()
490 private final SendHandler handler; field in WsRemoteEndpointImplBase.EndMessageHandler
493 SendHandler handler) { in EndMessageHandler()
747 private final SendHandler handler; field in WsRemoteEndpointImplBase.TextMessageSendHandler
755 public TextMessageSendHandler(SendHandler handler, CharBuffer message, in TextMessageSendHandler()
802 private final SendHandler handler; field in WsRemoteEndpointImplBase.OutputBufferSendHandler
908 private final SendHandler handler; field in WsRemoteEndpointImplBase.OutputBufferFlushSendHandler
[all …]
H A DAsyncChannelWrapperNonSecure.java51 CompletionHandler<Integer,B> handler) { in read()
63 CompletionHandler<Long,B> handler) { in write()
H A DWsRemoteEndpointImplClient.java44 protected void doWrite(SendHandler handler, long blockingWriteTimeoutExpiry, in doWrite()
H A DAsyncChannelWrapperSecure.java95 CompletionHandler<Integer,B> handler) { in read()
132 CompletionHandler<Long,B> handler) { in write()
444 private final CompletionHandler<T,A> handler; field in AsyncChannelWrapperSecure.WrapperFuture
455 public WrapperFuture(CompletionHandler<T,A> handler, A attachment) { in WrapperFuture()
/unit/src/
H A Dnxt_job.c109 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start()
140 nxt_work_handler_t handler; in nxt_job_thread_trampoline() local
157 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return()
186 nxt_work_handler_t handler; in nxt_job_thread_return_handler() local
H A Dnxt_signal.h13 nxt_work_handler_t handler; member
17 #define nxt_event_signal(sig, handler) \ argument
26 nxt_work_handler_t handler; member
H A Dnxt_conn_connect.c17 nxt_work_handler_t handler; in nxt_conn_sys_socket() local
38 nxt_work_handler_t handler; in nxt_conn_io_connect() local
153 nxt_work_handler_t handler; in nxt_conn_connect_error() local
H A Dnxt_file_event.h13 nxt_work_handler_t handler; member
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()
254 nxt_work_handler_t handler; in nxt_locked_work_queue_pop() local
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()
H A Dnxt_epoll_engine.c289 static nxt_work_handler_t handler; in nxt_epoll_test_accept4() local
726 nxt_work_handler_t handler; in nxt_epoll_signalfd_handler() local
754 nxt_epoll_enable_post(nxt_event_engine_t *engine, nxt_work_handler_t handler) in nxt_epoll_enable_post()
1062 nxt_work_handler_t handler; in nxt_epoll_edge_conn_io_connect() local
H A Dnxt_conn_read.c43 nxt_work_handler_t handler; in nxt_conn_io_read() local
/unit/src/java/javax/websocket/
H A DSession.java50 void addMessageHandler(MessageHandler handler) throws IllegalStateException; in addMessageHandler()
173 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Partial<T> handler) in addMessageHandler()
191 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) in addMessageHandler()
/unit/test/go/404/
H A Dapp.go10 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/command_line_arguments/
H A Dapp.go12 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/cookies/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/empty/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) {} func
/unit/test/go/get_variables/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/mirror/
H A Dapp.go10 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/post_variables/
H A Dapp.go8 func handler(w http.ResponseWriter, r *http.Request) { func
/unit/test/go/variables/
H A Dapp.go10 func handler(w http.ResponseWriter, r *http.Request) { func
/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()
/unit/test/python/lifespan/empty/
H A Dasgi.py4 async def handler(prefix, scope, receive, send): function

123