/unit/ |
H A D | CHANGES | 464 handler was used.
|
/unit/go/ |
H A D | nxt_cgo_lib.c | 19 nxt_cgo_run(uintptr_t handler) in nxt_cgo_run() argument 35 init.data = (void *) handler; in nxt_cgo_run()
|
H A D | nxt_cgo_lib.h | 21 int nxt_cgo_run(uintptr_t handler);
|
H A D | request.go | 109 go func(c_req *C.nxt_unit_request_info_t, handler http.Handler) { 117 handler.ServeHTTP(&r.resp, &r.req)
|
H A D | unit.go | 107 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 D | unit.example-go-app | 9 func handler(w http.ResponseWriter, r *http.Request) { 18 http.HandleFunc("/", handler)
|
/unit/pkg/deb/debian/ |
H A D | unit.example-go-app | 9 func handler(w http.ResponseWriter, r *http.Request) { 18 http.HandleFunc("/", handler)
|
/unit/pkg/rpm/rpmbuild/SOURCES/ |
H A D | unit.example-go-app | 9 func handler(w http.ResponseWriter, r *http.Request) { 18 http.HandleFunc("/", handler)
|
/unit/src/java/javax/websocket/ |
H A D | Session.java | 50 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 D | Request.java | 1215 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 D | AsyncChannelWrapper.java | 36 CompletionHandler<Integer,B> handler); in read() argument 42 CompletionHandler<Long,B> handler); in write() argument
|
H A D | AsyncChannelWrapperNonSecure.java | 51 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 D | AsyncChannelWrapperSecure.java | 95 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 D | LocalStrings.properties | 47 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 D | MessageHandlerResult.java | 23 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 D | WsFrameClient.java | 37 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 D | WsRemoteEndpointImplBase.java | 150 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 D | WsRemoteEndpointImplClient.java | 44 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 D | WsSession.java | 238 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 D | WsRemoteEndpointImplServer.java | 47 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 D | websocket_router.js | 107 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 D | nxt_buf.c | 86 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 D | nxt_cache.c | 134 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 D | nxt_cache.h | 73 nxt_work_handler_t handler; member
|
H A D | nxt_cert.c | 1063 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()
|