Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 1,200 for closer (0.08 sec)

  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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. 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);
    
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/CharStreams.java

       * CharStreams} method returns a singleton writer whose {@code close} method has no effect, while
       * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the
       * instance is {@link Writer#close() closed}.
       *
       * @since 15.0
       */
      public static Writer nullWriter() {
        return NullWriter.INSTANCE;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 29 13:56:24 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  5. tests/prepared_stmt_test.go

    	}
    	pdb.Mux.Unlock()
    
    	pdb.Close()
    	pdb.Mux.Lock()
    	defer pdb.Mux.Unlock()
    	if len(pdb.Stmts.Keys()) != 0 {
    		t.Fatalf("prepared stmt should be empty")
    	}
    }
    
    func isUsingClosedConnError(err error) bool {
    	// https://github.com/golang/go/blob/e705a2d16e4ece77e08e80c168382cdb02890f5b/src/database/sql/sql.go#L2717
    	return err.Error() == "sql: statement is closed"
    }
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  6. 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
        }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  7. 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) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  8. 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)
  9. 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();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (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
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Dec 30 23:59:23 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top