- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for ctb2 (0.26 sec)
-
cmd/shared-lock.go
// Send the lock context to anyone asking for it } } } } func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) { ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-ctx1.Done(): case <-ctx2.Done(): // The lock acquirer decides to cancel, exit this goroutine case <-ctx.Done(): } cancel() }()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
analysis/analysis-api/testData/components/compilerFacility/compilation/codeFragments/capturing/multipleFunctionContextReceivers.txt
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Mon Aug 14 15:22:43 UTC 2023 - 158 bytes - Viewed (0) -
analysis/analysis-api/testData/components/compilerFacility/compilation/codeFragments/capturing/secondClassContextReceiver.capturing.txt
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Mon Aug 14 15:22:43 UTC 2023 - 145 bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
pkg/kubelet/config/common_test.go
SecurityContext: securitycontext.ValidSecurityContextWithContainerDefaults(), VolumeMounts: []v1.VolumeMount{ { Name: "ctb-volume", MountPath: "/var/run/ctb-volume", }, }, }}, Volumes: []v1.Volume{ { Name: "ctb-volume", VolumeSource: v1.VolumeSource{ Projected: &v1.ProjectedVolumeSource{ Sources: []v1.VolumeProjection{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.7K bytes - Viewed (0) -
src/context/context_test.go
checkNoGoroutine() defer checkNoGoroutine() ctx1, cancel1 := WithCancel(Background()) defer cancel1() checkNoGoroutine() ctx2 := &myCtx{ctx1} ctx3, cancel3 := WithCancel(ctx2) defer cancel3() checkNoGoroutine() _, cancel3b := WithCancel(&myDoneCtx{ctx2}) defer cancel3b() checkCreatedGoroutine() // ctx1 is not providing Done, must not be used ctx4, cancel4 := WithTimeout(ctx3, veryLongDuration)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 19 19:13:01 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
annotations1 := audit.AuditEventFrom(ctx1).Annotations // guarantee different now times time.Sleep(time.Second) ctx2 := withAudit(context.Background()) _, _, _ = a.AuthenticateToken(ctx2, "token2") annotations2 := audit.AuditEventFrom(ctx2).Annotations if ok := len(annotations1) == 1 && len(annotations1["timestamp"]) > 0; !ok { t.Errorf("invalid annotations 1: %v", annotations1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0) -
src/net/pipe.go
// buffering. func Pipe() (Conn, Conn) { cb1 := make(chan []byte) cb2 := make(chan []byte) cn1 := make(chan int) cn2 := make(chan int) done1 := make(chan struct{}) done2 := make(chan struct{}) p1 := &pipe{ rdRx: cb1, rdTx: cn1, wrTx: cb2, wrRx: cn2, localDone: done1, remoteDone: done2, readDeadline: makePipeDeadline(),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
location: expectedIP + ":12345", }, { pod: api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo"}, Spec: api.PodSpec{ Containers: []api.Container{ {Name: "ctr1"}, {Name: "ctr2", Ports: []api.ContainerPort{{ContainerPort: 9376}}}, }, }, Status: api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}}, }, query: "foo", location: expectedIP + ":9376", }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
func (f *fakeKubeletVolumeHost) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { ctb, err := f.kubeClient.CertificatesV1alpha1().ClusterTrustBundles().Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return nil, fmt.Errorf("while getting ClusterTrustBundle %s: %w", name, err) } return []byte(ctb.Spec.TrustBundle), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0)