Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 186 for ready (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top