- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Si (0.2 sec)
-
cmd/namespace-lock.go
for i, path := range li.paths { if !li.ns.lock(ctx, li.volume, path, lockSource, li.opsID, readLock, timeout.Timeout()) { timeout.LogFailure() for si, sint := range success { if sint == 1 { li.ns.unlock(li.volume, li.paths[si], readLock) } } if errors.Is(ctx.Err(), context.Canceled) { return LockContext{}, ctx.Err() } return LockContext{}, OperationTimedOut{} }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/rebalance-admin.go
err = meta.load(ctx, z.serverPools[0]) if err != nil { return r, err } // Compute disk usage percentage si := z.StorageInfo(ctx, true) diskStats := make([]struct { AvailableSpace uint64 TotalSpace uint64 }, len(z.serverPools)) for _, disk := range si.Disks { // Ignore invalid. if disk.PoolIndex < 0 || len(diskStats) <= disk.PoolIndex { // https://github.com/minio/minio/issues/16500
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
continue } stats, err := disk.StatInfoFile(ctx, volume, file, true) if err != nil { continue } for _, si := range stats { found++ var r io.ReadCloser if !si.Dir { r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size) if err != nil { continue } } else { r = io.NopCloser(bytes.NewBuffer([]byte{})) }
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) -
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) { if contextCanceled(ctx) { return DiskInfo{}, ctx.Err() } si := p.updateStorageMetrics(storageMetricDiskInfo) defer si(&err) if opts.NoOp { if opts.Metrics { info.Metrics = p.getMetrics() } info.Metrics.TotalWrites = p.totalWrites.Load()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 32.7K bytes - Viewed (0) -
cmd/veeam-sos-api.go
var buf []byte switch object { case systemXMLObject: si := systemInfo{ ProtocolVersion: `"1.0"`, ModelName: "\"MinIO " + ReleaseTag + "\"", } si.ProtocolCapabilities.CapacityInfo = true // Default recommended block size with MinIO si.SystemRecommendations.KBBlockSize = 4096 buf = encodeResponse(&si) case capacityXMLObject: objAPI := newObjectLayerFn()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
cmd/admin-handlers.go
} rawDataFn := func(r io.Reader, host, disk, filename string, si StatInfo) error { // Prefix host+disk filename = path.Join(host, disk, filename) if si.Dir { filename += "/" si.Size = 0 } if si.Mode == 0 { // Not, set it to default. si.Mode = 0o600 } if si.ModTime.IsZero() { // Set time to now. si.ModTime = time.Now() }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/global-heal.go
for _, disk := range healing { status.HealDisks = append(status.HealDisks, disk.Endpoint) } return status, true } si := o.LocalStorageInfo(ctx, true) indexed := make(map[string][]madmin.Disk) for _, disk := range si.Disks { setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex) indexed[setIdx] = append(indexed[setIdx], disk) } for id, disks := range indexed {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 09:22:13 GMT 2024 - 14.2K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
PoolStats: make([]*rebalanceStats, len(z.serverPools)), } // Fetch disk capacity and available space. si := z.StorageInfo(ctx, true) diskStats := make([]struct { AvailableSpace uint64 TotalSpace uint64 }, len(z.serverPools)) var totalCap, totalFree uint64 for _, disk := range si.Disks { // Ignore invalid. if disk.PoolIndex < 0 || len(diskStats) <= disk.PoolIndex {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.5K bytes - Viewed (0) -
cmd/utils.go
if xfix[i] != str[i] { xfix = xfix[:i] break } } } else { // suffix, iterate right to left for i := 0; i < maxl; i++ { xi := xfixl - i - 1 si := strl - i - 1 if xfix[xi] != str[si] { xfix = xfix[xi+1:] break } } } } return xfix } // Returns the mode in which MinIO is running func getMinioMode() string { switch {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 32K bytes - Viewed (0) -
cmd/peer-rest-server.go
signalString := vars.Get(peerRESTSignal) if signalString == "" { return np, grid.NewRemoteErrString("signal name is missing") } si, err := strconv.Atoi(signalString) if err != nil { return np, grid.NewRemoteErr(err) } signal := serviceSignal(si) switch signal { case serviceRestart, serviceStop: dryRun := vars.Get("dry-run") == "true" // This is only supported for `restart/stop`
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)