Home
last modified time | relevance | path

Searched refs:t (Results 1 – 25 of 34) sorted by relevance

12

/unit/src/
H A Dnxt_nvbcq.h42 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_nvbcq_tail_cmp_inc()
85 nxt_nvbcq_atomic_t t, h, i; in nxt_nvbcq_enqueue() local
87 t = nxt_nvbcq_tail(q); in nxt_nvbcq_enqueue()
88 h = t - NXT_NVBCQ_SIZE; in nxt_nvbcq_enqueue()
91 i = nxt_nvbcq_map(q, t); in nxt_nvbcq_enqueue()
100 if ((t - h) == NXT_NVBCQ_SIZE) { in nxt_nvbcq_enqueue()
108 t++; in nxt_nvbcq_enqueue()
116 nxt_nvbcq_atomic_t h, t, i, e; in nxt_nvbcq_dequeue() local
119 t = h + NXT_NVBCQ_SIZE; in nxt_nvbcq_dequeue()
133 if ((t - h) == NXT_NVBCQ_SIZE) { in nxt_nvbcq_dequeue()
[all …]
H A Dnxt_nncq.h39 nxt_nncq_tail_cmp_inc(nxt_nncq_t volatile *q, nxt_nncq_atomic_t t) in nxt_nncq_tail_cmp_inc() argument
41 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_nncq_tail_cmp_inc()
101 nxt_nncq_atomic_t n, t, e, j; in nxt_nncq_enqueue() local
104 t = nxt_nncq_tail(q); in nxt_nncq_enqueue()
105 j = nxt_nncq_map(q, t); in nxt_nncq_enqueue()
109 t_cycle = nxt_nncq_cycle(q, t); in nxt_nncq_enqueue()
112 nxt_nncq_tail_cmp_inc(q, t); in nxt_nncq_enqueue()
127 nxt_nncq_tail_cmp_inc(q, t); in nxt_nncq_enqueue()
H A Dnxt_app_nncq.h39 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() argument
41 nxt_atomic_cmp_set(&q->tail, t, t + 1); in nxt_app_nncq_tail_cmp_inc()
104 nxt_app_nncq_atomic_t n, t, e, j; in nxt_app_nncq_enqueue() local
107 t = nxt_app_nncq_tail(q); in nxt_app_nncq_enqueue()
108 j = nxt_app_nncq_map(q, t); in nxt_app_nncq_enqueue()
112 t_cycle = nxt_app_nncq_cycle(q, t); in nxt_app_nncq_enqueue()
115 nxt_app_nncq_tail_cmp_inc(q, t); in nxt_app_nncq_enqueue()
130 nxt_app_nncq_tail_cmp_inc(q, t); in nxt_app_nncq_enqueue()
H A Dnxt_thread_time.c155 nxt_time_t t; in nxt_thread_time_shared() local
163 t = nxt_shared_time.realtime.sec; in nxt_thread_time_shared()
168 if (now->realtime.sec == t && now->realtime.nsec == n in nxt_thread_time_shared()
H A Dnxt_gnutls.c125 time_t t; in nxt_gnutls_time() local
131 t = (time_t) nxt_thread_time(thr); in nxt_gnutls_time()
134 *tp = t; in nxt_gnutls_time()
137 return t; in nxt_gnutls_time()
/unit/src/java/nginx/unit/websocket/server/
H A DWsRemoteEndpointImplServer.java116 private void clearHandler(Throwable t, boolean useDispatch) { in clearHandler() argument
127 OnResultRunnable r = new OnResultRunnable(sh, t); in clearHandler()
129 if (t == null) { in clearHandler()
132 sh.onResult(new SendResult(t)); in clearHandler()
142 private final Throwable t; field in WsRemoteEndpointImplServer.OnResultRunnable
144 private OnResultRunnable(SendHandler sh, Throwable t) { in OnResultRunnable() argument
146 this.t = t; in OnResultRunnable()
151 if (t == null) { in run()
154 sh.onResult(new SendResult(t)); in run()
H A DWsHttpUpgradeHandler.java150 Thread t = Thread.currentThread(); in onError() local
151 ClassLoader cl = t.getContextClassLoader(); in onError()
152 t.setContextClassLoader(applicationClassLoader); in onError()
156 t.setContextClassLoader(cl); in onError()
H A DUpgradeUtil.java141 for (Transformation t : transformations) { in doUpgrade()
142 negotiatedExtensionsPhase2.add(t.getExtensionResponse()); in doUpgrade()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerBase.java113 protected final void handlePojoMethodException(Throwable t) { in handlePojoMethodException() argument
114 t = ExceptionUtils.unwrapInvocationTargetException(t); in handlePojoMethodException()
115 ExceptionUtils.handleThrowable(t); in handlePojoMethodException()
116 if (t instanceof RuntimeException) { in handlePojoMethodException()
117 throw (RuntimeException) t; in handlePojoMethodException()
119 throw new RuntimeException(t.getMessage(), t); in handlePojoMethodException() local
H A DPojoEndpointBase.java78 } catch (Throwable t) { in doOnOpen()
79 handleOnOpenOrCloseError(session, t); in doOnOpen()
85 private void handleOnOpenOrCloseError(Session session, Throwable t) { in handleOnOpenOrCloseError() argument
87 ExceptionUtils.handleThrowable(t); in handleOnOpenOrCloseError()
90 onError(session, t); in handleOnOpenOrCloseError()
105 } catch (Throwable t) { in onClose()
107 pojo.getClass().getName()), t); in onClose()
108 handleOnOpenOrCloseError(session, t); in onClose()
134 } catch (Throwable t) { in onError()
135 ExceptionUtils.handleThrowable(t); in onError()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelGroupUtil.java139 Thread t = new Thread(r); in run() local
140 t.setName("WebSocketClient-AsyncIO-" + count.incrementAndGet()); in run()
141 t.setContextClassLoader(this.getClass().getClassLoader()); in run()
142 t.setDaemon(true); in run()
143 return t; in run()
H A DBackgroundProcessManager.java92 } catch (Throwable t) { in process()
93 ExceptionUtils.handleThrowable(t); in process()
95 "backgroundProcessManager.processFailed"), t); in process()
H A DWsFrameClient.java119 private final void close(Throwable t) { in close() argument
122 if (t instanceof WsIOException) { in close()
123 cr = ((WsIOException) t).getCloseReason(); in close()
125 cr = new CloseReason(CloseCodes.CLOSED_ABNORMALLY, t.getMessage()); in close()
H A DWsSession.java583 Thread t = Thread.currentThread(); in fireEndpointOnClose() local
584 ClassLoader cl = t.getContextClassLoader(); in fireEndpointOnClose()
585 t.setContextClassLoader(applicationClassLoader); in fireEndpointOnClose()
602 t.setContextClassLoader(cl); in fireEndpointOnClose()
614 Thread t = Thread.currentThread(); in fireEndpointOnError() local
615 ClassLoader cl = t.getContextClassLoader(); in fireEndpointOnError()
620 t.setContextClassLoader(cl); in fireEndpointOnError()
934 } catch (Throwable t) { in onMessage()
935 handleThrowableOnSend(t); in onMessage()
1010 ExceptionUtils.handleThrowable(t); in handleThrowableOnSend()
[all …]
H A DAsyncChannelWrapperSecure.java162 Thread t = new WebSocketSslHandshakeThread(wFuture); in handshake() local
163 t.start(); in handshake()
468 public void fail(Throwable t) { in fail() argument
469 throwable = t; in fail()
570 Thread t = new Thread(r); in newThread() local
571 t.setName("WebSocketClient-SecureIO-" + count.incrementAndGet()); in newThread()
574 t.setDaemon(true); in newThread()
575 return t; in newThread()
H A DWsFrameBase.java356 } catch (Throwable t) { in processDataControl()
357 handleThrowableOnSend(t); in processDataControl()
396 } catch (Throwable t) { in sendMessageText()
397 handleThrowableOnSend(t); in sendMessageText()
556 private void handleThrowableOnSend(Throwable t) throws WsIOException { in handleThrowableOnSend() argument
557 ExceptionUtils.handleThrowable(t); in handleThrowableOnSend()
558 wsSession.getLocal().onError(wsSession, t); in handleThrowableOnSend()
583 } catch (Throwable t) { in sendMessageBinary()
584 handleThrowableOnSend(t); in sendMessageBinary()
910 public void setNext(Transformation t) { in setNext() argument
H A DTransformation.java35 void setNext(Transformation t); in setNext() argument
H A DPerMessageDeflate.java294 public void setNext(Transformation t) { in setNext() argument
296 this.next = t; in setNext()
298 next.setNext(t); in setNext()
/unit/auto/
H A Dtime185 time_t t;
188 t = 0;
189 localtime_r(&t, &tm);
217 time_t t;
220 t = 0;
221 localtime_r(&t, &tm);
/unit/pkg/deb/debian/
H A Dunit.example-python-app12 output += "\t"
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.example-python-app12 output += "\t"
/unit/pkg/deb/debian.module/
H A Dunit.example-python-app12 output += "\t"
/unit/src/test/
H A Dnxt_cq_test.c44 struct timeval t; in elapsed_time() local
46 gettimeofday(&t, NULL); in elapsed_time()
48 return t.tv_sec * 1000000 + t.tv_usec - us; in elapsed_time()
/unit/src/java/nginx/unit/
H A DContext.java3439 public <T extends EventListener> void addListener(T t)
3441 trace("addListener<T> " + t.getClass().getName());
3447 if (c.isAssignableFrom(t.getClass())) {
3452 if (t instanceof ServletContextListener) {
3453 ctx_listeners_.add((ServletContextListener) t);
3456 if (t instanceof ServletContextAttributeListener) {
3460 if (t instanceof ServletRequestListener) {
3469 if (t instanceof HttpSessionAttributeListener) {
3473 if (t instanceof HttpSessionIdListener) {
3477 if (t instanceof HttpSessionListener) {
[all …]
/unit/
H A DCONTRIBUTING.md43 the expected behavior that doesn't occur.
89 - Don't rely on command-line commit messages with `-m`; use the editor instead

12