- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 972 for erre (0.13 sec)
-
cmd/erasure-decode.go
var err error bufs, err = reader.Read(bufs) if len(bufs) > 0 { if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) { if derr == nil { derr = err } } } else if err != nil { return err } if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil { return err } w := parallelWriter{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/erasure-object_test.go
_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(bigData), int64(len(bigData)), "", ""), ObjectOptions{}) if err != nil { t.Fatal(err) } gr, err = obj.GetObjectNInfo(ctx, bucket, object, nil, nil, ObjectOptions{}) if err != nil { t.Fatalf("Expected GetObject to succeed, but failed with %v", err) } _, err = io.Copy(output, gr) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-healing-common.go
modTimes[i] = timeSentinel } return modTimes } func listObjectETags(partsMetadata []FileInfo, errs []error, quorum int) (etags []string) { etags = make([]string, len(partsMetadata)) vidMap := map[string]int{} for index, metadata := range partsMetadata { if errs[index] != nil { continue } vid := metadata.VersionID if metadata.VersionID == "" { vid = nullVersionID }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.8K bytes - Viewed (0) -
cmd/data-scanner.go
} // Get last healing information buf, err := readConfig(ctx, objAPI, backgroundHealInfoPath) if err != nil { if !errors.Is(err, errConfigNotFound) { internalLogOnceIf(ctx, err, backgroundHealInfoPath) } return backgroundHealInfo{} } var info backgroundHealInfo if err = json.Unmarshal(buf, &info); err != nil { bugLogIf(ctx, err, backgroundHealInfoPath) } return info }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
src/archive/zip/reader_test.go
// log.Fatal(err) // } // } // // func makeZip(name string, r io.Reader) []byte { // var buf bytes.Buffer // w := zip.NewWriter(&buf) // wf, err := w.Create(name) // if err != nil { // log.Fatal(err) // } // if _, err = io.Copy(wf, r); err != nil { // log.Fatal(err) // } // if err := w.Close(); err != nil { // log.Fatal(err) // } // return buf.Bytes() // } //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 55.3K bytes - Viewed (0) -
src/bufio/bufio.go
func (b *Writer) ReadFrom(r io.Reader) (n int64, err error) { if b.err != nil { return 0, b.err } readerFrom, readerFromOK := b.wr.(io.ReaderFrom) var m int for { if b.Available() == 0 { if err1 := b.Flush(); err1 != nil { return n, err1 } } if readerFromOK && b.Buffered() == 0 { nn, err := readerFrom.ReadFrom(r) b.err = err n += nn return n, err }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
cmd/utils.go
dirPath, err := os.MkdirTemp("", "profile") if err != nil { return nil, err } fn := filepath.Join(dirPath, "trace.out") f, err := Create(fn) if err != nil { return nil, err } err = trace.Start(f) if err != nil { return nil, err } prof.ext = "trace" prof.stopFn = func() ([]byte, error) { trace.Stop() err := f.Close() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/object-api-utils_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 23.4K bytes - Viewed (0) -
cmd/iam-store.go
return err } bootstrapTraceMsg("loading group policy mapping") // load policies mapped to groups if err := store.loadMappedPolicies(ctx, regUser, true, newCache.iamGroupPolicyMap); err != nil { return err } bootstrapTraceMsg("loading service accounts") // load service accounts if err := store.loadUsers(ctx, svcUser, newCache.iamUsersMap); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/erasure-sets.go
func connectEndpoint(endpoint Endpoint) (StorageAPI, *formatErasureV3, error) { disk, err := newStorageAPI(endpoint, storageOpts{ cleanUp: false, healthCheck: false, }) if err != nil { return nil, nil, err } format, err := loadFormatErasure(disk, false) if err != nil { if errors.Is(err, errUnformattedDisk) { info, derr := disk.DiskInfo(context.TODO(), DiskInfoOptions{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5)