Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for enter_1 (0.13 sec)

  1. src/runtime/mgc.go

    	// termination complete.
    	n := work.cycles.Load()
    	gcWaitOnMark(n)
    
    	// We're now in sweep N or later. Trigger GC cycle N+1, which
    	// will first finish sweep N if necessary and then enter sweep
    	// termination N+1.
    	gcStart(gcTrigger{kind: gcTriggerCycle, n: n + 1})
    
    	// Wait for mark termination N+1 to complete.
    	gcWaitOnMark(n + 1)
    
    	// Finish sweep N+1 before returning. We do this both to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  2. src/runtime/mgcmark.go

    	if getg() == gp.m.g0 {
    		return
    	}
    	if mp := getg().m; mp.locks > 0 || mp.preemptoff != "" {
    		return
    	}
    
    	// This extremely verbose boolean indicates whether we've
    	// entered mark assist from the perspective of the tracer.
    	//
    	// In the tracer, this is just before we call gcAssistAlloc1
    	// *regardless* of whether tracing is enabled. This is because
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  3. src/internal/trace/order.go

    	}
    	if state.status != go122.GoRunning {
    		return curCtx, false, fmt.Errorf("%s event for goroutine that's not %s", go122.EventString(ev.typ), GoRunning)
    	}
    	// Goroutine entered a syscall. It's still running on this P and M.
    	state.status = go122.GoSyscall
    	pState, ok := o.pStates[curCtx.P]
    	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/net/http/client_test.go

    	// and thinks that the waitgroup inside httptest.Server is added to concurrently
    	// with us closing it. If we timed out immediately, we could close the testserver
    	// before we entered the handler. We're not timing out immediately and there's
    	// no way we would be done before we entered the handler, but the race detector
    	// doesn't know this, so synchronize explicitly.
    	defer func() { donec <- true }()
    
    	cst.c.Timeout = 5 * time.Millisecond
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:30:50 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/pv_controller.go

    	if err != nil {
    		logger.V(4).Info("Updating PersistentVolumeClaim status: cannot update internal cache", "PVC", klog.KObj(claim), "err", err)
    		return newClaim, err
    	}
    	logger.V(2).Info("Claim entered phase", "PVC", klog.KObj(claim), "phase", phase)
    	return newClaim, nil
    }
    
    // updateClaimStatusWithEvent saves new claim.Status to API server and emits
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // A corollary to all that is that we don't need to check isDone inside the loop because if we
        // get into the loop we know that we weren't done when we entered and therefore we aren't under
        // an obligation to execute 'immediately'.
        if (!isDone()) {
          Listener oldHead = listeners;
          if (oldHead != Listener.TOMBSTONE) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // A corollary to all that is that we don't need to check isDone inside the loop because if we
        // get into the loop we know that we weren't done when we entered and therefore we aren't under
        // an obligation to execute 'immediately'.
        if (!isDone()) {
          Listener oldHead = listeners;
          if (oldHead != Listener.TOMBSTONE) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  8. src/cmd/internal/obj/riscv/obj.go

    	wantNoneReg(ctxt, ins, "rs3", ins.rs3)
    }
    
    func validateRaw(ctxt *obj.Link, ins *instruction) {
    	// Treat the raw value specially as a 32-bit unsigned integer.
    	// Nobody wants to enter negative machine code.
    	if ins.imm < 0 || 1<<32 <= ins.imm {
    		ctxt.Diag("%v: immediate %d in raw position cannot be larger than 32 bits", ins.as, ins.imm)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 07 03:32:27 UTC 2024
    - 77K bytes
    - Viewed (0)
  9. testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h

        GTEST_CHECK_(has_owner_ && pthread_equal(owner_, pthread_self()))
            << "The current thread is not holding the mutex @" << this;
      }
    
      // A static mutex may be used before main() is entered.  It may even
      // be used before the dynamic initialization stage.  Therefore we
      // must be able to initialize a static mutex object at link time.
      // This means MutexBase has to be a POD and its member variables
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 67.2K bytes
    - Viewed (0)
  10. src/runtime/mprof.go

    	})
    	if labels != nil {
    		labels[0] = ourg.labels
    	}
    	ourg.goroutineProfiled.Store(goroutineProfileSatisfied)
    	goroutineProfile.offset.Store(1)
    
    	// Prepare for all other goroutines to enter the profile. Aside from ourg,
    	// every goroutine struct in the allgs list has its goroutineProfiled field
    	// cleared. Any goroutine created from this point on (while
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 53.3K bytes
    - Viewed (0)
Back to top