Home
last modified time | relevance | path

Searched refs:timeout (Results 1 – 25 of 52) sorted by relevance

123

/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointImplClient.java46 long timeout; in doWrite() local
49 timeout = getSendTimeout(); in doWrite()
50 if (timeout < 1) { in doWrite()
51 timeout = Long.MAX_VALUE; in doWrite()
54 timeout = blockingWriteTimeoutExpiry - System.currentTimeMillis(); in doWrite()
55 if (timeout < 0) { in doWrite()
62 channel.write(byteBuffer).get(timeout, TimeUnit.MILLISECONDS); in doWrite()
H A DFutureToSendHandler.java92 public Void get(long timeout, TimeUnit unit) in get() argument
98 retval = latch.await(timeout, unit); in get()
105 Long.valueOf(timeout), unit.toString().toLowerCase())); in get()
H A DAsyncChannelWrapperNonSecure.java62 long timeout, TimeUnit unit, A attachment, in write() argument
65 srcs, offset, length, timeout, unit, attachment, handler); in write()
106 public Void get(long timeout, TimeUnit unit) in get() argument
H A DWsRemoteEndpointAsync.java40 public void setSendTimeout(long timeout) { in setSendTimeout() argument
41 base.setSendTimeout(timeout); in setSendTimeout()
H A DWsWebSocketContainer.java288 long timeout = Constants.IO_TIMEOUT_MS_DEFAULT; in connectToServerRecursive() local
291 timeout = Long.valueOf(timeoutValue).intValue(); in connectToServerRecursive()
308 fConnect.get(timeout, TimeUnit.MILLISECONDS); in connectToServerRecursive()
311 writeRequest(channel, proxyConnect, timeout); in connectToServerRecursive()
341 fConnect.get(timeout, TimeUnit.MILLISECONDS); in connectToServerRecursive()
344 fHandshake.get(timeout, TimeUnit.MILLISECONDS); in connectToServerRecursive()
346 writeRequest(channel, request, timeout); in connectToServerRecursive()
960 public void setDefaultMaxSessionIdleTimeout(long timeout) { in setDefaultMaxSessionIdleTimeout() argument
961 this.defaultMaxSessionIdleTimeout = timeout; in setDefaultMaxSessionIdleTimeout()
1017 public void setAsyncSendTimeout(long timeout) { in setAsyncSendTimeout() argument
[all …]
H A DAsyncChannelWrapper.java41 long timeout, TimeUnit unit, A attachment, in write() argument
H A DAsyncChannelWrapperSecure.java131 long timeout, TimeUnit unit, A attachment, in write() argument
503 public T get(long timeout, TimeUnit unit) in get() argument
506 boolean latchResult = completionLatch.await(timeout, unit); in get()
551 public Integer get(long timeout, TimeUnit unit) in get() argument
554 Long result = wrapped.get(timeout, unit); in get()
/unit/test/unit/
H A Dutils.py20 def waitforfiles(*files, timeout=50): argument
21 for i in range(timeout):
37 def waitforglob(pattern, count=1, timeout=50): argument
38 for i in range(timeout):
91 def waitformount(template, timeout=50): argument
92 for i in range(timeout):
101 def waitforunmount(template, timeout=50): argument
102 for i in range(timeout):
H A Dhttp.py176 timeout = kwargs.get('read_timeout', timeout_default)
181 rlist = select.select([sock], [], [], timeout)[0]
185 if timeout == timeout_default:
/unit/test/
H A Dtest_tls_session.py38 def add_session(self, cache_size=None, timeout=None): argument
43 if timeout is not None:
44 session['timeout'] = timeout
109 assert 'success' in self.add_session(cache_size=5, timeout=1)
125 assert 'error' in self.add_session(timeout=-1)
126 assert 'error' in self.add_session(timeout={})
/unit/src/
H A Dnxt_semaphore.c75 nxt_sem_wait(nxt_sem_t *sem, nxt_nsec_t timeout) in nxt_sem_wait() argument
86 if (timeout == NXT_INFINITE_NSEC) { in nxt_sem_wait()
130 nxt_log_debug(thr->log, "sem_timedwait(%p, %N) enter", sem, timeout); in nxt_sem_wait()
133 ns = now->nsec + timeout; in nxt_sem_wait()
216 nxt_sem_wait(nxt_sem_t *sem, nxt_nsec_t timeout) in nxt_sem_wait() argument
228 err = nxt_thread_cond_wait(&sem->cond, &sem->mutex, timeout); in nxt_sem_wait()
H A Dnxt_thread_cond.c59 nxt_nsec_t timeout) in nxt_thread_cond_wait() argument
69 if (timeout == NXT_INFINITE_NSEC) { in nxt_thread_cond_wait()
85 cond, timeout); in nxt_thread_cond_wait()
89 ns = now->nsec + timeout; in nxt_thread_cond_wait()
H A Dnxt_test_build.c28 epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout) in epoll_wait() argument
87 const timespec_t *timeout) in port_getn() argument
127 int timeout) in pollset_poll() argument
H A Dnxt_thread_pool.h21 nxt_nsec_t timeout; member
37 nxt_nsec_t timeout, nxt_thread_pool_init_t init,
H A Dnxt_select_engine.c34 static void nxt_select_poll(nxt_event_engine_t *engine, nxt_msec_t timeout);
280 nxt_select_poll(nxt_event_engine_t *engine, nxt_msec_t timeout) in nxt_select_poll() argument
289 if (timeout == NXT_INFINITE_MSEC) { in nxt_select_poll()
293 tv.tv_sec = (long) (timeout / 1000); in nxt_select_poll()
294 tv.tv_usec = (long) ((timeout % 1000) * 1000); in nxt_select_poll()
313 nxt_debug(&engine->task, "select() nfds:%d timeout:%M", nfds, timeout); in nxt_select_poll()
H A Dnxt_test_build.h84 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout);
148 const timespec_t *timeout);
203 int timeout);
H A Dnxt_thread_pool.c18 nxt_thread_pool_create(nxt_uint_t max_threads, nxt_nsec_t timeout, in nxt_thread_pool_create() argument
30 tp->timeout = timeout; in nxt_thread_pool_create()
181 err = nxt_sem_wait(&tp->sem, tp->timeout); in nxt_thread_pool_wait()
H A Dnxt_semaphore.h29 NXT_EXPORT nxt_err_t nxt_sem_wait(nxt_sem_t *sem, nxt_nsec_t timeout);
H A Dnxt_eventport_engine.c55 nxt_msec_t timeout);
451 nxt_eventport_poll(nxt_event_engine_t *engine, nxt_msec_t timeout) in nxt_eventport_poll() argument
465 timeout = 0; in nxt_eventport_poll()
469 if (timeout == NXT_INFINITE_MSEC) { in nxt_eventport_poll()
473 ts.tv_sec = timeout / 1000; in nxt_eventport_poll()
474 ts.tv_nsec = (timeout % 1000) * 1000000; in nxt_eventport_poll()
479 engine->u.eventport.fd, timeout); in nxt_eventport_poll()
H A Dnxt_fiber.h51 void nxt_fiber_sleep(nxt_task_t *task, nxt_msec_t timeout);
H A Dnxt_timer.c71 nxt_msec_t timeout) in nxt_timer_add() argument
76 time = engine->timers.now + timeout; in nxt_timer_add()
79 timer->time, timer->bias, timeout, time); in nxt_timer_add()
H A Dnxt_tls.h87 nxt_time_t timeout; member
/unit/src/nodejs/unit-http/
H A Dsocket.js85 Socket.prototype.setTimeout = function setTimeout(timeout, callback) { argument
86 if (typeof timeout !== 'number') {
90 this.timeout = timeout;
/unit/src/java/javax/websocket/
H A DWebSocketContainer.java37 void setAsyncSendTimeout(long timeout); in setAsyncSendTimeout() argument
99 void setDefaultMaxSessionIdleTimeout(long timeout); in setDefaultMaxSessionIdleTimeout() argument
H A DRemoteEndpoint.java47 void setSendTimeout(long timeout); in setSendTimeout() argument

123