- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 1,539 for afterFn (0.06 seconds)
-
src/test/java/jcifs/smb/SmbPipeHandleImplTest.java
assertFalse(target.isOpen()); assertTrue(target.isStale()); } @Test @DisplayName("getInput and getOutput throw after close") void testGetInputOutputAndClosed() throws CIFSException { // After closing the handle, further calls throw target.close(); CIFSException e1 = assertThrows(SmbException.class, target::getInput);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 11.7K bytes - Click Count (0) -
docs/site-replication/run-multi-site-minio-idp.sh
exit_1 fi sleep 10 ./mc admin user svcacct info minio2 testsvc if [ $? -eq 0 ]; then echo "svc account found after delete, exiting.." exit_1 fi ./mc admin user svcacct info minio3 testsvc if [ $? -eq 0 ]; then echo "svc account found after delete, exiting.." exit_1 fi ./mc mb minio1/newbucket # copy large upload to newbucket on minio1 truncate -s 17M lrgfile
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 24 08:03:58 GMT 2024 - 12.1K bytes - Click Count (0) -
cmd/bootstrap-peer-server_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgServerSystemConfig(b *testing.B) { v := ServerSystemConfig{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.4K bytes - Click Count (0) -
cmd/bucket-metadata_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketMetadata(b *testing.B) { v := BucketMetadata{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/RateLimitHelper.java
/** * Request counters per IP address. * Entries automatically expire after the configured window period. */ protected Cache<String, AtomicLong> requestCounters; /** * Blocked IPs with automatic expiration. * Entries automatically expire after the configured block duration. */ protected Cache<String, Boolean> blockedIps; /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 9.4K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Suppliers.java
+ ")"; } } /** * Returns a supplier that caches the instance supplied by the delegate and removes the cached * value after the specified time has passed. Subsequent calls to {@code get()} return the cached * value if the expiration time has not passed. After the expiration time, a new value is * retrieved, cached, and returned. See: <a * href="http://en.wikipedia.org/wiki/Memoization">memoization</a> *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 31 21:24:28 GMT 2026 - 16.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* #collectValueFromNonCancelledFuture}. As this is called after the subclass is constructed, * we're guaranteed to have properly initialized the subclass. */ final void init() { /* * requireNonNull is safe because this is called from the constructor after `futures` is set but * before releaseResources could be called (because we have not yet set up any of the listeners
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 16K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java
long allocatedBeforeCleanup = bufferManager.getTotalAllocated(); // Cleanup should not throw exception assertDoesNotThrow(() -> bufferManager.cleanup()); // After cleanup, all regions should be released (but the count may not match exactly // if some regions were pooled rather than immediately released)Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.1K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* Cache} interfaces. The {@code asMap} view (and its collection views) have <i>weakly consistent * iterators</i>. This means that they are safe for concurrent use, but if other threads modify the * cache after the iterator is created, it is undefined which of these changes, if any, are * reflected in that iterator. These iterators never throw {@link ConcurrentModificationException}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 52K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt
* * With regular HTTP calls the request always completes sending before the response may begin * receiving. With duplex the request and response may be interleaved! That is, request body bytes * may be sent after response headers or body bytes have been received. * * Though any call may be initiated as a duplex call, only web servers that are specially
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:29 GMT 2025 - 9.3K bytes - Click Count (0)