Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Breiding (0.23 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 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    	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()`.
    	lock() *iamCache
    	unlock()
    	rlock() *iamCache
    	runlock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 74.4K bytes
    - Viewed (2)
  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 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  4. cmd/erasure-server-pool.go

    			return &GetObjectReader{
    				ObjInfo: objInfo,
    			}, toObjectErr(errMethodNotAllowed, bucket, object)
    		}
    		return nil, err
    	}
    
    	// check preconditions before reading the stream.
    	if checkPrecondFn != nil && checkPrecondFn(objInfo) {
    		return nil, PreConditionFailed{}
    	}
    
    	opts.NoLock = true
    	gr, err = z.serverPools[zIdx].GetObjectNInfo(ctx, bucket, object, rs, h, opts)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K bytes
    - Viewed (0)
  5. cmd/iam.go

    	}
    
    	select {
    	case <-sys.configLoaded:
    	default:
    		xioutil.SafeClose(sys.configLoaded)
    	}
    	return nil
    }
    
    // Init - initializes config system by reading entries from config/iam
    func (sys *IAMSys) Init(ctx context.Context, objAPI ObjectLayer, etcdClient *etcd.Client, iamRefreshInterval time.Duration) {
    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 18 19:09:19 GMT 2024
    - 69.9K bytes
    - Viewed (1)
  6. cmd/test-utils_test.go

    	}
    
    	// httptest Recorder to capture all the response by the http handler.
    	rec := httptest.NewRecorder()
    	// reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request.
    	// If the body is read in the handler the same request cannot be made use of.
    	buf, err := io.ReadAll(anonReq.Body)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  7. src/bytes/bytes_test.go

    		}
    	}
    	return true
    }
    
    func sliceOfString(s [][]byte) []string {
    	result := make([]string, len(s))
    	for i, v := range s {
    		result[i] = string(v)
    	}
    	return result
    }
    
    // For ease of reading, the test cases use strings that are converted to byte
    // slices before invoking the functions.
    
    var abcd = "abcd"
    var faces = "☺☻☹"
    var commas = "1,2,3,4"
    var dots = "1....2....3....4"
    
    type BinOpTest struct {
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Wed Jan 24 16:07:25 GMT 2024
    - 56.2K bytes
    - Viewed (0)
  8. src/archive/zip/reader_test.go

    	}
    	r, err := NewReader(bytes.NewReader(data), int64(len(data)))
    	if err != ErrInsecurePath {
    		t.Fatalf("Error reading the archive: %v", err)
    	}
    	_, err = r.Open("test.txt")
    	if err != nil {
    		t.Errorf("Error reading file: %v", err)
    	}
    	if len(r.File) != 1 {
    		t.Fatalf("No entries in the file list")
    	}
    	if r.File[0].Name != "../test.txt" {
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Wed Mar 27 18:23:49 GMT 2024
    - 55.3K bytes
    - Viewed (0)
  9. src/cmd/cgo/gcc.go

    	// Scan DWARF info for top-level TagVariable entries with AttrName __cgo__i.
    	types := make([]dwarf.Type, len(names))
    	r := d.Reader()
    	for {
    		e, err := r.Next()
    		if err != nil {
    			fatalf("reading DWARF entry: %s", err)
    		}
    		if e == nil {
    			break
    		}
    		switch e.Tag {
    		case dwarf.TagVariable:
    			name, _ := e.Val(dwarf.AttrName).(string)
    			// As of https://reviews.llvm.org/D123534, clang
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Thu Nov 02 16:43:23 GMT 2023
    - 97K bytes
    - Viewed (0)
  10. src/bufio/bufio_test.go

    		// Put it back and read it again.
    		if err = r.UnreadRune(); err != nil {
    			t.Fatal("unexpected error on UnreadRune:", err)
    		}
    		r2, _, err := r.ReadRune()
    		if err != nil {
    			t.Fatal("unexpected error reading after unreading:", err)
    		}
    		if r1 != r2 {
    			t.Fatalf("incorrect rune after unread: got %c, want %c", r1, r2)
    		}
    	}
    	if got != want {
    		t.Errorf("got %q, want %q", got, want)
    	}
    }
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
Back to top