| /unit/src/java/nginx/unit/websocket/server/ |
| H A D | WsRemoteEndpointImplServer.java | 116 private void clearHandler(Throwable t, boolean useDispatch) { in clearHandler()
142 private final Throwable t; field in WsRemoteEndpointImplServer.OnResultRunnable
144 private OnResultRunnable(SendHandler sh, Throwable t) { in OnResultRunnable()
|
| H A D | WsHttpUpgradeHandler.java | 150 Thread t = Thread.currentThread(); in onError() local
|
| /unit/src/ |
| H A D | nxt_nvbcq.h | 40 nxt_nvbcq_tail_cmp_inc(nxt_nvbcq_t volatile *q, nxt_nvbcq_atomic_t t) in nxt_nvbcq_tail_cmp_inc()
85 nxt_nvbcq_atomic_t t, h, i; in nxt_nvbcq_enqueue() local
116 nxt_nvbcq_atomic_t h, t, i, e; in nxt_nvbcq_dequeue() local
|
| H A D | nxt_app_nncq.h | 39 nxt_app_nncq_tail_cmp_inc(nxt_app_nncq_t volatile *q, nxt_app_nncq_atomic_t t) in nxt_app_nncq_tail_cmp_inc()
104 nxt_app_nncq_atomic_t n, t, e, j; in nxt_app_nncq_enqueue() local
|
| H A D | nxt_nncq.h | 39 nxt_nncq_tail_cmp_inc(nxt_nncq_t volatile *q, nxt_nncq_atomic_t t) in nxt_nncq_tail_cmp_inc()
101 nxt_nncq_atomic_t n, t, e, j; in nxt_nncq_enqueue() local
|
| H A D | nxt_sha1.c | 129 #define STEP(f, a, b, c, d, e, w, t) \ argument
|
| H A D | nxt_thread_time.c | 155 nxt_time_t t; in nxt_thread_time_shared() local
|
| H A D | nxt_php_sapi.c | 904 nxt_php_str_trim_trail(nxt_str_t *str, u_char t) in nxt_php_str_trim_trail()
915 nxt_php_str_trim_lead(nxt_str_t *str, u_char t) in nxt_php_str_trim_lead()
|
| H A D | nxt_gnutls.c | 125 time_t t; in nxt_gnutls_time() local
|
| H A D | nxt_conf_validation.c | 1358 nxt_uint_t value_type, n, t; in nxt_conf_vldt_type() local
|
| H A D | nxt_router.c | 1610 nxt_str_t *t, *s, *targets; in nxt_router_conf_create() local
|
| /unit/src/java/nginx/unit/websocket/pojo/ |
| H A D | PojoMessageHandlerBase.java | 113 protected final void handlePojoMethodException(Throwable t) { in handlePojoMethodException()
119 throw new RuntimeException(t.getMessage(), t); in handlePojoMethodException() local
|
| H A D | PojoEndpointBase.java | 85 private void handleOnOpenOrCloseError(Session session, Throwable t) { in handleOnOpenOrCloseError()
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | Transformation.java | 35 void setNext(Transformation t); in setNext()
|
| H A D | AsyncChannelGroupUtil.java | 139 Thread t = new Thread(r); in run() local
|
| H A D | WsFrameClient.java | 119 private final void close(Throwable t) { in close()
|
| H A D | AsyncChannelWrapperSecure.java | 162 Thread t = new WebSocketSslHandshakeThread(wFuture); in handshake() local
468 public void fail(Throwable t) { in fail()
570 Thread t = new Thread(r); in newThread() local
|
| H A D | WsSession.java | 583 Thread t = Thread.currentThread(); in fireEndpointOnClose() local
614 Thread t = Thread.currentThread(); in fireEndpointOnError() local
1009 private void handleThrowableOnSend(Throwable t) throws WsIOException { in handleThrowableOnSend()
|
| H A D | WsFrameBase.java | 556 private void handleThrowableOnSend(Throwable t) throws WsIOException { in handleThrowableOnSend()
910 public void setNext(Transformation t) { in setNext()
|
| H A D | PerMessageDeflate.java | 294 public void setNext(Transformation t) { in setNext()
|
| H A D | WsWebSocketContainer.java | 470 Transformation t = factory.create(extension.getName(), wrapper, false); in connectToServerRecursive() local
|
| /unit/src/test/ |
| H A D | nxt_cq_test.c | 44 struct timeval t; in elapsed_time() local
|