- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 64 for gotSock (0.33 sec)
-
pkg/kubelet/container/testing/mock_runtime_cache.go
// // Package testing is a generated GoMock package. package testing import ( context "context" reflect "reflect" time "time" gomock "go.uber.org/mock/gomock" container "k8s.io/kubernetes/pkg/kubelet/container" ) // MockRuntimeCache is a mock of RuntimeCache interface. type MockRuntimeCache struct { ctrl *gomock.Controller recorder *MockRuntimeCacheMockRecorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4K bytes - Viewed (0) -
cmd/namespace-lock.go
opsID string } // Lock - block until write lock is taken or timeout has occurred. func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) { lockSource := getSource(2) start := UTCNow() newCtx, cancel := context.WithCancel(ctx) if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{ Timeout: timeout.Timeout(), RetryInterval: timeout.RetryInterval(),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 05 23:56:35 UTC 2023 - 9.2K bytes - Viewed (0) -
pkg/kubelet/container/testing/mockdirentry.go
*/ // Code generated by MockGen. // Source: os (interfaces: DirEntry) package testing import ( fs "io/fs" reflect "reflect" gomock "go.uber.org/mock/gomock" ) // MockDirEntry is a mock of DirEntry interface. type MockDirEntry struct { ctrl *gomock.Controller recorder *MockDirEntryMockRecorder } // MockDirEntryMockRecorder is the mock recorder for MockDirEntry.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/server/stats/testing/mock_summary_provider.go
// // Package testing is a generated GoMock package. package testing import ( context "context" reflect "reflect" gomock "go.uber.org/mock/gomock" v1alpha1 "k8s.io/kubelet/pkg/apis/stats/v1alpha1" ) // MockSummaryProvider is a mock of SummaryProvider interface. type MockSummaryProvider struct { ctrl *gomock.Controller recorder *MockSummaryProviderMockRecorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
// fmt.Println("Getting initial write lock") if !lrwm.GetLock(ctx, "", "", time.Second) { panic("Failed to acquire initial write lock") } go func() { time.Sleep(2 * time.Second) lrwm.Unlock() // fmt.Println("Initial write lock released, waiting...") }() // fmt.Println("Trying to acquire 2nd write lock, waiting...") locked = lrwm.GetLock(ctx, "", "", duration) if locked {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-annotations-stress.test
EventBatch gen=1 m=1986496 time=2753925246280 size=267 ProcStart dt=549 p=0 p_seq=1 GoStart dt=211 g=18 g_seq=1 GoBlock dt=3533 reason_string=12 stack=21 GoStart dt=41 g=21 g_seq=1 GoBlock dt=150 reason_string=10 stack=22 GoStart dt=93 g=20 g_seq=1 GoSyscallBegin dt=51 p_seq=2 stack=23 GoSyscallEnd dt=400 GoBlock dt=582 reason_string=15 stack=25 GoStart dt=26 g=23 g_seq=1 HeapAlloc dt=50 heapalloc_value=1646592
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 38.3K bytes - Viewed (0) -
test/ken/chan.go
if v%100 == 75 { return end } return v + 1 } print("got ", v, " expected ", v0+1, "\n") panic("fail") } func (c *Chan) send() bool { // print("send ", c.sv, "\n"); totLock.Lock() tots++ totLock.Unlock() c.sv = expect(c.sv, c.sv) if c.sv == end { c.sc = nil return true } return false } func send(c *Chan) { for { for r := nrand(10); r >= 0; r-- {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 05:24:24 UTC 2012 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/version/helpers_test.go
} if gotMinorVersion != tt.wantMinorVersion { t.Errorf("parseKubeVersion() gotMinorVersion = %v, want %v", gotMinorVersion, tt.wantMinorVersion) } if gotOk != tt.wantOk { t.Errorf("parseKubeVersion() gotOk = %v, want %v", gotOk, tt.wantOk) } }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 19 02:46:55 UTC 2022 - 3.3K bytes - Viewed (0) -
internal/dsync/dsync_test.go
} dm := NewDRWMutex(ds, "aap") dm.refreshInterval = testDrwMutexRefreshInterval ctx, cancel := context.WithCancel(context.Background()) if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Make it run twice. timer := time.NewTimer(testDrwMutexRefreshInterval * 2) select { case <-ctx.Done():
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 11K bytes - Viewed (0) -
cmd/shared-lock.go
lockContext chan LockContext } func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) { for { locker := objAPI.NewNSLock(minioMetaBucket, lockName) lkctx, err := locker.GetLock(ctx, sharedLockTimeout) if err != nil { continue } keepLock: for { select { case <-ctx.Done(): return case <-lkctx.Context().Done():
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0)