Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for read (0.13 sec)

  1. cmd/erasure-object.go

    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    		// - xl.meta for inlined objects has already read the data
    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. cmd/erasure-server-pool.go

    	derrs := make([]error, len(poolIndices))
    	dobjects := make([]ObjectInfo, len(poolIndices))
    
    	// Delete concurrently in all server pools that reported no error or read quorum error
    	// where the read quorum issue is from metadata inconsistency.
    	var wg sync.WaitGroup
    	for idx, pe := range poolIndices {
    		if v, ok := pe.Err.(InsufficientReadQuorum); ok && v.Type != RQInconsistentMeta {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. 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)
  4. cmd/object-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	api.getObjectAttributesHandler(ctx, objectAPI, bucket, object, w, r)
    }
    
    // HeadObjectHandler - HEAD Object
    // -----------
    // The HEAD operation retrieves metadata from an object without returning the object itself.
    func (api objectAPIHandlers) HeadObjectHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "HeadObject")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/common-main.go

    	ctxt.Interface = ctx.String("interface")
    	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
    	ctxt.ConnReadDeadline = ctx.Duration("conn-read-deadline")
    	ctxt.ConnWriteDeadline = ctx.Duration("conn-write-deadline")
    	ctxt.ConnClientReadDeadline = ctx.Duration("conn-client-read-deadline")
    	ctxt.ConnClientWriteDeadline = ctx.Duration("conn-client-write-deadline")
    	ctxt.SendBufSize = ctx.Int("send-buf-size")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  6. cmd/test-utils_test.go

    	// If the body is read in the handler the same request cannot be made use of.
    	buf, err := io.ReadAll(anonReq.Body)
    	if err != nil {
    		t.Fatal(failTestStr(anonTestStr, err.Error()))
    	}
    
    	// creating 2 read closer (to set as request body) from the body content.
    	readerOne := io.NopCloser(bytes.NewBuffer(buf))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  7. internal/event/name.go

    	case ObjectAccessedGetRetention:
    		return "s3:ObjectAccessed:GetRetention"
    	case ObjectAccessedGetLegalHold:
    		return "s3:ObjectAccessed:GetLegalHold"
    	case ObjectAccessedHead:
    		return "s3:ObjectAccessed:Head"
    	case ObjectAccessedAttributes:
    		return "s3:ObjectAccessed:Attributes"
    	case ObjectCreatedAll:
    		return "s3:ObjectCreated:*"
    	case ObjectCreatedCompleteMultipartUpload:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  8. 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:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  9. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  10. cmd/format-erasure.go

    		return nil, err
    	}
    
    	return getFormatErasureInQuorum(formats)
    }
    
    // ecDrivesNoConfig returns the erasure coded drives in a set if no config has been set.
    // It will attempt to read it from env variable and fall back to drives/2.
    func ecDrivesNoConfig(setDriveCount int) (int, error) {
    	sc, err := storageclass.LookupConfig(config.KVS{}, setDriveCount)
    	if err != nil {
    		return 0, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
Back to top