- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 1,049 for closes (0.04 sec)
-
src/main/java/jcifs/SmbWatchHandle.java
/** * Get the next set of changes * * Will block until the server returns a set of changes that match the given filter. The file will be automatically * opened if it is not and should be closed with {@link #close()} when no longer * needed. * * Closing the context should cancel a pending notify request, but that does not seem to work reliable in all * implementations. *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.3K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/SamrPolicyHandleTest.java
doNothing().when(mockHandle).sendrecv(any(MsrpcSamrConnect4.class)); SamrPolicyHandle handle = new SamrPolicyHandle(mockHandle, server, access); handle.close(); // First close handle.close(); // Second close // Verify sendrecv for close was called only once verify(mockHandle, times(1)).sendrecv(any(MsrpcSamrCloseHandle.class)); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.4K bytes - Viewed (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
* Features: * - Simple state management (CLOSED, OPEN, HALF_OPEN) * - Lock-free atomic operations * - Configurable thresholds and timeouts * - No complex dependencies */ public class SimpleCircuitBreaker { private static final Logger log = LoggerFactory.getLogger(SimpleCircuitBreaker.class); /** * Circuit breaker states */ public enum State { CLOSED, // Normal operation
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 11.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseCommonTest.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt
@Synchronized override fun close() { executor.shutdown() socket?.closeQuietly() serverSocket?.closeQuietly() } override fun toString(): String = "MockHttp2Peer[$port]" private class OutFrame( val sequence: Int, val start: Long, val truncated: Boolean, ) class InFrame( val sequence: Int, val reader: Http2Reader,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 8.7K bytes - Viewed (0) -
cmd/lock-rest-client.go
func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker func (c *lockRESTClient) IsLocal() bool { return false } // Close - marks the client as closed. func (c *lockRESTClient) Close() error { return nil } // String - returns the remote host of the connection. func (c *lockRESTClient) String() string { return c.connection.Remote }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
assertFalse(writer.closed()); source.copyTo(writer); assertFalse(writer.closed()); } public void testClosesOnErrors_copyingToCharSinkThatThrows() { for (TestOption option : EnumSet.of(OPEN_THROWS, WRITE_THROWS, CLOSE_THROWS)) { TestCharSource okSource = new TestCharSource(STRING); assertThrows(IOException.class, () -> okSource.copyTo(new TestCharSink(option)));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 11.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt
) val part = parts.nextPart()!! parts.close() assertFailsWith<IllegalStateException> { part.body.request(10) }.also { expected -> assertThat(expected).hasMessage("closed") } } @Test fun `cannot call nextPart after calling close`() { val parts = MultipartReader( boundary = "simple boundary",
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 15.4K bytes - Viewed (0) -
guava/src/com/google/common/io/CharStreams.java
* CharStreams} method returns a singleton writer whose {@code close} method has no effect, while * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the * instance is {@link Writer#close() closed}. * * @since 15.0 */ public static Writer nullWriter() { return NullWriter.INSTANCE; } private static final class NullWriter extends Writer {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 30 17:25:01 UTC 2025 - 10.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt
.build(), ) val exception = assertFailsWith<IOException> { call2.execute() } assertThat(exception.message).isIn("Socket closed", "Socket is closed") }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3K bytes - Viewed (0)