- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for flushed (0.12 sec)
-
src/runtime/mgc.go
trace.GCStart() traceRelease(trace) } // Check that all Ps have finished deferred mcache flushes. for _, p := range allp { if fg := p.mcache.flushGen.Load(); fg != mheap_.sweepgen { println("runtime: p", p.id, "flushGen", fg, "!= sweepgen", mheap_.sweepgen) throw("p mcache not flushed") } } gcBgMarkStartWorkers() systemstack(gcResetMarkState)
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
scanobject(b, gcw) // Flush background scan work credit. if gcw.heapScanWork >= gcCreditSlack { gcController.heapScanWork.Add(gcw.heapScanWork) workFlushed += gcw.heapScanWork gcw.heapScanWork = 0 } } // Unlike gcDrain, there's no need to flush remaining work // here because this never flushes to bgScanCredit and // gcw.dispose will flush any remaining work to scanWork.
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/net/http/httputil/reverseproxy_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/runtime/mprof.go
// indicate whether future[cycle] in all buckets has been queued to flush into // the active profile. type mProfCycleHolder struct { value atomic.Uint32 } // read returns the current cycle count. func (c *mProfCycleHolder) read() (cycle uint32) { v := c.value.Load() cycle = v >> 1 return cycle } // setFlushed sets the flushed flag. It returns the current cycle count and the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
tx.Flush(&knftables.Set{ Name: clusterIPsSet, }) tx.Flush(&knftables.Map{ Name: firewallIPsMap, }) tx.Flush(&knftables.Map{ Name: noEndpointServicesMap, }) tx.Flush(&knftables.Map{ Name: noEndpointNodePortsMap, }) tx.Flush(&knftables.Map{ Name: serviceIPsMap, }) tx.Flush(&knftables.Map{ Name: serviceNodePortsMap,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0) -
src/bufio/bufio_test.go
w.Reset(&buf2) // and not flushed w.WriteString("bar") w.Flush() if buf1.String() != "" { t.Errorf("buf1 = %q; want empty", buf1.String()) } if buf2.String() != "bar" { t.Errorf("buf2 = %q; want bar", buf2.String()) } *w = Writer{} // zero out the Writer w.Reset(&buf3) // and not flushed w.WriteString("bar") w.Flush() if buf1.String() != "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 10 18:56:01 UTC 2023 - 51.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
natChains.Write(utiliptables.MakeChainLine(chain)) // flush natRules.Write("-X", chainString) // delete } } // Hunt for service and endpoint chains. for chain := range existingNATChains { chainString := string(chain) if isServiceChainName(chainString) { natChains.Write(utiliptables.MakeChainLine(chain)) // flush natRules.Write("-X", chainString) // delete }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
{bucketNames[0], objectNames[0], uploadIDs[0], inputParts[3].parts, s3MD5, nil, true}, // The other parts will be flushed after a successful CompletePart (Test number 18). // the case above successfully completes CompleteMultipartUpload, the remaining Parts will be flushed. // Expecting to fail with Invalid UploadID.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
// Cause the size to grow to 12 should evict 'A'. set("c", "c", "c") cache.flush() assertThat(cache.size()).isEqualTo(8) assertAbsent("a") assertValue("b", "bb", "bbbb") assertValue("c", "c", "c") // Causing the size to grow to 10 should evict nothing. set("d", "d", "d") cache.flush() assertThat(cache.size()).isEqualTo(10) assertAbsent("a")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0)