- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 1,514 for close (0.04 seconds)
-
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* should return immediately. Responses returned after shutdown will not be transmitted: their * socket connections have already been closed. */ public open override fun close() {}Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 1.6K bytes - Click Count (0) -
docs/features/interceptors.md
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 8.1K bytes - Click Count (0) -
internal/grid/muxserver.go
case <-t.C: last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0)) if last > 4*m.clientPingInterval { gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last)) m.close() return } } } } // checkSeq will check if sequence number is correct and increment it by 1. func (m *muxServer) checkSeq(seq uint32) (ok bool) { if seq != m.RecvSeq {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.7K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Flushables.java
* method * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws * an {@code IOException}. * @see Closeables#close */ @SuppressWarnings("IdentifierName") // See Closeables.close public static void flush(Flushable flushable, boolean swallowIOException) throws IOException { try { flushable.flush(); } catch (IOException e) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 28 02:48:50 GMT 2024 - 2.5K bytes - Click Count (0) -
internal/event/targetlist_test.go
return nil } // SendFromStore - interface compatible method does no-op. func (target *ExampleTarget) SendFromStore(_ store.Key) error { return nil } func (target ExampleTarget) Close() error { if target.closeErr { return errors.New("close error") } return nil } func (target ExampleTarget) IsActive() (bool, error) { return false, errors.New("not connected to target server/service") }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java
} @Override public void close() throws IOException { state = RdmaConnectionState.CLOSING; try { // In real implementation, this would close the DiSNI endpoint: // if (endpoint != null) { // endpoint.close(); // } } finally { state = RdmaConnectionState.CLOSED; }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 10.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java
assertFalse(region.hasAccess(RdmaAccess.REMOTE_READ), "Should not have remote read access"); // Test cleanup region.close(); assertFalse(region.isValid(), "Region should be invalid after close"); } @Test public void testGetProviderName() { assertEquals("TCP Fallback", provider.getProviderName()); } @Test
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 4.2K bytes - Click Count (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/SamrAliasHandle.java
if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } } /** * Closes this SAM alias handle. * * @throws IOException if an I/O error occurs during handle closure */ public void close() throws IOException { final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); handle.sendrecv(rpc); if (rpc.retval != 0) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.4K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepositoryLifecycle.kt
val userData = context.userData as MutableMap<String, Any?> val key = BinaryCompatibilityRepositorySetupRule.REPOSITORY_CONTEXT_KEY (userData[key] as BinaryCompatibilityRepository).close() userData[key] = null }
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 2.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 07:09:00 GMT 2025 - 15.9K bytes - Click Count (0)