- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 118 for v_size (0.18 sec)
-
cmd/batch-rotate.go
if err != nil { return err } wk, err := workers.New(workerSize) if err != nil { // invalid worker size. return err } retryAttempts := ri.RetryAttempts ctx, cancel := context.WithCancel(ctx) results := make(chan ObjectInfo, 100) if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/connection.go
} // Stats returns the current connection stats. func (c *Connection) Stats() ConnectionStats { return ConnectionStats{ IncomingStreams: c.inStream.Size(), OutgoingStreams: c.outgoing.Size(), } } func (c *Connection) debugMsg(d debugMsg, args ...any) { if debugPrint { fmt.Println("debug: sending message", d, args) } switch d {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// task queue is full, no more workers, we shall move on and heal later. return nil } // Don't wait for result return nil } // respCh must be set to wait for result. // We make it size 1, so a result can always be written // even if we aren't listening. task.respCh = make(chan healResult, 1) select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/s3select/csv/reader_contrib_test.go
}, } for i, c := range cases { t.Run(c.file, func(t *testing.T) { var err error var record sql.Record var result bytes.Buffer input := openTestFile(t, c.file) // Get above block size. input = append(input, input...) args := ReaderArgs{ FileHeaderInfo: use, RecordDelimiter: c.recordDelimiter, FieldDelimiter: c.fieldDelimiter,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 38.5K bytes - Viewed (0) -
cmd/site-replication.go
if svcErr != nil { return info, errSRBackendIssue(svcErr) } } info.UserPolicies = make(map[string]madmin.SRPolicyMapping, userPolicyMap.Size()) addPolicy := func(t IAMUserType, mp *xsync.MapOf[string, MappedPolicy]) { mp.Range(func(k string, mp MappedPolicy) bool { info.UserPolicies[k] = madmin.SRPolicyMapping{ IsGroup: false,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
internal/disk/stat_solaris.go
s := unix.Statvfs_t{} if err = unix.Statvfs(path, &s); err != nil { return Info{}, err } reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail) info = Info{ Total: uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks), Free: uint64(s.Frsize) * uint64(s.Bavail), Files: uint64(s.Files), Ffree: uint64(s.Ffree), FSType: getFSType(s.Fstr[:]), } if info.Free > info.Total {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.8K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
// Payload size can give an indication of expected payload size. // If plSize is <= 0 it will be calculated. func (x *xlMetaInlineData) serialize(plSize int, keys [][]byte, vals [][]byte) { if len(keys) != len(vals) { panic(fmt.Errorf("xlMetaInlineData.serialize: keys/value number mismatch")) } if len(keys) == 0 { *x = nil return } if plSize <= 0 { plSize = 1 + msgp.MapHeaderSize
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/disk/stat_netbsd.go
s := unix.Statvfs_t{} if err = unix.Statvfs(path, &s); err != nil { return Info{}, err } reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail) info = Info{ Total: uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks), Free: uint64(s.Frsize) * uint64(s.Bavail), Files: uint64(s.Files), Ffree: uint64(s.Ffree), FSType: string(s.Fstypename[:]), } if info.Free > info.Total {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/disk/stat_linux.go
s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - s.Bavail info = Info{ Total: uint64(s.Frsize) * (s.Blocks - reservedBlocks), Free: uint64(s.Frsize) * s.Bavail, Files: s.Files, Ffree: s.Ffree, //nolint:unconvert FSType: getFSType(int64(s.Type)), } st := syscall.Stat_t{} err = syscall.Stat(path, &st)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/disk/stat_openbsd.go
err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := uint64(s.F_bfree) - uint64(s.F_bavail) info = Info{ Total: uint64(s.F_bsize) * (uint64(s.F_blocks) - reservedBlocks), Free: uint64(s.F_bsize) * uint64(s.F_bavail), Files: uint64(s.F_files), Ffree: uint64(s.F_ffree), FSType: getFSType(s.F_fstypename[:]), } if info.Free > info.Total {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.8K bytes - Viewed (0)