- Sort Score
- Num 10 results
- Language All
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.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)