- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 115 for chain (0.04 sec)
-
src/cmd/internal/testdir/testdir_test.go
cgoEnabled bool goExperiment string goDebug string // dirs are the directories to look for *.go files in. // TODO(bradfitz): just use all directories? dirs = []string{".", "ken", "chan", "interface", "syntax", "dwarf", "fixedbugs", "codegen", "runtime", "abi", "typeparam", "typeparam/mdempsky", "arenas"} ) // Test is the main entrypoint that runs tests in the GOROOT/test directory. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:08:06 UTC 2024 - 57.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
}, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { ns := metav1.NamespaceDefault client, esController := newController(t, []string{"node-1"}, tc.batchPeriod) stopCh := make(chan struct{}) defer close(stopCh) _, ctx := ktesting.NewTestContext(t) go esController.Run(ctx, 1) esController.serviceStore.Add(&v1.Service{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
src/cmd/go/internal/test/test.go
runs = append(runs, runTest) prints = append(prints, printTest) } // Order runs for coordinating start JSON prints. ch := make(chan struct{}) close(ch) for _, a := range runs { if r, ok := a.Actor.(*runTestActor); ok { r.prev = ch ch = make(chan struct{}) r.next = ch } } // Ultimately the goal is to print the output.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
src/cmd/compile/internal/types2/expr.go
case *Signature: return "func" case *Interface: if isTypeParam(typ) { return check.sprintf("type parameter %s", typ) } return "interface" case *Map: return "map" case *Chan: return "chan" default: return check.sprintf("%s", typ) // catch-all } } // If e != nil, it must be the shift expression; it may be nil for non-constant shifts.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 02:09:54 UTC 2024 - 51.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
if svc != nil { t.Fatalf("expected nil, got %v", svc) } } func BenchmarkServiceEntryHandler(b *testing.B) { _, sd := initServiceDiscoveryWithoutEvents(b) stopCh := make(chan struct{}) go sd.Run(stopCh) defer close(stopCh) for i := 0; i < b.N; i++ { sd.serviceEntryHandler(config.Config{}, *httpDNS, model.EventAdd) sd.serviceEntryHandler(config.Config{}, *httpDNSRR, model.EventAdd)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
klog.V(3).InfoS("Running preStop hook", "pod", klog.KObj(pod), "podUID", pod.UID, "containerName", containerSpec.Name, "containerID", containerID.String()) start := metav1.Now() done := make(chan struct{}) go func() { defer close(done) defer utilruntime.HandleCrash() if _, err := m.runner.Run(ctx, containerID, pod, containerSpec, containerSpec.Lifecycle.PreStop); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
src/net/http/fs_test.go
open func(name string) (File, error) } func (fs *testFileSystem) Open(name string) (File, error) { return fs.open(name) } func TestFileServerCleans(t *testing.T) { defer afterTest(t) ch := make(chan string, 1) fs := FileServer(&testFileSystem{func(name string) (File, error) { ch <- name return nil, errors.New("file does not exist") }}) tests := []struct { reqPath, openArg string }{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 60.2K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// - unschedulablePods holds pods that were already attempted for scheduling and // are currently determined to be unschedulable. type PriorityQueue struct { *nominator stop chan struct{} clock clock.Clock // pod initial backoff duration. podInitialBackoffDuration time.Duration // pod maximum backoff duration. podMaxBackoffDuration time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)