- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 263 for flushed (0.42 sec)
-
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) -
cmd/sftp-server-driver.go
_ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy.go
var w io.Writer = dst if flushInterval != 0 { mlw := &maxLatencyWriter{ dst: dst, flush: http.NewResponseController(dst).Flush, latency: flushInterval, } defer mlw.stop() // set up initial timer so headers get flushed even if body writes are delayed mlw.flushPending = true mlw.t = time.AfterFunc(flushInterval, mlw.delayedFlush) w = mlw }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/composition.go
func (rb *reorderBuffer) setFlusher(out []byte, f func(*reorderBuffer) bool) { rb.out = out rb.flushF = f } // reset discards all characters from the buffer. func (rb *reorderBuffer) reset() { rb.nrune = 0 rb.nbyte = 0 } func (rb *reorderBuffer) doFlush() bool { if rb.f.composing { rb.compose() } res := rb.flushF(rb) rb.reset() return res }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 14.1K 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) -
src/vendor/golang.org/x/text/unicode/norm/composition.go
func (rb *reorderBuffer) setFlusher(out []byte, f func(*reorderBuffer) bool) { rb.out = out rb.flushF = f } // reset discards all characters from the buffer. func (rb *reorderBuffer) reset() { rb.nrune = 0 rb.nbyte = 0 } func (rb *reorderBuffer) doFlush() bool { if rb.f.composing { rb.compose() } res := rb.flushF(rb) rb.reset() return res }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 19:27:51 UTC 2019 - 14.1K bytes - Viewed (0) -
src/cmd/trace/gstate.go
// activeRanges is the set of all active ranges on the goroutine. activeRanges map[string]activeRange // completedRanges is a list of ranges that completed since before the // goroutine stopped executing. These are flushed on every stop or block. completedRanges []completedRange // startRunning is the most recent event that caused a goroutine to // transition to GoRunning. startRunningTime trace.Time
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/util/iptables/iptables.go
// data should be formatted like the output of SaveInto() // flush sets the presence of the "--noflush" flag. see: FlushFlag // counters sets the "--counters" flag. see: RestoreCountersFlag Restore(table Table, data []byte, flush FlushFlag, counters RestoreCountersFlag) error // RestoreAll is the same as Restore except that no table is specified. RestoreAll(data []byte, flush FlushFlag, counters RestoreCountersFlag) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 28.6K 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)