Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 1,312 for reads (0.03 seconds)

  1. internal/http/headers.go

    	// Header indicates if the etag should be preserved by client
    	MinIOSourceETag = "x-minio-source-etag"
    
    	// Writes expected write quorum
    	MinIOWriteQuorum = "x-minio-write-quorum"
    
    	// Reads expected read quorum
    	MinIOReadQuorum = "x-minio-read-quorum"
    
    	// Indicates if we are using default storage class and there was problem loading config
    	// if this header is set to "true"
    	MinIOStorageClassDefaults = "x-minio-storage-class-defaults"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/script/groovy/GroovyEngine.java

     * and DI container integration.
     *
     * <p>Thread Safety: This class is thread-safe. Each cached entry holds its own
     * GroovyClassLoader. The cache uses Guava Cache with segment-based locking for
     * lock-free concurrent reads. Each evaluate() call creates a new Script instance
     * to ensure thread isolation of bindings.</p>
     *
     * <p>Note on class-level isolation: Compiled Script classes are cached and reused.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 11.9K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

      }
    
      /**
       * Regression test for an edge case where closing response body in the HTTP engine doesn't release
       * the corresponding stream allocation. This test keeps those response bodies alive and reads
       * them after the redirect has completed. This forces a connection to not be reused where it would
       * be otherwise.
       *
       *
       * This test leaks a response body by not closing it.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.3K bytes
    - Click Count (1)
  4. src/bytes/reader_test.go

    		t.Errorf("r.Len(): got %d, want %d", got, want)
    	}
    	if n, err := r.Read(make([]byte, 10)); err != nil || n != 10 {
    		t.Errorf("Read failed: read %d %v", n, err)
    	}
    	if got, want := r.Len(), 1; got != want {
    		t.Errorf("r.Len(): got %d, want %d", got, want)
    	}
    	if n, err := r.Read(make([]byte, 1)); err != nil || n != 1 {
    		t.Errorf("Read failed: read %d %v; want 1, nil", n, err)
    	}
    	if got, want := r.Len(), 0; got != want {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  5. 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)
  6. src/test/java/org/codelibs/fess/util/SystemUtilTest.java

                fail("getSearchEngineHttpAddress method should exist");
            }
        }
    
        @Test
        public void test_systemProperty_independence() {
            // Test that method correctly reads from system properties each time
            String originalValue = System.getProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS);
    
            try {
                // Set initial value
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 17.1K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

             * @return True if the process was terminated, false otherwise.
             */
            public boolean isTeminated() {
                return teminated;
            }
        }
    
        /**
         * Thread that reads input stream data and buffers it for later retrieval.
         * Captures output from command execution with configurable line buffering.
         */
        protected static class InputStreamThread extends Thread {
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  8. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            assertEquals(TransPeekNamedPipeResponse.STATUS_LISTENING, response.getStatus());
            // Middle bytes were read but not used
        }
    
        @Test
        @DisplayName("Test consecutive reads update state correctly")
        void testConsecutiveReads() {
            // First read
            byte[] buffer1 = new byte[10];
            SMBUtil.writeInt2(100, buffer1, 0);
            SMBUtil.writeInt2(0, buffer1, 2);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  9. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan any
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

            /** Stores the value lines for the currently processed property.*/
            private final List<String> valueLines;
    
            /** Stores the name of the last read property.*/
            private String propertyName;
    
            /** Stores the value of the last read property.*/
            private String propertyValue;
    
            private boolean maybeTyped;
    
            /** Stores if the properties are typed or not */
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 38.4K bytes
    - Click Count (0)
Back to Top