- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 169 for flushed (0.41 sec)
-
src/mime/quotedprintable/writer.go
w.line[w.i] = '=' w.i++ return w.insertCRLF() } func (w *Writer) insertCRLF() error { w.line[w.i] = '\r' w.line[w.i+1] = '\n' w.i += 2 return w.flush() } func (w *Writer) flush() error { if _, err := w.w.Write(w.line[:w.i]); err != nil { return err } w.i = 0 return nil } func isWhitespace(b byte) bool { return b == ' ' || b == '\t'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 3.2K bytes - Viewed (0) -
operator/pkg/metrics/monitoring.go
"legacy_path_translation_total", "Number of times a legacy API path is translated", ) // CacheFlushTotal counts number of cache flushes. CacheFlushTotal = monitoring.NewSum( "cache_flush_total", "number of times operator cache was flushed", ) ) func init() { initOperatorCrdResourceMetrics() } func IncrementReconcileRequest(reason string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/AbstractDaemonLifecycleSpec.groovy
} void doDaemonContext(gradleHandle, Closure assertions) { // poll here since even though the daemon has been marked as busy in the registry, the context may not have been // flushed to the log yet. DaemonContext context poll(5) { context = DaemonContextParser.parseFromString(gradleHandle.standardOutput, GradleVersion.current()) } context.with(assertions)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:32:55 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/logger/logrotate.go
// Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer. // Any accepted writes will be flushed. Any new writes will be rejected. // Once Close() exits, files are synchronized to disk. func (w *Writer) Close() error { w.pw.CloseWithError(nil) if w.f != nil { if err := w.closeCurrentFile(); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/logging/src/integTest/groovy/org/gradle/internal/logging/console/taskgrouping/AbstractBasicGroupedTaskLoggingFunctionalTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 8.2K bytes - Viewed (0) -
src/runtime/tracebuf.go
// // Returns whether the buffer was flushed. func (w traceWriter) ensure(maxSize int) (traceWriter, bool) { refill := w.traceBuf == nil || !w.available(maxSize) if refill { w = w.refill(traceNoExperiment) } return w, refill } // flush puts w.traceBuf on the queue of full buffers. func (w traceWriter) flush() traceWriter { systemstack(func() { lock(&trace.lock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 6.8K bytes - Viewed (0) -
src/runtime/mwbbuf.go
// un-shaded stacks and flush after each stack scan. gcw := &pp.gcw pos := 0 for _, ptr := range ptrs { if ptr < minLegalPointer { // nil pointers are very common, especially // for the "old" values. Filter out these and // other "obvious" non-heap pointers ASAP. // // TODO: Should we filter out nils in the fast // path to reduce the rate of flushes? continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
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/hash/maphash/maphash.go
type Hash struct { _ [0]func() // not comparable seed Seed // initial seed used for this hash state Seed // current hash of all flushed bytes buf [bufSize]byte // unflushed byte buffer n int // number of unflushed bytes } // bufSize is the size of the Hash write buffer. // The buffer ensures that writes depend only on the sequence of bytes,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 19:15:34 UTC 2023 - 7.9K bytes - Viewed (0) -
src/compress/lzw/reader.go
// Non-literal codes decode to a sequence of suffixes that are first // written right-to-left from the end of the buffer before being copied // to the start of the buffer. // It is flushed when it contains >= 1<<maxWidth bytes, // so that there is always room to decode an entire code. output [2 * 1 << maxWidth]byte o int // write index into output toRead []byte // bytes to return from Read }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:39 UTC 2023 - 8K bytes - Viewed (0)