Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,204 for readn (0.03 sec)

  1. 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
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Mar 05 14:29:21 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    			if errors.Is(err, io.EOF) {
    				err = nil
    			}
    			break
    		}
    
    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context or network errors returns an error.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. cmd/healthcheck-router.go

    import (
    	"net/http"
    
    	"github.com/minio/mux"
    )
    
    const (
    	healthCheckPath            = "/health"
    	healthCheckLivenessPath    = "/live"
    	healthCheckReadinessPath   = "/ready"
    	healthCheckClusterPath     = "/cluster"
    	healthCheckClusterReadPath = "/cluster/read"
    	healthCheckPathPrefix      = minioReservedBucketPath + healthCheckPath
    )
    
    // registerHealthCheckRouter - add handler functions for liveness and readiness routes.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jan 23 11:12:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. 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 (!closed) {
          readHeader()
          if (!isControlFrame) {
            break
          }
          readControlFrame()
        }
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. 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
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  6. 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.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. 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")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

      }
    
      /**
       * Returns a reader wrapping the given reader that only reads half of the maximum number of
       * characters that it could read in read(char[], int, int).
       */
      private static Reader newNonBufferFillingReader(Reader reader) {
        return new FilterReader(reader) {
          @Override
          public int read(char[] cbuf, int off, int len) throws IOException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/CharStreamsTest.java

      }
    
      /**
       * Returns a reader wrapping the given reader that only reads half of the maximum number of
       * characters that it could read in read(char[], int, int).
       */
      private static Reader newNonBufferFillingReader(Reader reader) {
        return new FilterReader(reader) {
          @Override
          public int read(char[] cbuf, int off, int len) throws IOException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  10. 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];
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.6K bytes
    - Viewed (0)
Back to top