Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 1,448 for ready (0.13 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        }
      }
    
      /** Read headers and process any control frames until we reach a non-control frame. */
      @Throws(IOException::class)
      private fun readUntilNonControlFrame() {
        while (!receivedCloseFrame) {
          readHeader()
          if (!isControlFrame) {
            break
          }
          readControlFrame()
        }
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformationResponseTest.java

            response = new Trans2QueryFSInformationResponse(config, FileSystemInformation.SMB_INFO_ALLOCATION);
    
            byte[] buffer = new byte[10];
            int read = response.readSetupWireFormat(buffer, 0, 10);
    
            assertEquals(0, read);
        }
    
        @Test
        void testReadParametersWireFormat() {
            // Test readParametersWireFormat returns 0
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotificationTest.java

            @Test
            @DisplayName("Should handle multiple consecutive reads")
            void testMultipleConsecutiveReads() throws Exception {
                // First read
                byte[] buffer1 = createValidOplockBreakBuffer((byte) 0x01, createTestData(16));
                notification.readBytesWireFormat(buffer1, 0);
    
                // Second read with different values
                byte[] fileId2 = new byte[16];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

            // Read first message
            assertEquals(1, sis.read());
            assertEquals(2, sis.read());
    
            // Read second message
            assertEquals(3, sis.read());
            assertEquals(4, sis.read());
            assertEquals(5, sis.read());
    
            // After all data is consumed, next read throws IOException
            assertThrows(IOException.class, () -> sis.read());
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  5. cmd/metrics-v3-system-process.go

    	processIORCharBytesMD             = NewCounterMD(processIORCharBytes, "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar")
    	processIOReadBytesMD              = NewCounterMD(processIOReadBytes, "Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jun 20 17:55:03 GMT 2024
    - 6.5K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

      var peek: String? = null
    
      while (true) {
        // Read a scheme name for this challenge if we don't have one already.
        if (peek == null) {
          skipCommasAndWhitespace()
          peek = readToken()
          if (peek == null) return
        }
    
        val schemeName = peek
    
        // Read a token68, a sequence of parameters, or nothing.
        val commaPrefixed = skipCommasAndWhitespace()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  7. cmd/untar.go

    	prefixAll  string
    }
    
    // disconnectReader will ensure that no reads can take place on
    // the upstream reader after close has been called.
    type disconnectReader struct {
    	r  io.Reader
    	mu sync.Mutex
    }
    
    func (d *disconnectReader) Read(p []byte) (n int, err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	if d.r != nil {
    		return d.r.Read(p)
    	}
    	return 0, errors.New("reader closed")
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (2)
  8. src/main/java/jcifs/smb/SmbNamedPipe.java

    /**
     * This class will allow a Java program to read and write data to Named
     * Pipes and Transact NamedPipes.
     *
     * <p>
     * There are three Win32 function calls provided by the Windows SDK
     * that are important in the context of using jCIFS. They are:
     *
     * <ul>
     * <li><code>CallNamedPipe</code> A message-type pipe call that opens,
     * writes to, reads from, and closes the pipe in a single operation.
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyResolverResult.java

         * <p>A typical usage is to invoke this method for all dependencies having a
         * {@link DependencyScope#TEST TEST} or {@link DependencyScope#TEST_ONLY TEST_ONLY}
         * {@linkplain Dependency#getScope() scope}. An {@code --add-reads} option may need
         * to be generated for compiling and running the test classes that use such dependencies.</p>
         *
         * @param dependency path to the dependency for which to get the module name
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Mar 05 14:29:21 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/MapMakerInternalMap.java

         * look at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily
         * cause a concurrent read operation to see inconsistent data. This is made easier by the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
Back to Top