- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for sweeping (0.36 sec)
-
src/runtime/mgc.go
// we can go ahead and publish the heap profile. // // First, wait for sweeping to finish. (We know there are no // more spans on the sweep queue, but we may be concurrently // sweeping spans, so we have to wait.) for work.cycles.Load() == n+1 && !isSweepDone() { Gosched() } // Now we're really done with sweeping, so we can publish the // stable heap profile. Only do this if we haven't already hit
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/mheap.go
// constrained as follows: // // - A span may transition from free to in-use or manual during any GC // phase. // // - During sweeping (gcphase == _GCoff), a span may transition from // in-use to free (as a result of sweeping) or manual to free (as a // result of stacks being freed). // // - During GC (gcphase != _GCoff), a span *must not* transition from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
src/runtime/mprof.go
// is required to obtain a consistent picture of mallocs and frees // for some point in time. // The problem is that mallocs come in real time, while frees // come only after a GC during concurrent sweeping. So if we would // naively count them, we would get a skew toward mallocs. // // Hence, we delay information to get consistent snapshots as // of mark termination. Allocations count toward the next mark
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
src/runtime/malloc.go
// allocate a new group of pages (at least 1MB) from the // operating system. Allocating a large run of pages // amortizes the cost of talking to the operating system. // // Sweeping an mspan and freeing objects on it proceeds up a similar // hierarchy: // // 1. If the mspan is being swept in response to allocation, it // is returned to the mcache to satisfy the allocation. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 59.6K bytes - Viewed (0) -
src/internal/trace/order.go
} func (o *ordering) advanceGCSweepActive(ev *baseEvent, evt *evTable, m ThreadID, gen uint64, curCtx schedCtx) (schedCtx, bool, error) { 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.
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/runtime/mgcscavenge.go
printControllerReset bool // targetCPUFraction is the target CPU overhead for the scavenger. targetCPUFraction float64 // sleepRatio is the ratio of time spent doing scavenging work to // time spent sleeping. This is used to decide how long the scavenger // should sleep for in between batches of work. It is set by // critSleepController in order to maintain a CPU overhead of // targetCPUFraction. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
src/net/http/transport.go
// first and second stages to remedy the situation. // // This two-stage split is analogous to the use of two lists // in Okasaki's purely functional queue but without the // overhead of reversing the list when swapping stages. head []*wantConn headPos int tail []*wantConn } // len returns the number of items in the queue. func (q *wantConnQueue) len() int { return len(q.head) - q.headPos + len(q.tail)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
makeInstance(tcpStatic, "2.2.2.2", 444, tcpStatic.Spec.(*networking.ServiceEntry).Ports[0], nil, MTLS), }, "2.2.2.2") } // Keeping this test for legacy - but it never happens in real life. func TestServiceDiscoveryInstances(t *testing.T) { store, sd, _ := initServiceDiscovery(t) createConfigs([]*config.Config{httpDNS, tcpStatic}, store, t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go
"key1": "value", "key2": "value", }, }}, expectError{ applyPatchOperation{ "modifying one value in the object with maxProperties restriction, but keeping old fields", myCRDV1Beta1, myCRDInstanceName, map[string]interface{}{ "restricted": map[string]interface{}{ "key1": "hi", "key2": "theres", "key3": "buddy", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 59.5K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// check against, and the case where 'err != this known error' would be the 'this feature isn't supported' case, as is being // used here. For now, seeming as how nothing before ws2019 (1809) is listed as supported for k8s we can pretty much assume // any error here isn't because the query failed, it's just that dualstack simply isn't supported on the host. With all
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0)