Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for READ (0.02 seconds)

  1. cmd/object-handlers_test.go

    				// Read last byte of object
    				fmt.Sprintf("bytes=-%d", 1),
    				// Read all but first byte of object
    				"bytes=1-",
    				// Read first half of object
    				fmt.Sprintf("bytes=%d-%d", 0, objLen/2),
    				// Read last half of object
    				fmt.Sprintf("bytes=-%d", objLen/2),
    				// Read middle half of object
    				fmt.Sprintf("bytes=%d-%d", objLen/4, objLen*3/4),
    				// Read 100MiB of the object from the beginning
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  2. cmd/metrics-v2.go

    		Name:      rcharBytes,
    		Help:      "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar",
    		Type:      counterMetric,
    	}
    }
    
    func getMinIOProcessSysCallRMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: sysCallSubsystem,
    		Name:      readTotal,
    		Help:      "Total read SysCalls to the kernel. /proc/[pid]/io syscr",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  3. cmd/bucket-replication.go

    		defer rc.Close()
    
    		if !p.initialized() {
    			return re, nil
    		}
    		var data [4]byte
    		n, err := rc.Read(data[:])
    		if err != nil {
    			return re, err
    		}
    		if n != len(data) {
    			return re, errors.New("replication mrf: no data")
    		}
    		// Read resync meta header
    		switch binary.LittleEndian.Uint16(data[0:2]) {
    		case mrfMetaFormat:
    		default:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  4. cmd/admin-handlers.go

    	if logKind == 0 {
    		logKind = madmin.LogMaskAll
    	}
    
    	// Avoid reusing tcp connection if read timeout is hit
    	// This is needed to make r.Context().Done() work as
    	// expected in case of read timeout
    	w.Header().Set("Connection", "close")
    
    	setEventStreamHeaders(w)
    
    	logCh := make(chan log.Info, 1000)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  5. cmd/object-handlers.go

    		return
    	}
    
    	if r.ContentLength <= 0 {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEmptyRequestBody), r.URL)
    		return
    	}
    
    	// Take read lock on object, here so subsequent lower-level
    	// calls do not need to.
    	lock := objectAPI.NewNSLock(bucket, object)
    	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  6. cmd/sts-handlers_test.go

    	}
    
    	gotBuckets := set.NewStringSet()
    	for _, b := range accInfo.Buckets {
    		gotBuckets.Add(b.Name)
    		if !b.Access.Read || !b.Access.Write {
    			c.Fatalf("root user should have read and write access to bucket: %v", b.Name)
    		}
    	}
    	shouldHaveBuckets := set.CreateStringSet(bucket2, bucket)
    	if !gotBuckets.Equals(shouldHaveBuckets) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
  7. cmd/server_test.go

    	c.Assert(err, nil)
    	// Since only part of the object is requested, expecting response status to be http.StatusPartialContent .
    	c.Assert(response.StatusCode, http.StatusPartialContent)
    	// read the downloaded content from the response body.
    	getContent, err := io.ReadAll(response.Body)
    	c.Assert(err, nil)
    
    	// Compare putContent and getContent.
    	c.Assert(string(getContent), putContent[10485750:10485770])
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  8. cmd/site-replication.go

    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    	// attempt to read just the version key in the state file to ensure we
    	// are reading a compatible version.
    	var ver struct {
    		Version int `json:"version"`
    	}
    	err = json.Unmarshal(buf, &ver)
    	if err != nil {
    		return err
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  9. cmd/testdata/decryptObjectInfo.json.zst

    n-S3-Sealed-Key":"IAAfAMW1CTBkkFiL3sKx+jTM/1Klxvcj2NRf2uywmpcB0/+w==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/internal/goobj/read.go","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"tvb+rLRu+so5/ridUkmol22E5Q2AKt3tp=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-key","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key":"IAAfAKCx+Lvsgx4ocR...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 29 16:34:20 GMT 2020
    - 164K bytes
    - Click Count (0)
Back to Top