Searched refs:timeoutMs (Results 1 – 10 of 10) sorted by relevance
91 public static boolean joinUninterruptibly(final Thread thread, long timeoutMs) { in joinUninterruptibly() argument93 long timeRemainingMs = timeoutMs; in joinUninterruptibly()104 timeRemainingMs = timeoutMs - elapsedTimeMs; in joinUninterruptibly()132 public static boolean awaitUninterruptibly(CountDownLatch barrier, long timeoutMs) { in awaitUninterruptibly() argument134 long timeRemainingMs = timeoutMs; in awaitUninterruptibly()146 timeRemainingMs = timeoutMs - elapsedTimeMs; in awaitUninterruptibly()
109 public boolean waitForFramesRendered(int timeoutMs) in waitForFramesRendered() argument111 doneRendering.await(timeoutMs, TimeUnit.MILLISECONDS); in waitForFramesRendered()182 private boolean waitForLocalSDP(int timeoutMs) in waitForLocalSDP() argument186 localSdpEvent.wait(timeoutMs); in waitForLocalSDP()192 private boolean waitForIceCandidates(int timeoutMs) in waitForIceCandidates() argument196 iceCandidateEvent.wait(timeoutMs); in waitForIceCandidates()202 private boolean waitForIceConnected(int timeoutMs) in waitForIceConnected() argument206 iceConnectedEvent.wait(timeoutMs); in waitForIceConnected()216 private boolean waitForPeerConnectionClosed(int timeoutMs) in waitForPeerConnectionClosed() argument220 closeEvent.wait(timeoutMs); in waitForPeerConnectionClosed()
100 private synchronized T doGet(Long timeoutMs) in doGet() argument110 if (timeoutMs == null) { in doGet()114 } else if (timeoutMs > 0) { in doGet()116 long deadlineMs = nowMs + timeoutMs; in doGet()
209 int timeoutMs = request.getTimeoutMs(); in openConnection() local210 connection.setConnectTimeout(timeoutMs); in openConnection()211 connection.setReadTimeout(timeoutMs); in openConnection()
86 int timeoutMs = request.getTimeoutMs(); in performRequest() local90 HttpConnectionParams.setSoTimeout(httpParams, timeoutMs); in performRequest()
46 static final int timeoutMs = 3000; field in JavaGrpcTest196 streamAlive.await(timeoutMs, TimeUnit.MILLISECONDS);232 streamAlive.await(timeoutMs, TimeUnit.MILLISECONDS);
86 public synchronized boolean waitForNewFrame(final long timeoutMs) throws InterruptedException { in waitForNewFrame() argument88 long timeRemainingMs = timeoutMs; in waitForNewFrame()92 timeRemainingMs = timeoutMs - elapsedTimeMs; in waitForNewFrame()
485 public DecodedTextureBuffer dequeueTextureBuffer(int timeoutMs) { in dequeueTextureBuffer() argument487 if (renderedBuffer == null && timeoutMs > 0 && isWaitingForTexture()) { in dequeueTextureBuffer()489 newFrameLock.wait(timeoutMs); in dequeueTextureBuffer()
531 request.timeoutMs = FLAGS.timeoutMs
141 timeoutMs = _messages.IntegerField(6, variant=_messages.Variant.UINT32) variable in BigqueryJobsGetQueryResultsRequest1621 timeoutMs = _messages.IntegerField(7, variant=_messages.Variant.UINT32) variable in QueryRequest