- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 422 for readPing (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 thanRegistered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 34.7K bytes - Viewed (0) -
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) -
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) -
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 _theRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0)