- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for dist (0.35 sec)
-
internal/disk/disk_windows.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 951 bytes - Viewed (0) -
internal/disk/disk_unix.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package disk import ( "syscall" ) // SameDisk reports whether di1 and di2 describe the same disk. func SameDisk(disk1, disk2 string) (bool, error) { st1 := syscall.Stat_t{} st2 := syscall.Stat_t{} if err := syscall.Stat(disk1, &st1); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 1.2K bytes - Viewed (0) -
cmd/naughty-disk_test.go
return d.disk.IsLocal() } func (d *naughtyDisk) Endpoint() Endpoint { return d.disk.Endpoint() } func (d *naughtyDisk) Hostname() string { return d.disk.Hostname() } func (d *naughtyDisk) Healing() *healingTracker { return d.disk.Healing() } func (d *naughtyDisk) Close() (err error) { if err = d.calcError(); err != nil { return err } return d.disk.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
lastSuccess int64 // atomic time of last time a token was grabbed. lastStarted int64 // Atomic status of disk. status atomic.Int32 // Atomic number indicates if a disk is hung waiting atomic.Int32 } // newDiskHealthTracker creates a new disk health tracker. func newDiskHealthTracker() *diskHealthTracker { d := diskHealthTracker{ lastSuccess: time.Now().UnixNano(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
actualDisksName := make(map[string]string) // Calculate the set/disk index for _, disk := range localDisks { expectedDisksName[fmt.Sprintf("%d-%d", disk.index/setSize, disk.index%setSize)] = disk.path format, err := getFormatJSON(disk.path) if err != nil { log.Printf("Unable to read format.json from `%s`, error: %v\n", disk.path, err) continue } foundDiskLoc, err := getDiskLocation(format)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/bitrot-whole.go
return nil } // Returns whole-file bitrot writer. func newWholeBitrotWriter(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, shardSize int64) io.WriteCloser { return &wholeBitrotWriter{disk, volume, filePath, shardSize, algo.New()} } // Implementation to verify bitrot for the whole file. type wholeBitrotReader struct { disk StorageAPI volume string filePath string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 2.7K bytes - Viewed (0) -
cmd/storage-errors.go
var errDiskFull = StorageErr("drive path full") // errDiskNotDir - cannot use storage disk if its not a directory var errDiskNotDir = StorageErr("drive is not directory or mountpoint") // errDiskNotFound - cannot find the underlying configured disk anymore. var errDiskNotFound = StorageErr("drive not found") // errDiskOngoingReq - indicates if the disk has an on-going request in progress.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/erasure-heal_test.go
case *streamingBitrotReader: r.disk = badDisk{nil} case *wholeBitrotReader: r.disk = badDisk{nil} } } for j := 0; j < test.badStaleDisks; j++ { staleDisks[j] = badDisk{nil} } staleWriters := make([]io.Writer, len(staleDisks)) for i, disk := range staleDisks { if disk == nil { continue } os.Remove(pathJoin(disk.String(), "testbucket", "testobject"))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/metrics.go
float64(totalDisks.Sum()), ) for _, disk := range server.Disks { // Total disk usage by the disk ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(diskNamespace, "storage", "used"), "Total disk storage used on the drive", []string{"disk"}, nil), prometheus.GaugeValue, float64(disk.UsedSpace), disk.DrivePath, )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/bucket/replication/destination.go
// Make subtype to avoid recursive UnmarshalXML(). type destination Destination dest := destination{} if err := dec.DecodeElement(&dest, &start); err != nil { return err } parsedDest, err := parseDestination(dest.Bucket) if err != nil { return err } if dest.StorageClass != "" { switch dest.StorageClass { case "STANDARD", "REDUCED_REDUNDANCY": default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4K bytes - Viewed (2)