- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 74 for inline (0.14 sec)
-
cmd/storage-interface.go
// Storage operations. // Returns true if disk is online and its valid i.e valid format.json. // This has nothing to do with if the drive is hung or not responding. // For that individual storage API calls will fail properly. The purpose // of this function is to know if the "drive" has "format.json" or not // if it has a "format.json" then is it correct "format.json" or not. IsOnline() bool // Returns the last time this disk (re)-connected
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/notification.go
} idx := xxhash.Sum64String(s) % uint64(len(peerClients)) return peerClients[idx] } // GetPeerOnlineCount gets the count of online and offline nodes. func (sys *NotificationSys) GetPeerOnlineCount() (nodesOnline, nodesOffline int) { nodesOnline = 1 // Self is always online. nodesOffline = 0 nodesOnlineIndex := make([]bool, len(sys.peerClients)) var wg sync.WaitGroup for idx, client := range sys.peerClients {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
for _, disk := range onlineDisks { if disk != nil && disk.IsOnline() { continue } er.addPartial(bucket, object, fi.VersionID) break } } for i := 0; i < len(onlineDisks); i++ { if onlineDisks[i] != nil && onlineDisks[i].IsOnline() { // Object info is the same in all disks, so we can pick // the first meta from online disk fi = partsMetadata[i] break } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
z.Checksum, bts, err = msgp.ReadBytesBytes(bts, z.Checksum) if err != nil { err = msgp.WrapError(err, "Checksum") return } case "Inlined": z.Inlined, bts, err = msgp.ReadBoolBytes(bts) if err != nil { err = msgp.WrapError(err, "Inlined") return } case "DataBlocks": z.DataBlocks, bts, err = msgp.ReadIntBytes(bts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
clusterDriveMetrics: newClusterStorageInfoCache(), nodesUpDown: newNodesUpDownCache(), } } type nodesOnline struct { Online, Offline int } func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] { loadNodesUpDown := func() (v nodesOnline, err error) { v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount() return } return cachevalue.NewFromFunc(1*time.Minute,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/erasure.go
localEndpoints = append(localEndpoints, endpoint) } } return getStorageInfo(localDisks, localEndpoints, metrics) } // getOnlineDisksWithHealingAndInfo - returns online disks and overall healing status. // Disks are ordered in the following groups: // - Non-scanning disks // - Non-healing disks // - Healing disks (if inclHealing is true)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
internal/kms/kes.go
kmsCtx, err := kmsContext.MarshalText() if err != nil { results = append(results, VerifyResult{Status: "offline", Endpoint: endpoint}) continue } result := VerifyResult{Status: "online", Endpoint: endpoint, Version: state.Version} key, err := client.GenerateKey(ctx, env.Get(EnvKESKeyName, ""), kmsCtx) if err != nil { result.Encrypt = fmt.Sprintf("Encryption failed: %v", err) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
restoreObjStatus string expireRestored bool expectedDataDir string }{ { // object versions with inlined data don't count towards shared data directory versionID: mustGetUUID(), dataDir: d0, data: data, shares: 0, }, { // object versions with inlined data don't count towards shared data directory versionID: mustGetUUID(), dataDir: d1, data: data2,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/sftp-server-driver.go
case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() } for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err } type writerAt struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/metacache-walk.go
) //go:generate msgp -file $GOFILE // WalkDirOptions provides options for WalkDir operations. type WalkDirOptions struct { // Bucket to scanner Bucket string // Directory inside the bucket. BaseDir string // Do a full recursive scan. Recursive bool // ReportNotFound will return errFileNotFound if all disks reports the BaseDir cannot be found. ReportNotFound bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0)