Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 300 for brokers (0.05 seconds)

  1. cmd/signature-v4-utils.go

    		return true
    	case emptySHA256:
    		// some broken clients set empty-sha256
    		// with > 0 content-length in the body,
    		// we should skip such clients and allow
    		// blindly such insecure clients only if
    		// S3 strict compatibility is disabled.
    
    		// We return true only in situations when
    		// deployment has asked MinIO to allow for
    		// such broken clients and content-length > 0.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 25 17:10:22 GMT 2024
    - 9.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/net/InternetDomainName.java

       * {@code co.uk}, {@code google.invalid}, or {@code blogspot.com}.
       *
       * <p>This method can be used to determine whether it will probably be possible to set cookies on
       * the domain, though even that depends on individual browsers' implementations of cookie
       * controls. See <a href="http://www.ietf.org/rfc/rfc2109.txt">RFC 2109</a> for details.
       *
       * @since 6.0
       */
      public boolean isUnderPublicSuffix() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 21:21:59 GMT 2026
    - 26.2K bytes
    - Click Count (0)
  3. cmd/erasure-server-pool-decom.go

    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	var vc *versioning.Versioning
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  4. src/main/java/jcifs/internal/smb2/lock/Smb2LeaseBreakNotification.java

         * @param config the configuration for this notification
         */
        public Smb2LeaseBreakNotification(Configuration config) {
            super(config);
        }
    
        /**
         * Gets the lease key that is being broken
         * @return the lease key
         */
        public Smb2LeaseKey getLeaseKey() {
            return leaseKey;
        }
    
        /**
         * Gets the current lease state before the break
         * @return the current lease state
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  5. tensorflow/c/eager/c_api_test_util.h

    // Return a shape op fetching the shape of `a`.
    TFE_Op* ShapeOp(TFE_Context* ctx, TFE_TensorHandle* a);
    
    // Return an allreduce op adding up input tensor `in` from `group_size` workers.
    TFE_Op* AllReduceOp(TFE_Context* ctx, TFE_TensorHandle* in, int group_size);
    
    // Return a SendOp op `op_name` with send input tensor `in` and attributes
    // `send_device`, `recv_device`, and `send_device_incarnation` set.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Mon Jul 17 23:43:59 GMT 2023
    - 7.7K bytes
    - Click Count (0)
  6. cmd/batch-rotate.go

    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/crypto"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/pkg/v3/env"
    	"github.com/minio/pkg/v3/workers"
    )
    
    // keyrotate:
    //   apiVersion: v1
    //   bucket: BUCKET
    //   prefix: PREFIX
    //   encryption:
    //     type: sse-s3 # valid values are sse-s3 and sse-kms
    //     key: <new-kms-key> # valid only for sse-kms
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. cmd/bucket-replication-metrics.go

    func (m *rateMeasurement) getExpMovingAvgBytesPerSecond() float64 {
    	m.lock.Lock()
    	defer m.lock.Unlock()
    	return m.expMovingAvg
    }
    
    // ActiveWorkerStat is stat for active replication workers
    type ActiveWorkerStat struct {
    	Curr int     `json:"curr"`
    	Avg  float32 `json:"avg"`
    	Max  int     `json:"max"`
    	hist metrics.Histogram
    }
    
    func newActiveWorkerStat(r metrics.Registry) *ActiveWorkerStat {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  8. docs/ko/docs/deployment/docker.md

    그런 경우에는 `--workers` 커맨드 라인 옵션을 사용해 실행할 워커 수를 설정할 수 있습니다:
    
    ```{ .dockerfile .annotate }
    FROM python:3.14
    
    WORKDIR /code
    
    COPY ./requirements.txt /code/requirements.txt
    
    RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
    
    COPY ./app /code/app
    
    # (1)!
    CMD ["fastapi", "run", "app/main.py", "--port", "80", "--workers", "4"]
    ```
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 32.6K bytes
    - Click Count (0)
  9. compat/maven-model-builder/src/main/java/org/apache/maven/model/normalization/DefaultModelNormalizer.java

             * unique within a single POM. Upon multiple declarations, 2.x just kept the last one but retained the order of
             * the first occurrence. So when we're in lenient/compat mode, we have to deal with such broken POMs and mimic
             * the way 2.x works. When we're in strict mode, the removal of duplicates just saves other merging steps from
             * aftereffects and bogus error messages.
             */
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  10. internal/config/heal/heal.go

    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    // GetWorkers returns the number of workers, -1 is none configured
    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 04 19:06:02 GMT 2024
    - 4.9K bytes
    - Click Count (0)
Back to Top