Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 1,261 for closer (0.04 seconds)

  1. internal/http/server.go

    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    	// Close underneath HTTP listener.
    	srv.listenerMutex.Lock()
    	err := srv.listener.Close()
    	srv.listenerMutex.Unlock()
    	if err != nil {
    		return err
    	}
    
    	// Wait for opened connection to be closed up to Shutdown timeout.
    	return nil
    }
    
    // UseIdleTimeout configure idle connection timeout
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

                }
            }
        }
    
        /**
         * Closes the underlying CrawlerClient and releases any resources associated with it.
         *
         * @throws Exception if an error occurs during the close operation
         */
        @Override
        public void close() throws Exception {
            client.close();
        }
    
        /**
         * Returns the underlying CrawlerClient.
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. internal/config/lambda/event/targetlist.go

    	// Stores any error while removing a target or while sending an event.
    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/core/zip/ZipFileUtil.java

        }
    
        /**
         * Closes the Zip file.
         * <p>
         * If {@link ZipFile#close()} throws an exception, an error message is logged. The exception is not rethrown.
         * </p>
         *
         * @param zipFile
         *            Zip file. Must not be {@literal null}.
         */
        public static void close(final ZipFile zipFile) {
            assertArgumentNotNull("zipFile", zipFile);
    
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  5. internal/stmt_store/stmt_store.go

    	// Cache the Stmt object with the associated key.
    	s.Set(key, cacheStmt)
    	// Unlock after completing initialization to prevent deadlocks.
    	locker.Unlock()
    
    	// Ensure the prepared channel is closed after the function execution completes.
    	defer close(cacheStmt.prepared)
    
    	// Prepare the SQL statement using the provided connection.
    	cacheStmt.Stmt, err = conn.PrepareContext(ctx, key)
    	if err != nil {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  6. 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)
  7. src/main/java/jcifs/util/AuthenticationRateLimiter.java

         * @throws SmbException if account is locked out
         */
        public boolean checkAttempt(String username, String sourceIp) throws SmbException {
            if (closed.get()) {
                throw new IllegalStateException("Rate limiter is closed");
            }
    
            // Check global rate limit
            if (!checkGlobalRateLimit()) {
                totalAttemptsBlocked.incrementAndGet();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClient.java

         */
        ResponseData execute(RequestData data);
    
        /**
         * Closes the crawler client and releases any resources associated with it.
         * This default implementation does nothing.
         *
         * @throws Exception if an error occurs during closing
         */
        @Override
        default void close() throws Exception {
            // nothing
        }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sat Mar 15 06:52:00 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  9. 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)
  10. src/builtin/builtin.go

    func clear[T ~[]Type | ~map[Type]Type1](t T)
    
    // The close built-in function closes a channel, which must be either
    // bidirectional or send-only. It should be executed only by the sender,
    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
Back to Top