- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 1,142 for _close (0.04 sec)
-
src/main/java/jcifs/util/SecureKeyManager.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 21.5K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes andRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 8.8K bytes - Viewed (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; }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 10.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 10.3K bytes - Viewed (0) -
internal/event/target/amqp.go
return err } // Delete the event from store. return target.store.Del(key) } // Close - does nothing and available for interface compatibility. func (target *AMQPTarget) Close() error { close(target.quitCh) if target.conn != nil { return target.conn.Close() } return nil } func (target *AMQPTarget) init() error { return target.initOnce.Do(target.initAMQP) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 21 04:25:07 UTC 2025 - 10K bytes - Viewed (0) -
build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/support/ClassBytesRepository.kt
} } private fun openJarFile(file: File) = openJars.computeIfAbsent(file, ::JarFile) override fun close() { openJars.values.forEach(JarFile::close) } } /** * See https://docs.oracle.com/javase/8/docs/technotes/tools/findingclasses.html#userclass */ private val File.isClassPathArchiveRegistered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Fri Jun 28 08:29:28 UTC 2024 - 6.3K bytes - Viewed (0) -
prepare_stmt.go
} return nil, ErrInvalidDB } // Close closes all prepared statements in the store func (db *PreparedStmtDB) Close() { db.Mux.Lock() defer db.Mux.Unlock() for _, key := range db.Stmts.Keys() { db.Stmts.Delete(key) } } // Reset Deprecated use Close instead func (db *PreparedStmtDB) Reset() { db.Close() }Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 5.7K bytes - Viewed (0) -
internal/event/target/mysql.go
return err } // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to MySQL database. func (target *MySQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil { // FIXME: log returned error. ignore time being. _ = target.updateStmt.Close() } if target.deleteStmt != nil { // FIXME: log returned error. ignore time being.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 11.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/LsaPolicyHandle.java
handle.sendrecv(rpc); if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } } /** * Closes the LSA policy handle. * * @throws IOException if an I/O error occurs */ public void close() throws IOException { final MsrpcLsarClose rpc = new MsrpcLsarClose(this); handle.sendrecv(rpc); if (rpc.retval != 0) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/util/AuthenticationRateLimiter.java
totalAttemptsBlocked.set(0); totalAccountsLocked.set(0); totalIpsBlocked.set(0); log.info("Rate limiter state reset"); } @Override public void close() { if (!closed.compareAndSet(false, true)) { return; } cleanupScheduler.shutdownNow(); try { cleanupScheduler.awaitTermination(5, TimeUnit.SECONDS);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.1K bytes - Viewed (0)