Home
last modified time | relevance | path

Searched refs:handler (Results 1 – 25 of 105) sorted by path

12345

/unit/
H A DCHANGES503 handler was used.
/unit/go/
H A Dnxt_cgo_lib.c19 nxt_cgo_run(uintptr_t handler) in nxt_cgo_run() argument
35 init.data = (void *) handler; in nxt_cgo_run()
H A Dnxt_cgo_lib.h21 int nxt_cgo_run(uintptr_t handler);
H A Drequest.go109 go func(c_req *C.nxt_unit_request_info_t, handler http.Handler) {
117 handler.ServeHTTP(&r.resp, &r.req)
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/pkg/deb/debian.module/
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
18 http.HandleFunc("/", handler)
/unit/pkg/deb/debian/
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
18 http.HandleFunc("/", handler)
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.example-go-app9 func handler(w http.ResponseWriter, r *http.Request) {
18 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
/unit/src/java/nginx/unit/
H A DRequest.java1215 T handler; in upgrade() local
1218 handler = httpUpgradeHandlerClass.getConstructor().newInstance(); in upgrade()
1225 return handler; in upgrade()
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapper.java36 CompletionHandler<Integer,B> handler); in read() argument
42 CompletionHandler<Long,B> handler); in write() argument
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()
H A DAsyncChannelWrapperSecure.java95 CompletionHandler<Integer,B> handler) { in read() argument
98 new WrapperFuture<>(handler, attachment); in read()
132 CompletionHandler<Long,B> handler) { in write() argument
135 new WrapperFuture<>(handler, attachment); in write()
444 private final CompletionHandler<T,A> handler; field in AsyncChannelWrapperSecure.WrapperFuture
455 public WrapperFuture(CompletionHandler<T,A> handler, A attachment) { in WrapperFuture() argument
456 this.handler = handler; in WrapperFuture()
463 if (handler != null) { in complete()
464 handler.completed(result, attachment); in complete()
471 if (handler != null) { in fail()
[all …]
H A DLocalStrings.properties47 util.invalidMessageHandler=The message handler provided does not have an onMessage(Object) method
94 wsRemoteEndpoint.nullHandler=Invalid null handler argument
108 wsSession.duplicateHandlerBinary=A binary message handler has already been configured
109 wsSession.duplicateHandlerPong=A pong message handler has already been configured
110 wsSession.duplicateHandlerText=A text message handler has already been configured
111 wsSession.invalidHandlerTypePong=A pong message handler must implement MessageHandler.Whole
115 wsSession.removeHandlerFailed=Unable to remove the handler [{0}] as it was not registered with this…
116 wsSession.unknownHandler=Unable to add the message handler [{0}] as it was for the unrecognised typ…
117 wsSession.unknownHandlerType=Unable to add the message handler [{0}] as it was wrapped as the unrec…
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 DWsFrameClient.java37 private final CompletionHandler<Integer, Void> handler; field in WsFrameClient
46 this.handler = new WsFrameClientCompletionHandler(); in WsFrameClient()
101 channel.read(response, null, handler); in processSocketRead()
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 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 DWsSession.java238 public <T> void addMessageHandler(Class<T> clazz, Partial<T> handler) in addMessageHandler() argument
240 doAddMessageHandler(clazz, handler); in addMessageHandler()
245 public <T> void addMessageHandler(Class<T> clazz, Whole<T> handler) in addMessageHandler() argument
247 doAddMessageHandler(clazz, handler); in addMessageHandler()
289 MessageHandler handler = mhResult.getHandler(); in doAddMessageHandler() local
290 if (handler instanceof MessageHandler.Whole<?>) { in doAddMessageHandler()
291 pongMessageHandler = (MessageHandler.Whole<PongMessage>) handler; in doAddMessageHandler()
/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/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/
H A Dnxt_buf.c86 ts->work.handler = nxt_buf_ts_completion; in nxt_buf_mem_ts_alloc()
257 ts->work.handler = b->completion_handler; in nxt_buf_ts_handle()
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_cache.h73 nxt_work_handler_t handler; member
H A Dnxt_cert.c1063 nxt_port_rpc_handler_t handler, void *ctx) in nxt_cert_store_get() argument
1086 stream = nxt_port_rpc_register_handler(task, recv_port, handler, handler, in nxt_cert_store_get()
1104 handler(task, NULL, ctx); in nxt_cert_store_get()

12345