- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 390 for finished (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
******@****.***ThreadDoesntHoldLock() var remainingByteCount = byteCount while (remainingByteCount > 0L) { val finished: Boolean val flowControlError: Boolean synchronized(this@Http2Stream) { finished = this.finished flowControlError = remainingByteCount + readBuffer.size > maxByteCount }
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 23.2K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
} } /** * @param finished * The finished to set. */ public void setFinished(final boolean finished) { this.finished = finished; } /** * @return Returns the teminated. */ public boolean isTeminated() { return teminated; } }
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
tests/test_dependency_contextmanager.py
assert middleware_state["context_b"] == "finished b with a: started a" assert middleware_state["context_a"] == "finished a" assert middleware_state["bg"] == "not set" assert state["context_b"] == "finished b with a: started a" assert state["context_a"] == "finished a" assert state["bg"] == "bg set - b: finished b with a: started a - a: finished a" def test_sync_raise_raises():
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Sat Feb 24 23:06:37 GMT 2024 - 11.6K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.cc
// Tells the worker thread that there is new work. tensorflow::condition_variable start_execute_; // The worker thread notifies that work has finished. tensorflow::condition_variable finished_execute_; // Notifies a StartExecute that the previous Join has finished. tensorflow::condition_variable finished_join_; // Temporary state between `StartExecute` and `Join`. //
C++ - Registered: Tue Apr 16 12:39:09 GMT 2024 - Last Modified: Fri Feb 09 07:47:20 GMT 2024 - 25.4K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 20K bytes - Viewed (0) -
docs/contribute/debug_logging.md
[2020-01-01 00:00:00] Q10003 scheduled after 0 µs: OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10003 starting : OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10001 finished run in 3 ms: OkHttp squareup.com applyAndAckSettings [2020-01-01 00:00:00] Q10003 finished run in 528 µs: OkHttp squareup.com onSettings [2020-01-01 00:00:00] Q10000 scheduled after 0 µs: OkHttp ConnectionPool
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 2.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
/** Used by [AsyncCall.run] to signal completion. */ internal fun finished(call: AsyncCall) { call.callsPerHost.decrementAndGet() finished(runningAsyncCalls, call) } /** Used by [Call.execute] to signal completion. */ internal fun finished(call: RealCall) { finished(runningSyncCalls, call) } private fun <T> finished( calls: Deque<T>, call: T, ) {
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 8.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
cmd/metacache.go
dataVersion uint8 `msg:"v"` } func (m *metacache) finished() bool { return !m.ended.IsZero() } // worthKeeping indicates if the cache by itself is worth keeping. func (m *metacache) worthKeeping() bool { if m == nil { return false } cache := m switch { case !cache.finished() && time.Since(cache.lastUpdate) > metacacheMaxRunningAge: // Not finished and update for metacacheMaxRunningAge, discard it. return false
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0)