- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 186 for ready (0.22 sec)
-
cmd/storage-rest-server.go
// the Close() function is called. type closeNotifier struct { rc io.ReadCloser done chan struct{} } func (c *closeNotifier) Read(p []byte) (n int, err error) { n, err = c.rc.Read(p) if err != nil { if c.done != nil { xioutil.SafeClose(c.done) c.done = nil } } return n, err } func (c *closeNotifier) Close() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/globals.go
ptr := globalDeploymentIDPtr.Load() if ptr == nil { return "" } return *ptr } globalAllHealState = newHealState(GlobalContext, true) // The always present healing routine ready to heal objects globalBackgroundHealRoutine = newHealRoutine() globalBackgroundHealState = newHealState(GlobalContext, false) globalMRFState = mrfState{ opCh: make(chan partialOperation, mrfOpsQueueSize), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/config/api/api.go
EnvAPIObjectMaxVersions = "MINIO_API_OBJECT_MAX_VERSIONS" EnvAPIObjectMaxVersionsLegacy = "_MINIO_OBJECT_MAX_VERSIONS" ) // Deprecated key and ENVs const ( apiReadyDeadline = "ready_deadline" apiReplicationWorkers = "replication_workers" apiReplicationFailedWorkers = "replication_failed_workers" ) // DefaultKVS - default storage class config var ( DefaultKVS = config.KVS{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
cmd/signature-v4_test.go
"X-Amz-Date": now.Format(iso8601Format), "X-Amz-Content-Sha256": payloadSHA256, }, region: region, expected: ErrSignatureDoesNotMatch, }, // (6) Should error if the request is not ready yet, ie X-Amz-Date is in the future. { queryParams: map[string]string{ "X-Amz-Algorithm": signV4Algorithm, "X-Amz-Date": now.Add(1 * time.Hour).Format(iso8601Format),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 10.4K bytes - Viewed (1) -
internal/hash/checksum.go
return NewChecksumWithType(NewChecksumType(alg), value) } // AppendTo will append the checksum to b. // 'parts' is used when checksum has ChecksumMultipart set. // ReadCheckSums reads the values back. func (c *Checksum) AppendTo(b []byte, parts []byte) []byte { if c == nil { return nil } var tmp [binary.MaxVarintLen32]byte n := binary.PutUvarint(tmp[:], uint64(c.Type)) crc := c.Raw
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/encryption-v1_test.go
t.Fatalf("Impossible read specified: %d %d %d", skipLen, readLen, oSize) } var cumulativeSum, cumulativeEncSum int64 toRead := readLen readStart := false for i, v := range s { partOffset := int64(0) partDarePkgOffset := int64(0) if !readStart && cumulativeSum+v > skipLen { // Read starts at the current part readStart = true
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
type diskHealthWrapper struct { tracker *healthDiskCtxValue r io.Reader w io.Writer } func (d *diskHealthWrapper) Read(p []byte) (int, error) { if d.r == nil { return 0, fmt.Errorf("diskHealthWrapper: Read with no reader") } n, err := d.r.Read(p) if err == nil || err == io.EOF && n > 0 { d.tracker.logSuccess() } return n, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/s3select/select.go
} return rsc.offset, nil } // Read call to implement io.Reader func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) { if rsc.reader == nil { rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} copy(objectEncryptionKey[:], key) partEncryptionKey := objectEncryptionKey.DerivePartKey(uint32(partID)) in := io.Reader(hashReader) if size > encryptBufferThreshold { // The encryption reads in blocks of 64KB. // We add a buffer on bigger files to reduce the number of syscalls upstream. in = bufio.NewReaderSize(hashReader, encryptBufferSize) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
docs/config/README.md
### Certificate Directory TLS certificates by default are expected to be stored under ``${HOME}/.minio/certs`` directory. You need to place certificates here to enable `HTTPS` based access. Read more about [How to secure access to MinIO server with TLS](https://min.io/docs/minio/linux/operations/network-encryption.html). Following is a sample directory structure for MinIO server with TLS certificates. ```sh
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0)