- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 300 for brokers (0.05 seconds)
-
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) -
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) -
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.VersioningCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
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 stateCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 4.8K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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)