- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 587 for blocked (0.12 sec)
-
tensorflow/cc/training/queue_runner_test.cc
std::vector<Tensor> dq1; TF_EXPECT_OK(session->Run({}, {kDequeueOp1}, {}, &dq1)); EXPECT_EQ(*dq1[0].scalar<int>().data(), 10); // The expected behavior is the QueueRunner::Join() call is blocked until // Session::Close() is called. bool join_succeeded = false; Notification join_done; Env::Default()->SchedClosure( std::bind(&JoinThread, qr.get(), &join_succeeded, &join_done));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Sep 21 06:27:51 UTC 2019 - 14.7K bytes - Viewed (0) -
tests/integration/telemetry/policy/helper_test.go
if err := t.ConfigIstio().YAML(serviceNamespace.Name(), b).Apply(); err != nil { t.Fatalf("failed to apply gateway: %v. template: %v", err, b) } } // TODO support native environment for registry only/gateway. Blocked by #13177 because the listeners for native use static // routes and this test relies on the dynamic routes sent through pilot to allow external traffic.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 11.4K bytes - Viewed (0) -
src/internal/trace/order.go
pid := ProcID(ev.args[0]) // N.B. In practice Ps can't block while they're sweeping, so this can only // ever reference curCtx.P. However, be lenient about this like we are with // GCMarkAssistActive; there's no reason the runtime couldn't change to block // in the middle of a sweep. pState, ok := o.pStates[pid] if !ok {
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/context/x_test.go
} select { case x := <-c.Done(): t.Errorf("<-c.Done() == %v want nothing (it should block)", x) default: } } cancel() // Should propagate synchronously. for i, c := range contexts { select { case <-c.Done(): default: t.Errorf("<-c[%d].Done() blocked, but shouldn't have", i) } if e := c.Err(); e != Canceled {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
abstract <T> Facade<T> newFacade(); } static void awaitWaiting(Thread t) { while (true) { Thread.State state = t.getState(); switch (state) { case RUNNABLE: case BLOCKED: Thread.yield(); break; case WAITING: return; default: throw new AssertionError("unexpected state: " + state); } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 06 12:56:11 UTC 2023 - 13.6K bytes - Viewed (0) -
src/runtime/race/testdata/chan_test.go
// Test that sender synchronizes with receiver even if the sender was blocked. func TestNoRaceBlockedSendSync(t *testing.T) { c := make(chan *int, 1) c <- nil go func() { i := 42 c <- &i }() // Give the sender time to actually block. // This sleep is completely optional: race report must not be printed // regardless of whether the sender actually blocks or not. // It cannot lead to flakiness.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0) -
platforms/software/ivy/src/main/java/org/gradle/api/publish/ivy/internal/publication/DefaultIvyPublication.java
updateModuleDescriptorArtifact(); } // TODO: This method should be removed in favor of lazily adding artifacts to the publication state. // This is currently blocked by Signing eagerly realizing the publication artifacts. private void populateFromComponent() { if (populated) { return; } populated = true;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 22:25:49 UTC 2023 - 20.6K bytes - Viewed (0) -
src/internal/fuzz/worker.go
func (cr *contextReader) Read(b []byte) (int, error) { if ctxErr := cr.ctx.Err(); ctxErr != nil { return 0, ctxErr } done := make(chan struct{}) // This goroutine may stay blocked after Read returns because the underlying // read is blocked. var n int var err error go func() { n, err = cr.r.Read(b) close(done) }() select { case <-cr.ctx.Done(): return 0, cr.ctx.Err()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
// - have the threads use some specific immutable view of the build model state instead of requiring direct access to the build model. // - not have a thread blocked around task execution, so that other threads can use the build model. // - maybe split the states into one for the build model and one for the task graph. state.assertNotInState(State.Finished);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
src/runtime/proc.go
pp, _ = pidleget(0) } var locked bool if pp == nil { globrunqput(gp) // Below, we stoplockedm if gp is locked. globrunqput releases // ownership of gp, so we must check if gp is locked prior to // committing the release by unlocking sched.lock, otherwise we // could race with another M transitioning gp from unlocked to // locked. locked = gp.lockedm != 0 } else if sched.sysmonwait.Load() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)