- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 2,124 for func (0.12 sec)
-
cmd/local-locker_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsglocalLockMap(b *testing.B) { v := localLockMap{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsglocalLockMap(b *testing.B) { v := localLockMap{} bts := make([]byte, 0, v.Msgsize())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
args := f.Called(ctx, pod) return args.Error(0) } func (f *fakeServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ctx, pod) return args.Error(0) } func (f *fakeServer) Start(ctx context.Context) { } func (f *fakeServer) Stop() { } func (f *fakeServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/xl-storage-errors.go
"errors" "os" "runtime" "syscall" ) // No space left on device error func isSysErrNoSpace(err error) bool { return errors.Is(err, syscall.ENOSPC) } // Invalid argument, unsupported flags such as O_DIRECT func isSysErrInvalidArg(err error) bool { return errors.Is(err, syscall.EINVAL) } // Input/output error func isSysErrIO(err error) bool { return errors.Is(err, syscall.EIO) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:29 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} func (d *naughtyDisk) LastConn() time.Time { return d.disk.LastConn() } func (d *naughtyDisk) IsLocal() bool { 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() }
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/object-api-errors.go
func (e ObjectNameInvalid) Error() string { return "Object name invalid: " + e.Bucket + "/" + e.Object } // Error returns string an error formatted as the given text. func (e ObjectNameTooLong) Error() string { return "Object name too long: " + e.Bucket + "/" + e.Object } // Error returns string an error formatted as the given text. func (e ObjectNamePrefixAsSlash) Error() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
cmd/erasure-decode_test.go
} func BenchmarkErasureDecode_4_64KB(b *testing.B) { const size = 64 * 1024 b.Run(" 00|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 0, size, b) }) b.Run(" 00|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 1, size, b) }) b.Run(" X0|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 0, size, b) }) b.Run(" X0|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 1, size, b) })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 21.1K bytes - Viewed (1) -
cmd/namespace-lock.go
ctx context.Context cancel context.CancelFunc } // Context returns lock context func (l LockContext) Context() context.Context { return l.ctx } // Cancel function calls cancel() function func (l LockContext) Cancel() { if l.cancel != nil { l.cancel() } } // newNSLock - return a new name space lock map. func newNSLock(isDistErasure bool) *nsLockMap { nsMutex := nsLockMap{ isDistErasure: isDistErasure,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
internal/grid/connection.go
"github.com/tinylib/msgp/msgp" "github.com/zeebo/xxh3" ) func gridLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "grid", err, errKind...) } func gridLogIfNot(ctx context.Context, err error, ignored ...error) { logger.LogIfNot(ctx, "grid", err, ignored...) } func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
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/xl-storage-disk-id-check.go
func (p *xlStorageDiskIDCheck) IsLocal() bool { return p.storage.IsLocal() } func (p *xlStorageDiskIDCheck) Endpoint() Endpoint { return p.storage.Endpoint() } func (p *xlStorageDiskIDCheck) Hostname() string { return p.storage.Hostname() } func (p *xlStorageDiskIDCheck) Healing() *healingTracker { return p.storage.Healing() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/consolelogger.go
// for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node. func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error { // Enable console logging for remote client. if !sys.HasLogListeners() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0)