Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 486 for unready (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top