- Sort Score
- Num 10 results
- Language All
Results 591 - 600 of 1,113 for lose (0.02 seconds)
-
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 transportCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (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)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 11.6K bytes - Click Count (0) -
docs/bucket/replication/README.md
to be replicated will eventually be synced to the target cluster as the scanner schedules them. This may be slower depending on the load on the cluster, latency and size of the namespace. In the rare event that target DR site is entirely lost and previously replicated objects to the DR cluster need to be re-replicated, `mc replicate resync start alias/bucket --remote-bucket <arn>` can be used to initiate a reset. This would initiate a re-sync between the two clusters by walking the bucket...
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/AddressTest.kt
import org.junit.jupiter.api.Test class AddressTest { private val factory = TestValueFactory().apply { uriHost = "example.com" uriPort = 80 } @AfterEach fun tearDown() { factory.close() } @Test fun equalsAndHashcode() { val a = factory.newAddress() val b = factory.newAddress() assertThat(b).isEqualTo(a) assertThat(b.hashCode()).isEqualTo(a.hashCode()) }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 1.8K bytes - Click Count (0) -
src/main/java/jcifs/dcerpc/msrpc/SamrDomainHandle.java
handle.sendrecv(rpc); if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } this.opened = true; } @Override public synchronized void close() throws IOException { if (this.opened) { this.opened = false; final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); this.handle.sendrecv(rpc);
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.5K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
public open fun enqueue(response: MockResponse) { responseQueue.add(response) } public open fun clear() { responseQueue.clear() } public override fun close() { responseQueue.add(DEAD_LETTER) } public open fun setFailFast(failFast: Boolean) { setFailFast( failFastResponse = when {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jun 14 16:09:26 GMT 2025 - 2.9K bytes - Click Count (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/nullaway/NullawayStatusService.kt
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Aug 20 13:18:23 GMT 2025 - 3.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessRpcClient.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 12.1K bytes - Click Count (0) -
src/main/java/jcifs/smb/compression/DefaultCompressionService.java
DeflaterOutputStream deflaterStream = new DeflaterOutputStream(baos, new Deflater(COMPRESSION_LEVEL, false)); deflaterStream.write(data, offset, length); deflaterStream.close(); return baos.toByteArray(); } catch (IOException e) { throw new CIFSException("LZ77+Huffman compression failed", e); } } /**
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 11.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
StringWriter writer = new StringWriter(); char[] buf = new char[64]; int read; while ((read = reader.read(buf)) != -1) { writer.write(buf, 0, read); } reader.close(); writer.close(); assertTrue(source.wasStreamClosed()); assertEquals(STRING, writer.toString()); } public void testLines() throws IOException { source = new TestCharSource(LINES);Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 11.5K bytes - Click Count (0)