- Sort Score
- Result 10 results
- Languages All
Results 531 - 540 of 887 for closure (0.07 sec)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
var dispatcher: Dispatcher = mockWebServer.dispatcher dispatcher = mockWebServer.dispatcher mockWebServer.dispatcher = QueueDispatcher() mockWebServer.dispatcher = QueueDispatcher() mockWebServer.close() } @Test @Ignore fun pushPromise() { val pushPromise: PushPromise = PushPromise("", "", headersOf(), MockResponse()) val method: String = pushPromise.method
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
// Test that listeners added both before and after the value is available // get called correctly. for (int i = 0; i < 20; i++) { // Right in the middle start up a thread to close the latch. if (i == 10) { new Thread(() -> latch.countDown()).start(); } future.addListener(listenerLatch::countDown, exec); } assertSame(Boolean.TRUE, future.get());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/main/java/jcifs/SmbTransportPool.java
/** * Closes the pool and all connections in it * * @return whether any transport was still in use * * @throws CIFSException * */ boolean close () throws CIFSException; /** * Authenticate arbitrary credentials represented by the * <tt>NtlmPasswordAuthentication</tt> object against the domain controller
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun May 17 09:02:44 UTC 2020 - 6.3K bytes - Viewed (0) -
cmd/callhome.go
return nil } if e := enc.Encode(healthInfo); e != nil { internalLogIf(ctx, fmt.Errorf("Could not encode health info: %w", e)) return nil } gzWriter.Flush() gzWriter.Close() return b.Bytes()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 17 16:53:34 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/http/dial_linux.go
_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15) } // Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket // with dead end because tcp-keepalive is not fired when there is data in the socket buffer. // https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComReadAndX.java
this.maxCount = this.minCount = maxCount; } @Override protected int getBatchLimit ( Configuration cfg, byte cmd ) { return cmd == SMB_COM_CLOSE ? cfg.getBatchLimit("ReadAndX.Close") : 0; } @Override protected int writeParameterWordsWireFormat ( byte[] dst, int dstIndex ) { int start = dstIndex; SMBUtil.writeInt2(this.fid, dst, dstIndex);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
cmd/global-heal.go
bytes: sz, skipped: true, } } // Collect updates to tracker from concurrent healEntry calls results := make(chan healEntryResult, 1000) quitting := make(chan struct{}) defer func() { close(results) <-quitting }() go func() { for res := range results { if res.entryDone { tracker.setObject(res.name) if time.Since(tracker.getLastUpdate()) > time.Minute {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/settings/ArraySettingsTest.java
.pluginTypes("org.codelibs.opensearch.extension.ExtensionPlugin")); runner.ensureYellow(); } @AfterClass public static void afterClass() throws Exception { runner.close(); runner.clean(); } @Before public void before() throws Exception { try { runner.admin().indices().prepareDelete("_all").execute().actionGet();
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 3.6K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt
getOnly = true, ) runBatch(dnsProviders, names) } finally { bootstrapClient.connectionPool.evictAll() bootstrapClient.dispatcher.executorService.shutdownNow() bootstrapClient.cache?.close() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0)