- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 486 for unready (0.04 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val index = serialTaskQueue.indexOfFirst { it.isReady() } if (index == -1) return null val nextTask = serialTaskQueue.removeAt(index) currentTask = nextTask contextSwitchCount++ nextTask.start() return nextTask } private interface SerialTask { /** Returns true if this task is ready to start. */ fun isReady() = true
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
src/bytes/buffer.go
b.off += n b.lastRead = readOp(n) return r, n, nil } // UnreadRune unreads the last rune returned by [Buffer.ReadRune]. // If the most recent read or write operation on the buffer was // not a successful [Buffer.ReadRune], UnreadRune returns an error. (In this regard // it is stricter than [Buffer.UnreadByte], which will unread the last byte // from any read operation.) func (b *Buffer) UnreadRune() error {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 17:38:56 UTC 2025 - 16K bytes - Viewed (0) -
src/bufio/bufio.go
if b.err != nil { return 0, b.readErr() } b.fill() // buffer is empty } c := b.buf[b.r] b.r++ b.lastByte = int(c) return c, nil } // UnreadByte unreads the last byte. Only the most recently read byte can be unread. // // UnreadByte returns an error if the most recent method called on the // [Reader] was not a read operation. Notably, [Reader.Peek], [Reader.Discard], and [Reader.WriteTo] are not
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed Sep 03 14:04:47 UTC 2025 - 22K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
rawSocket?.closeQuietly() } } } override fun connectTlsEtc(): ConnectResult { val rawSocket = requireNotNull(rawSocket) { "TCP not connected" } check(!isReady) { "already connected" } val connectionSpecs = route.address.connectionSpecs var retryTlsConnection: ConnectPlan? = null var success = false
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} } /** * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary * until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately * this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { assertLockHeld()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
private byte[] b; private int n; private boolean ready; private SmbFileOutputStream out; private SmbException e = null; WriterThread() { super("JCIFS-WriterThread"); this.ready = false; } /** * @return the ready */ boolean isReady() { return this.ready; } /** * @throws SmbException *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 16.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbCopyUtilTest.java
w.start(); // Wait until writer thread is ready synchronized (w) { long deadline = System.currentTimeMillis() + 2000; while (!w.isReady() && System.currentTimeMillis() < deadline) { w.wait(10); } assertTrue(w.isReady(), "WriterThread should be ready"); // Submit a write that will throw inside the writer thread
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/SmbComTransactionTest.java
void testPadCalculation() { // Test pad calculation with different alignment values assertEquals(0, transaction.pad(0)); // Already aligned assertEquals(0, transaction.pad(4)); // Already aligned assertEquals(0, transaction.pad(8)); // Already aligned assertEquals(3, transaction.pad(1)); // Need 3 bytes to align to 4 assertEquals(2, transaction.pad(2)); // Need 2 bytes to align to 4
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.7K bytes - Viewed (0) -
docs/en/docs/history-design-future.md
## Development { #development } By the time I started creating **FastAPI** itself, most of the pieces were already in place, the design was defined, the requirements and tools were ready, and the knowledge about the standards and specifications was clear and fresh. ## Future { #future } By this point, it's already clear that **FastAPI** with its ideas is being useful for many people.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 4.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
service.startAsync(); } catch (IllegalStateException e) { // This can happen if the service has already been started or stopped (e.g. by another // service or listener). Our contract says it is safe to call this method if // all services were NEW when it was called, and this has already been verified above, so we // don't propagate the exception.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (1)