Home
last modified time | relevance | path

Searched defs:handler (Results 1 – 25 of 61) 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.c107 nxt_job_start(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_start()
138 nxt_work_handler_t handler; in nxt_job_thread_trampoline() local
155 nxt_job_return(nxt_task_t *task, nxt_job_t *job, nxt_work_handler_t handler) in nxt_job_return()
184 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_file_cache.c71 nxt_work_handler_t handler; in nxt_file_cache_query() local
99 nxt_work_handler_t handler; in nxt_file_cache_query_locked() local
278 nxt_work_handler_t handler; in nxt_cache_wake_handler() local
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_cache.c134 nxt_work_handler_t handler; in nxt_cache_query() local
207 nxt_work_handler_t handler; in nxt_cache_node_hold() local
382 nxt_work_handler_t handler; in nxt_cache_wake_handler() 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