Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Read (0.16 sec)

  1. cmd/xl-storage.go

    	if err != nil {
    		// We start off with '0' if we can read the attributes
    		return 0
    	}
    	return binary.LittleEndian.Uint64(buf[:8])
    }
    
    func (s *xlStorage) getWriteAttribute() uint64 {
    	attr := "user.total_writes"
    	buf, err := xattr.LGet(s.formatFile, attr)
    	if err != nil {
    		// We start off with '0' if we can read the attributes
    		return 0
    	}
    
    	return binary.LittleEndian.Uint64(buf[:8])
    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/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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  3. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    	} else {
    		c.iamUsersMap[key] = u
    	}
    	c.updatedAt = time.Now()
    	return nil
    }
    
    // IAMStorageAPI defines an interface for the IAM persistence layer
    type IAMStorageAPI interface {
    	// The role of the read-write lock is to prevent go routines from
    	// concurrently reading and writing the IAM storage. The (r)lock()
    	// functions return the iamCache. The cache can be safely written to
    	// only when returned by `lock()`.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. cmd/object-api-listobjects_test.go

    				// The length of the expected ListObjectsResult.Objects
    				// should match in both expected result from test cases
    				// and in the output. On failure calling t.Fatalf,
    				// otherwise it may lead to index out of range error in
    				// assertion following this.
    				if !testCase.versioned {
    					if len(testCase.resultL.Objects) != len(resultL.Objects) {
    						t.Logf("want: %v", objInfoNames(testCase.resultL.Objects))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  6. src/bufio/bufio_test.go

    	buf := make([]byte, 1)
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("1st nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != errFake {
    		t.Fatalf("1st Read = %v; want errFake", err)
    	}
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("2nd nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != nil {
    		t.Fatalf("3rd Read with buffer = %v; want nil", err)
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
  7. 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) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  8. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  9. 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  10. cmd/xl-storage_test.go

    		// we are attempting to read it.
    		{
    			volume: "exists",
    			path:   "as-directory",
    			err:    errFileNotFound,
    		},
    		// TestXLStorage case - 4.
    		{
    			volume: "exists",
    			path:   "as-file-parent/as-file",
    			err:    errFileNotFound,
    		},
    		// TestXLStorage case - 5.
    		// Validate the good condition file exists and we are able to read it.
    		{
    			volume: "exists",
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top