Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Breiding (0.71 sec)

  1. cmd/xl-storage.go

    // for io.EOF.
    //
    // If an EOF happens after reading some but not all the bytes,
    // ReadFile returns ErrUnexpectedEOF.
    //
    // If the BitrotVerifier is not nil or not verified ReadFile
    // tries to verify whether the disk has bitrot.
    //
    // Additionally ReadFile also starts reading from an offset. ReadFile
    // semantics are same as io.ReadFull.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		readMsgpReaderPool.Put(r)
    	}
    }
    
    func (client *storageRESTClient) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) {
    	// Use websocket when not reading data.
    	if !opts.ReadData {
    		resp, err := storageReadVersionRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    			storageRESTDiskID:     *client.diskID.Load(),
    			storageRESTOrigVolume: origvolume,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, object, &er)
    	}
    
    	if !opts.NoLock {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		ctx = lkctx.Context()
    		defer lk.RUnlock(lkctx)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  4. cmd/xl-storage-disk-id-check.go

    		// coming up and trying to read format.json or create format.json
    		return nil
    	}
    	storedDiskID, err := p.storage.GetDiskID()
    	if err != nil {
    		// return any error generated while reading `format.json`
    		return err
    	}
    	if err == nil && *p.diskID.Load() == storedDiskID {
    		return nil
    	}
    	// not the same disk we remember, take it offline.
    	return errDiskNotFound
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) {
    	if opts.CheckPrecondFn != nil {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		rctx := lkctx.Context()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  6. cmd/object-handlers_test.go

    		}
    		// read the response body.
    		actualContent, err := io.ReadAll(rec.Body)
    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed reading response body: <ERROR> %v", i+1, instanceType, err)
    		}
    
    		if rec.Code == http.StatusOK || rec.Code == http.StatusPartialContent {
    			if !bytes.Equal(testCase.expectedContent, actualContent) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top