- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,105 for errC (0.04 sec)
-
cmd/notification.go
g.workers.Take() go func() { defer g.workers.Give() g.errs[index] = NotificationPeerErr{ Host: addr, } retryCount := g.retryCount for i := 0; i < retryCount; i++ { g.errs[index].Err = nil if err := f(); err != nil { g.errs[index].Err = err if contextCanceled(ctx) { // context already canceled no retries. retryCount = 0 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 disks, err := getRandomDisks(nDisks) if err != nil { t.Fatal(err) } objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...)) if err != nil { removeRoots(disks) t.Fatal(err) } defer removeRoots(disks) z := objLayer.(*erasureServerPools) testShuffleDisks(t, z) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
wg.Wait() // we should return 'errs' from per disk if isAllNotFound(errs) { if isAllVolumeNotFound(errs) { return errVolumeNotFound } return nil } if err != nil { return err } if contextCanceled(ctx) { return ctx.Err() } for _, err := range errs { if errors.Is(err, io.EOF) { continue }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/format-erasure_test.go
b, err := json.Marshal(m) if err != nil { t.Fatal(err) } if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil { t.Fatal(err) } if err = os.WriteFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile), b, os.FileMode(0o644)); err != nil { t.Fatal(err) } formatData, _, err := formatErasureMigrate(rootPath)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Apr 15 08:25:46 UTC 2024 - 12.9K bytes - Viewed (0) -
internal/rest/rpc-stats.go
"net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 tcpTimeForFirstByteTotalDur uint64 }{} // RPCStats holds information about the DHCP/TCP metrics and errors type RPCStats struct { Errs uint64 DialAvgDuration uint64 TTFBAvgDuration uint64 DialErrs uint64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 18:21:34 UTC 2024 - 2.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
gorm.go
return nil, applyErr } defer func(opt Option) { if errr := opt.AfterInitialize(db); errr != nil { err = errr } }(opt) } } if d, ok := dialector.(interface{ Apply(*Config) error }); ok { if err = d.Apply(config); err != nil { return } } if config.NamingStrategy == nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Oct 09 11:29:48 UTC 2024 - 12.1K bytes - Viewed (0) -
cmd/prepare-storage.go
// Attempt to load all `format.json` from all disks. formatConfigs, sErrs := loadFormatErasureAll(storageDisks, false) if err := checkDiskFatalErrs(sErrs); err != nil { return nil, err } for i, err := range sErrs { if err != nil && !errors.Is(err, errXLBackend) && !errors.Is(err, errUnformattedDisk) { if errors.Is(err, errDiskNotFound) && verboseLogging {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
cmd/erasure-metadata_test.go
} // Test them. for _, testCase := range testCases { index, offset, err := fi.ObjectToPartOffset(context.Background(), testCase.offset) if err != testCase.expectedErr { t.Fatalf("%+v: expected = %s, got: %s", testCase, testCase.expectedErr, err) } if index != testCase.expectedIndex { t.Fatalf("%+v: index: expected = %d, got: %d", testCase, testCase.expectedIndex, index)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:02:50 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/bucket-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if checksum != nil && checksum.Valid() { if err = hashReader.AddChecksumNoTrailer(formValues, true); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 63.4K bytes - Viewed (0)