Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 94 for Read (0.15 sec)

  1. 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)
  2. 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)
  3. internal/hash/checksum.go

    	h.Write(data)
    	raw := h.Sum(nil)
    	c := Checksum{Type: t, Encoded: base64.StdEncoding.EncodeToString(raw), Raw: raw}
    	if !c.Valid() {
    		return nil
    	}
    	return &c
    }
    
    // ReadCheckSums will read checksums from b and return them.
    func ReadCheckSums(b []byte, part int) map[string]string {
    	res := make(map[string]string, 1)
    	for len(b) > 0 {
    		t, n := binary.Uvarint(b)
    		if n < 0 {
    			break
    		}
    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)
  4. 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)
  5. docs/debugging/xl-meta/main.go

    					return nil, err
    				}
    			case 1, 2:
    				v, b, err := msgp.ReadBytesZC(b)
    				if err != nil {
    					return nil, err
    				}
    				if _, nbuf, err := msgp.ReadUint32Bytes(b); err == nil {
    					// Read metadata CRC (added in v2, ignore if not found)
    					b = nbuf
    				}
    
    				_, err = msgp.CopyToJSON(buf, bytes.NewReader(v))
    				if err != nil {
    					return nil, err
    				}
    				data = b
    			case 3:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  6. cmd/object-api-errors.go

    		return "Unknown"
    	}
    }
    
    // InsufficientReadQuorum storage cannot satisfy quorum for read operation.
    type InsufficientReadQuorum struct {
    	Bucket string
    	Object string
    	Err    error
    	Type   RQErrType
    }
    
    func (e InsufficientReadQuorum) Error() string {
    	return "Storage resources are insufficient for the read operation " + e.Bucket + "/" + e.Object
    }
    
    // Unwrap the error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    	bucket := "bucket"
    	object := "object"
    
    	// Create "bucket"
    	err = obj.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Test: Upload a small file and read it.
    	smallData := []byte{'a'}
    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(smallData), int64(len(smallData)), "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    		return
    	}
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.PutObjectAction, dstBucket, dstObject); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	// Read escaped copy source path to check for parameters.
    	cpSrcPath := r.Header.Get(xhttp.AmzCopySource)
    	var vid string
    	if u, err := url.Parse(cpSrcPath); err == nil {
    		vid = strings.TrimSpace(u.Query().Get(xhttp.VersionID))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  9. cmd/object_api_suite_test.go

    	return &testOneByteReadNoEOF{false, data}
    }
    
    // testOneByteReadNoEOF - implements io.Reader which returns 1 byte and nil error, but
    // returns io.EOF on the next Read().
    type testOneByteReadNoEOF struct {
    	eof  bool
    	data []byte
    }
    
    func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) {
    	if r.eof {
    		return 0, io.EOF
    	}
    	n = copy(p, r.data)
    	r.eof = true
    	return n, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  10. cmd/update.go

    // Check if this is Helm package installation and report helm chart version
    func getHelmVersion(helmInfoFilePath string) string {
    	// Read the file exists.
    	helmInfoFile, err := Open(helmInfoFilePath)
    	if err != nil {
    		// Log errors and return "" as MinIO can be deployed
    		// without Helm charts as well.
    		if !osIsNotExist(err) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
Back to top