Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for breaker (0.36 sec)

  1. src/main/java/jcifs/smb/SmbTransportImpl.java

                // Log circuit breaker rejection
                auditLogger.logSecurityViolation("Circuit breaker open for SMB connection",
                        java.util.Map.of("address", address.getHostAddress(), "port", String.valueOf(port)));
                throw new IOException("Connection rejected by circuit breaker: " + e.getMessage(), e);
            } catch (RuntimeException e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  2. src/main/resources/fess_config.properties

    suggest.update.contents.limit.num=10000
    # Maximum document size for suggestion update.
    suggest.update.contents.limit.doc.size=50000
    # Scroll size for suggestion source reader.
    suggest.source.reader.scroll.size=1
    # Cache size for popular word suggestion.
    suggest.popular.word.cache.size=1000
    # Cache expiration (seconds) for popular word suggestion.
    suggest.popular.word.cache.expire=60
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 05 14:45:37 UTC 2025
    - 54.7K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    				writeErrorResponse(ctx, w, apiErr, r.URL)
    				return
    			}
    			reader = &b
    			actualSize = n
    		}
    
    		// we have found the File part of the request we are done processing multipart-form
    		break
    	}
    
    	// check if have a file
    	if reader == nil {
    		apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		if err != nil {
    			return setRestoreHeaderFn(oi, toObjectErr(err, bucket, object))
    		}
    		pReader := NewPutObjReader(hashReader)
    		_, err = er.PutObject(ctx, bucket, object, pReader, ropts)
    		return setRestoreHeaderFn(oi, toObjectErr(err, bucket, object))
    	}
    
    	res, err := er.NewMultipartUpload(ctx, bucket, object, ropts)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. cmd/xl-storage_test.go

    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    		w.Write(shard[:n])
    		if err == nil {
    			continue
    		}
    		if err == io.EOF {
    			break
    		}
    		t.Fatal(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  6. docs/bucket/notifications/README.md

    MINIO_NOTIFY_AMQP_COMMENT        (sentence)  optionally add a comment to this setting
    ```
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *ChecksumAlgo) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = ChecksumAlgo(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 56K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/CacheBuilder.java

       *
       * <p>Note that the cache <b>may evict an entry before this limit is exceeded</b>. For example, in
       * the current implementation, when {@code concurrencyLevel} is greater than {@code 1}, each
       * resulting segment inside the cache <i>independently</i> limits its own size to approximately
       * {@code maximumSize / concurrencyLevel}.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  9. src/main/webapp/css/font-awesome.min.css

    -plus-square:before{content:"\f0d4"}.fa-google-wallet:before{content:"\f1ee"}.fa-gopuram:before{content:"\f664"}.fa-graduation-cap:before{content:"\f19d"}.fa-gratipay:before{content:"\f184"}.fa-grav:before{content:"\f2d6"}.fa-greater-than:before{content:"\f531"}.fa-greater-than-equal:before{content:"\f532"}.fa-grimace:before{content:"\f57f"}.fa-grin:before{content:"\f580"}.fa-grin-alt:before{content:"\f581"}.fa-grin-beam:before{content:"\f582"}.fa-grin-beam-sweat:before{content:"\f583"}.fa-grin-...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Dec 14 21:22:25 UTC 2019
    - 55.8K bytes
    - Viewed (2)
  10. android/guava/src/com/google/common/base/CharMatcher.java

       * @param start the first index to examine; must be nonnegative and no greater than {@code
       *     sequence.length()}
       * @return the index of the first matching character, guaranteed to be no less than {@code start},
       *     or {@code -1} if no character matches
       * @throws IndexOutOfBoundsException if start is negative or greater than {@code
       *     sequence.length()}
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 53.9K bytes
    - Viewed (0)
Back to top