Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 1,209 for close (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/dsync/dsync-client_test.go

    		u:    u,
    		rest: rest.NewClient(u, tr, nil),
    	}
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ForwardingExecutorServiceTest.java

              @Override
              public void close() {
                throw new AssertionError(
                    "ForwardingExecutorService should have used the default method"
                        + " ExecutorService.close() (which would forward to methods like shutdown() on"
                        + " the delegate) instead of forwarding to delegate.close()");
              }
            };
        ExecutorService wrapper =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 2.9K bytes
    - Click Count (0)
  3. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

            assertEquals("working", result);
    
            // Close it
            cbToClose.close();
    
            // Should not throw exception (close should be idempotent)
            cbToClose.close();
        }
    
        @Test
        public void testEnhancedMetricsTracking() throws Exception {
            SmbCircuitBreaker cbWithEnhanced = new SmbCircuitBreaker("enhanced-test");
    
            try {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  4. src/test/java/jcifs/util/ResourceManagerTest.java

            private final AtomicBoolean closed = new AtomicBoolean(false);
            private final String name;
    
            TestResource(String name) {
                this.name = name;
            }
    
            @Override
            public void close() {
                closed.set(true);
            }
    
            boolean isClosed() {
                return closed.get();
            }
    
            String getName() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  5. src/main/java/jcifs/dcerpc/msrpc/MsrpcSamrCloseHandle.java

    import jcifs.dcerpc.rpc.policy_handle;
    
    /**
     * Microsoft RPC SAM close handle request.
     * This class implements the SAMR close handle operation.
     *
     * @author mbechler
     */
    public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle {
    
        /**
         * Creates a new request to close a SAM handle.
         *
         * @param handle the policy handle to close
         */
        public MsrpcSamrCloseHandle(final policy_handle handle) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcSamrCloseHandle.java

    import jcifs.smb1.dcerpc.rpc;
    
    /**
     * MS-RPC SAMR close handle operation.
     *
     * This class implements the SAMR CloseHandle operation for releasing
     * Security Account Manager (SAM) handles.
     */
    public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle {
    
        /**
         * Creates a new request to close a SAM handle.
         *
         * @param policyHandle the policy handle to close
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  7. src/test/java/jcifs/SmbTransportPoolTest.java

            }
    
            @Test
            @DisplayName("Should close pool with active transports")
            void testClosePoolWithActiveTransports() throws CIFSException {
                // Given
                when(transportPool.close()).thenReturn(true);
    
                // When
                boolean result = transportPool.close();
    
                // Then
                assertTrue(result);
                verify(transportPool).close();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 22.6K bytes
    - Click Count (0)
  8. src/test/java/jcifs/CloseableIteratorTest.java

        @Mock
        private CloseableIterator<SmbResource> mockIterator;
    
        @Test
        @DisplayName("Should define close method")
        void testCloseMethod() throws CIFSException {
            // When
            mockIterator.close();
    
            // Then
            verify(mockIterator).close();
        }
    
        @Test
        @DisplayName("Should extend Iterator and AutoCloseable")
        void testInterfaceInheritance() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 964 bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/AppendableWriter.java

        checkNotClosed();
        if (target instanceof Flushable) {
          ((Flushable) target).flush();
        }
      }
    
      @Override
      public void close() throws IOException {
        this.closed = true;
        if (target instanceof Closeable) {
          ((Closeable) target).close();
        }
      }
    
      @Override
      public Writer append(char c) throws IOException {
        checkNotClosed();
        target.append(c);
        return this;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/io/LittleEndianDataOutputStream.java

        ((DataOutputStream) out).writeUTF(str);
      }
    
      // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
      // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.
      // It should flush itself if necessary.
      @Override
      public void close() throws IOException {
        out.close();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 5.1K bytes
    - Click Count (0)
Back to Top