- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,027 for Closer (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/authenticator/JavaNetAuthenticatorTest.kt
dns = fakeDns } @BeforeEach fun setup() { Authenticator.setDefault(recordingAuthenticator) } @AfterEach fun tearDown() { Authenticator.setDefault(null) factory.close() } @Test fun testBasicAuth() { fakeDns["server"] = listOf(InetAddress.getLocalHost()) val route = factory.newRoute() val request = Request .Builder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
.assertSuccessful() .assertCode(200) println("server1.requestCount ${server1.requestCount}") assertThat(server1.requestCount).isEqualTo(1) // Close the proxy server if (cleanClose) { server1.close() } // Now redirect with DNS to proxyServer2 // Then redirect socket connection to server2 dns["myproxy"] = listOf(proxyServer2)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 11.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
// Disconnect existing transport SmbTransport oldTransport = channel.getTransport(); if (oldTransport != null) { try { oldTransport.close(); } catch (Exception e) { log.debug("Error disconnecting old transport", e); } } // Create new transport
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/net/MimeTypeUtil.java
} return URLConnection.guessContentTypeFromName(path); } catch (final IOException e) { throw new IORuntimeException(e); } finally { CloseableUtil.close(is); } }
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 1.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/UtilTest.kt
val socket = Socket() socket.connect(serverSocket.localSocketAddress) val socketSource = socket.source().buffer() assertThat(socket.isHealthy(socketSource)).isTrue() serverSocket.close() assertThat(socket.isHealthy(socketSource)).isFalse() } @Test fun testDurationTimeUnit() { assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectRequest.java
* * @author mbechler */ public class Smb2TreeDisconnectRequest extends ServerMessageBlock2Request<Smb2TreeDisconnectResponse> { /** * Creates a new SMB2 tree disconnect request to close a tree connection. * * @param config the CIFS configuration */ public Smb2TreeDisconnectRequest(final Configuration config) { super(config, SMB2_TREE_DISCONNECT); } @Override
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.5K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return p.storage.GetDiskLoc() } func (p *xlStorageDiskIDCheck) Close() error { p.diskCancel() return p.storage.Close() } func (p *xlStorageDiskIDCheck) GetDiskID() (string, error) { return p.storage.GetDiskID() } func (p *xlStorageDiskIDCheck) SetDiskID(id string) { p.diskID.Store(&id)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 34.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessRpcClient.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/compression/DefaultCompressionService.java
int uniqueBytes = countUniqueBytes(data); double entropy = (double) uniqueBytes / 256.0; // Estimate compression ratio based on entropy // Lower entropy = better compression return 0.3 + (entropy * 0.6); // Range from 30% to 90% } @Override public int getMinCompressionSize() { return MIN_COMPRESSION_SIZE; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 11.2K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
targetFailed = true } else if tgtSize != tgtCtnt.Size { fmt.Printf("unreadable on target - size differs upon read: %s\n", tgtCtnt.Key) targetFailed = true } }() wg.Wait() sobj.Close() tobj.Close() if !sourceFailed && !targetFailed { ssum := srcSha256.Sum(nil) tsum := tgtSha256.Sum(nil) allgood = bytes.Equal(ssum, tsum) if !allgood {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0)