Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 406 for swallowed (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/logger/target/kafka/kafka.go

    	store.StreamItems(h.store, h, ctx.Done(), h.kconfig.LogOnce)
    	return err
    }
    
    func (h *Target) startKafkaLogger() {
    	h.logChMu.RLock()
    	logCh := h.logCh
    	if logCh != nil {
    		// We are not allowed to add when logCh is nil
    		h.wg.Add(1)
    		defer h.wg.Done()
    	}
    	h.logChMu.RUnlock()
    
    	if logCh == nil {
    		return
    	}
    
    	// Create a routine which sends json logs received
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

         * <p>
         * This method starts a process with the given command list, manages its execution,
         * handles timeouts, and logs relevant information. It ensures the process is destroyed
         * if it exceeds the allowed execution time or becomes unresponsive. The method also
         * captures and logs the process output for debugging purposes.
         * </p>
         *
         * @param thumbnailId the identifier for the thumbnail being generated
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jan 01 12:47:47 GMT 2026
    - 16.6K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt

          when (dot) {
            -1 -> length - labelStart
            else -> dot - labelStart
          }
        if (labelLength !in 1..63) return true
        if (dot == -1) break
        if (dot == length - 1) break // Trailing '.' is allowed.
        labelStart = dot + 1
      }
    
      return false
    }
    
    internal fun String.containsInvalidHostnameAsciiCodes(): Boolean {
      for (i in 0 until length) {
        val c = this[i]
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 11.2K bytes
    - Click Count (0)
  4. cmd/endpoint-ellipses_test.go

    		// Range cannot start bigger than end.
    		{":9000", []string{"/export1{64...1}"}, false},
    		// Range can only be numeric.
    		{":9000", []string{"/export1{a...z}"}, false},
    		// Duplicate disks not allowed.
    		{":9000", []string{"/export1{1...32}", "/export1{1...32}"}, false},
    		// Same host cannot export same disk on two ports - special case localhost.
    		{":9001", []string{"http://localhost:900{1...2}/export{1...64}"}, false},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  5. internal/auth/credentials.go

    		expAt, err = 0, ErrInvalidDuration
    	}
    	if expAt < 0 {
    		return 0, ErrInvalidDuration
    	}
    	return expAt, err
    }
    
    // GenerateCredentials - creates randomly generated credentials of maximum
    // allowed length.
    func GenerateCredentials() (accessKey, secretKey string, err error) {
    	accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/util/IpAddressUtil.java

     */
    public final class IpAddressUtil {
    
        /**
         * Private constructor to prevent instantiation of utility class.
         */
        private IpAddressUtil() {
            // Utility class - no instances allowed
        }
    
        /**
         * Determines if the given address string represents an IPv6 address.
         * This method validates the address using InetAddress to ensure it's a valid IPv6 address.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 06 08:31:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/project/DefaultMavenProjectBuilder.java

                List<?> repositories, ProjectBuildingRequest request) throws ProjectBuildingException {
            /*
             * This provides backward-compat with 2.x that allowed plugins like the maven-remote-resources-plugin:1.0 to
             * populate the builder configuration with model repositories instead of artifact repositories.
             */
    
            if (repositories != null) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  8. helm-releases/minio-5.0.6.tgz

    service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 13 06:53:06 GMT 2023
    - 20.3K bytes
    - Click Count (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetTestSuiteBuilder.java

          for (Object o : entries) {
            @SuppressWarnings("unchecked")
            Multiset.Entry<E> entry = (Entry<E>) o;
            checkArgument(
                elements.add(entry.getElement()), "Duplicate keys not allowed in EntrySetGenerator");
            for (int i = 0; i < entry.getCount(); i++) {
              contents.add(entry.getElement());
            }
          }
          return ((Multiset<E>) gen.create(contents.toArray())).entrySet();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  10. src/main/java/jcifs/Configuration.java

        /**
         * Enforce secure negotiation
         *
         * Property {@code jcifs.smb.client.requireSecureNegotiate} (boolean, default true)
         *
         * This does not provide any actual downgrade protection if SMB1 is allowed.
         *
         * It will also break connections with SMB2 servers that do not properly sign error responses.
         *
         * @return whether to enforce the use of secure negotiation.
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 25.4K bytes
    - Click Count (0)
Back to Top