Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 1,049 for closes (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ResponseCommonTest.kt

       * most [BufferedSource] instances, but not of [Buffer].
       */
      private fun responseBody(content: String): ResponseBody {
        val data = Buffer().writeUtf8(content)
        val source: Source =
          object : Source {
            var closed = false
    
            override fun close() {
              closed = true
            }
    
            override fun read(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top