Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 422 for readPing (0.05 sec)

  1. cmd/xl-storage-format-utils_test.go

    			transfi.TransitionTier = "MINIO-TIER"
    			transfi.TransitionedObjName = mustGetUUID()
    			xl.DeleteVersion(transfi)
    
    			fi.SetTierFreeVersionID(mustGetUUID())
    			// delete this version leading to a free version
    			xl.DeleteVersion(fi)
    			freeVersionIDs = append(freeVersionIDs, fi.TierFreeVersionID())
    			allVersionIDs = append(allVersionIDs, fi.TierFreeVersionID())
    		} else {
    			versions = append(versions, fi)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

      private ExceptionTypePolicy policy = ExceptionTypePolicy.NPE_OR_UOE;
    
      /*
       * Requiring desugaring for guava-*testlib* is likely safe, at least for the reflection-based
       * NullPointerTester. But if you are a user who is reading this because this change caused you
       * trouble, please let us know: https://github.com/google/guava/issues/new
       */
      @IgnoreJRERequirement
      public NullPointerTester() {
        try {
          /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

        disconnectBeforeTrailers(Protocol.HTTP_1_1)
      }
    
      @Test
      fun disconnectBeforeTrailersHttp2() {
        disconnectBeforeTrailers(Protocol.HTTP_2)
      }
    
      /** Confirm we can get an [IOException] reading trailers. */
      private fun disconnectBeforeTrailers(protocol: Protocol) {
        enableProtocol(protocol)
    
        server.enqueue(
          MockResponse
            .Builder()
            .trailers(headersOf("t1", "v2"))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 18K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponseTest.java

            assertEquals(0xFFFFFFFF, response.getCapabilities());
            assertEquals(0xFFFFFFFF, response.getMaximalAccess());
        }
    
        @Test
        @DisplayName("Should handle buffer too small for reading")
        void testBufferTooSmall() {
            // Given
            byte[] buffer = new byte[15]; // Too small for 16-byte structure
            SMBUtil.writeInt2(16, buffer, 0);
    
            // When & Then
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/Files.java

        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file), charset));
      }
    
      /**
       * Returns a new {@link ByteSource} for reading bytes from the given file.
       *
       * @since 14.0
       */
      public static ByteSource asByteSource(File file) {
        return new FileByteSource(file);
      }
    
      private static final class FileByteSource extends
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  6. cmd/bitrot-streaming.go

    		// Offset should always be aligned to b.shardSize
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	if b.rc == nil {
    		// For the first ReadAt() call we need to open the stream for reading.
    		b.currOffset = offset
    		streamOffset := (offset/b.shardSize)*int64(b.h.Size()) + offset
    		if len(b.data) == 0 && b.tillOffset != streamOffset {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          return null // Another edit is in progress.
        }
    
        if (entry != null && entry.lockingSourceCount != 0) {
          return null // We can't write this file because a reader is still reading it.
        }
    
        if (mostRecentTrimFailed || mostRecentRebuildFailed) {
          // The OS has become our enemy! If the trim job failed, it means we are storing more data than
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/io/CharSink.java

       * Does not close {@code readable} if it is {@code Closeable}.
       *
       * @return the number of characters written
       * @throws IOException if an I/O error occurs while reading from {@code readable} or writing to
       *     this sink
       */
      @CanIgnoreReturnValue
      public long writeFrom(Readable readable) throws IOException {
        checkNotNull(readable);
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 16:07:06 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  9. src/test/java/jcifs/pac/ASN1UtilTest.java

        }
    
        // --- as(Class, ASN1InputStream) ---
    
        @Test
        void testAs_ASN1InputStream_Success() throws IOException, PACDecodingException {
            // Test successful reading and casting from ASN1InputStream
            ASN1Integer original = new ASN1Integer(456);
            ByteArrayInputStream bais = new ByteArrayInputStream(original.getEncoded());
            ASN1InputStream ais = new ASN1InputStream(bais);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

         * seenExceptionsField to its exception
         *
         * Thread2: calls setException(), which returns false, CASes seenExceptionsField to its
         * exception, and wrongly believes that its exception is new (leading it to logging it when it
         * shouldn't)
         *
         * Our solution is for threads to CAS seenExceptionsField from null to a Set populated with _the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top