- Sort Score
- Num 10 results
- Language All
Results 281 - 290 of 1,423 for closed (0.04 seconds)
-
internal/lru/lru.go
c.removeOldest() } c.size = size return diff } // Close destroys cleanup goroutine. To clean up the cache, run Purge() before Close(). // func (c *LRU[K, V]) Close() { // c.mu.Lock() // defer c.mu.Unlock() // select { // case <-c.done: // return // default: // } // close(c.done) // } // removeOldest removes the oldest item from the cache. Has to be called with lock!
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 12.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java
/** * Access to the file is random */ public static final int FILE_RANDOM_ACCESS = 0x800; /** * Delete the file when the last handle to it is closed */ public static final int FILE_DELETE_ON_CLOSE = 0x1000; /** * Open file by its file ID */ public static final int FILE_OPEN_BY_FILE_ID = 0x2000; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 22.9K bytes - Click Count (0) -
src/main/java/jcifs/dcerpc/msrpc/samr.java
} /** The return value of the operation */ public int retval; /** The handle to be closed */ public rpc.policy_handle handle; /** * Constructs a SamrCloseHandle request. * * @param handle The policy handle to close */ public SamrCloseHandle(final rpc.policy_handle handle) { this.handle = handle; }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 23.4K bytes - Click Count (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/samr.java
} /** The return value of the operation */ public int retval; /** The handle to be closed */ public rpc.policy_handle handle; /** * Constructs a SamrCloseHandle request. * * @param handle The policy handle to close */ public SamrCloseHandle(final rpc.policy_handle handle) { this.handle = handle; }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 23.1K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
} /** * {@inheritDoc} * * @see jcifs.SmbTransportPool#close() */ @Override public boolean close() throws CIFSException { boolean inUse = false; // Cleanup first cleanup(); log.debug("Closing pool"); // Create a snapshot of connections to close List<SmbTransportImpl> toClose = new ArrayList<>(this.connections);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 33.4K bytes - Click Count (0) -
internal/s3select/select.go
} } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the // object for reading and a subsequent Close call is required to ensure // resources are freed. func (rsc *ObjectReadSeekCloser) Close() error { rsc.closerOnce.Do(func() { if rsc.reader != nil { rsc.closerErr = rsc.reader.Close() rsc.reader = nil } }) return rsc.closerErr
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (0) -
CHANGELOG.md
of unacknowledged data per stream and no per-connection limit. * Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We had a severe bug where web sockets were closed on the wrong thread, which caused `NullPointerException` crashes in `Deflater`. * Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 15 11:57:47 GMT 2026 - 36.2K bytes - Click Count (2) -
cmd/object-api-utils.go
cleanUpFns: cFns, } return r, nil } } return fn, off, length, nil } // Close - calls the cleanup actions in reverse order func (g *GetObjectReader) Close() error { if g == nil { return nil } // sync.Once is used here to ensure that Close() is // idempotent. g.once.Do(func() { for i := len(g.cleanUpFns) - 1; i >= 0; i-- { g.cleanUpFns[i]() }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Jun 25 15:08:54 GMT 2025 - 37.3K bytes - Click Count (0) -
src/test/java/jcifs/SmbResourceTest.java
class ResourceManagementTests { @Test @DisplayName("close operation should work correctly") void testClose() { // When/Then assertDoesNotThrow(() -> mockResource.close(), "Close operation should not throw exception"); verify(mockResource).close(); } @Test @DisplayName("resource should be AutoCloseable")Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 35K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
windowSizeIncrement = increment, ), ) } handler.windowUpdate(streamId, increment) } @Throws(IOException::class) override fun close() { source.close() } /** * Decompression of the header block occurs above the framing layer. This class lazily reads * continuation frames as they are needed by [Hpack.Reader.readHeaders]. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0)