Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 587 for blocked (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top