Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,142 for _close (0.14 sec)

  1. src/main/java/jcifs/util/SecureKeyManager.java

                return Integer.parseInt(versionStr);
            } catch (Exception e) {
                return 0;
            }
        }
    
        /**
         * Close the key manager and securely wipe all keys
         */
        @Override
        public void close() {
            if (closed) {
                return;
            }
    
            log.info("Closing SecureKeyManager and wiping all keys");
    
            try {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  2. 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 and
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. 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)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

            @Throws(IOException::class)
            override fun close() {
              if (!cacheRequestClosed &&
                !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
              ) {
                cacheRequestClosed = true
                cacheRequest.abort()
              }
              source.close()
            }
          }
    
        val contentType = response.header("Content-Type")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  5. 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)
  6. 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.isClassPathArchive
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Fri Jun 28 08:29:28 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top