- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 75 for stopCh (0.17 sec)
-
src/runtime/asm_amd64.s
// by the compiler. // Note that runtime.sehtramp can't be attached directly to asmcgocall // because its initial stack pointer can be outside the system stack bounds, // and Windows stops the stack unwinding without calling the exception handler // when it reaches that point. MOVQ BX, CX // CX = first argument in Win64 CALL AX // The exception handler is not called if the next instruction is part of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 60.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
assert.NoError(t, result.Error()) verifyContainerStatuses(t, fakeRuntime, expected, "init container still running; do nothing") // 3. should create all app containers because init container finished. // Stop init container instance 0. sandboxIDs, err := m.getSandboxIDByPodUID(ctx, pod.UID, nil) require.NoError(t, err) sandboxID := sandboxIDs[0] initID0, err := fakeRuntime.GetContainerID(sandboxID, initContainers[0].Name, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
src/cmd/internal/obj/arm/asm5.go
if p.From.Offset < 0 { o1 &^= (1 << 23) o1 |= uint32((-p.From.Offset) & 0xfff) } else { o1 |= uint32(p.From.Offset & 0xfff) } // This is supposed to be something that stops execution. // It's not supposed to be reached, ever, but if it is, we'd // like to be able to tell how we got there. Assemble as // 0xf7fabcfd which is guaranteed to raise undefined instruction // exception.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 20:51:01 UTC 2023 - 79.4K bytes - Viewed (0) -
src/cmd/go/internal/test/test.go
ctx, close, err = trace.Start(ctx, cfg.DebugTrace) if err != nil { base.Fatalf("failed to start trace: %v", err) } defer func() { if err := close(); err != nil { base.Fatalf("failed to stop trace: %v", err) } }() } ctx, span := trace.StartSpan(ctx, fmt.Sprint("Running ", cmd.Name(), " command")) defer span.Done() work.FindExecCmd() // initialize cached result
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
cmd/sts-handlers_test.go
c.Fatalf("normalize err: %v", err) } return normalizedDN } actualUserDN := mustNormalizeDN("uid=svc.algorithm,OU=swengg,DC=min,DC=io") // \uFE52 is the unicode dot SMALL FULL STOP used below: userDNWithUnicodeDot := "uid=svc﹒algorithm,OU=swengg,DC=min,DC=io" if err = s.adm.SetPolicy(ctx, policy, userDNWithUnicodeDot, false); err != nil { c.Fatalf("Unable to set policy: %v", err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 18:45:50 UTC 2024 - 90K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
} tc.informerFactory.Start(tc.ctx.Done()) t.Cleanup(func() { // Need to cancel before waiting for the shutdown. tCtx.Cancel("test is done") // Now we can wait for all goroutines to stop. tc.informerFactory.Shutdown() }) tc.informerFactory.WaitForCacheSync(tc.ctx.Done()) for _, node := range nodes { nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
ticker := time.NewTicker(10 * time.Millisecond) var attach *storage.VolumeAttachment var err error defer ticker.Stop() // wait for attachment to be saved for i := 0; i < 100; i++ { attach, err = client.StorageV1().VolumeAttachments().Get(context.TODO(), attachID, metav1.GetOptions{}) if err != nil { attach = nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
ws := new(restful.WebService) ws.Path(a.prefix) // a.prefix contains "prefix/group/version" ws.Doc("API at " + a.prefix) // Backwards compatibility, we accepted objects with empty content-type at V1. // If we stop using go-restful, we can default empty content-type to application/json on an // endpoint by endpoint basis ws.Consumes("*/*") mediaTypes, streamMediaTypes := negotiation.MediaTypesForSerializer(a.group.Serializer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
src/internal/trace/order.go
} func (o *ordering) advanceProcStop(ev *baseEvent, evt *evTable, m ThreadID, gen uint64, curCtx schedCtx) (schedCtx, bool, error) { // We must be able to advance this P. // // There are 2 ways a P can stop: ProcStop and ProcSteal. ProcStop is used when the P // is stopped by the same M that started it, while ProcSteal is used when another M // steals the P by stopping it from a distance. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/time/time_test.go
go func(i int) { defer wg.Done() for j := 0; j < tries; j++ { timer.Reset(Hour + Duration(i*j)) } }(i) go func(i int) { defer wg.Done() timer.Stop() }(i) } wg.Wait() } func TestTimeIsDST(t *testing.T) { undo := DisablePlatformSources() defer undo() tzWithDST, err := LoadLocation("Australia/Sydney") if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0)