- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for enter_1 (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 (1) -
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) -
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
object : AsyncTimeout() { override fun timedOut() { latch.countDown() } } watchdogJob.deadlineNanoTime(System.nanoTime()) // Due immediately! watchdogJob.enter() latch.await() } private fun connectWithSettings( client: Boolean, settings: Settings?, ): Http2Connection { peer.setClient(client)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)