- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 849 for flushF (0.17 sec)
-
src/runtime/mcache.go
} // Clear tinyalloc pool. c.tiny = 0 c.tinyoffset = 0 // Flush tinyAllocs. stats := memstats.heapStats.acquire() atomic.Xadd64(&stats.tinyAllocCount, int64(c.tinyAllocs)) c.tinyAllocs = 0 memstats.heapStats.release() // Update heapLive and heapScan. gcController.update(dHeapLive, scanAlloc) } // prepareForSweep flushes c if the system has entered a new sweep phase
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
misc/go_android_exec/exitcode_test.go
_, err := f.Write([]byte{text[i]}) if err != nil { t.Fatal(err) } } // The "pre" output should all have been flushed already. if want, got := pre, out.String(); want != got { t.Errorf("filter should have already flushed %q, but flushed %q", want, got) } code, err := f.Finish() if err != nil { t.Fatal(err) } // Nothing more should have been written to out.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 03 14:54:58 UTC 2023 - 2.1K 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) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/FlushConsoleListener.java
import org.gradle.internal.logging.events.OutputEvent; import org.gradle.internal.logging.events.OutputEventListener; import org.gradle.internal.logging.events.UpdateNowEvent; /** * Flushes the console output. Used when no other listener in the chain flushes the console. */ public class FlushConsoleListener implements OutputEventListener { private final OutputEventListener delegate; private final Console console;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/fake.go
// For HTTP2 an http.ResponseWriter object implements // http.Flusher and http.CloseNotifier. // It is used for testing purpose only type FakeResponseWriterFlusherCloseNotifier struct { *FakeResponseWriter } func (fw *FakeResponseWriterFlusherCloseNotifier) Flush() {} func (fw *FakeResponseWriterFlusherCloseNotifier) CloseNotify() <-chan bool { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 01 19:58:11 UTC 2021 - 1.8K bytes - Viewed (0) -
src/runtime/tracetype.go
// bound is pretty loose, but avoids counting // lots of varint sizes. // // Add 1 because we might also write a traceAllocFreeTypesBatch byte. var flushed bool w, flushed = w.ensure(1 + maxBytes) if flushed { // Annotate the batch as containing types. w.byte(byte(traceAllocFreeTypesBatch)) } // Emit type. w.varint(uint64(node.id)) w.varint(uint64(uintptr(unsafe.Pointer(typ))))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:31:27 UTC 2024 - 2.3K bytes - Viewed (0) -
src/text/tabwriter/tabwriter.go
// complete for formatting purposes. func (b *Writer) Flush() error { return b.flush() } // flush is the internal version of Flush, with a named return value which we // don't want to expose. func (b *Writer) flush() (err error) { defer b.handlePanic(&err, "Flush") b.flushNoDefers() return nil } // flushNoDefers is like flush, but without a deferred handlePanic call. This
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 16:46:34 UTC 2024 - 17.8K bytes - Viewed (0) -
src/compress/flate/deflate.go
// If the underlying writer returns an error, Flush returns that error. // // In the terminology of the zlib library, Flush is equivalent to Z_SYNC_FLUSH. func (w *Writer) Flush() error { // For more about flushing: // https://www.bolet.org/~pornin/deflate-flush.html return w.d.syncFlush() } // Close flushes and closes the writer. func (w *Writer) Close() error { return w.d.close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 20.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go
if len(contentType) == 0 { contentType = "application/octet-stream" } w.Header().Set("Content-Type", contentType) w.WriteHeader(statusCode) // Flush headers, if possible if flusher, ok := w.(http.Flusher); ok { flusher.Flush() } writer := w.(io.Writer) if flush { writer = flushwriter.Wrap(w) } io.Copy(writer, out) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/hbone/util.go
nr, err := src.Read(buf) log.Debugf("read %v/%v", nr, err) if nr > 0 { // before dealing with the read error nw, ew := dst.Write(buf[0:nr]) log.Debugf("write %v/%v", nw, ew) if f, ok := dst.(http.Flusher); ok { f.Flush() } if nr != nw { // Should not happen ew = io.ErrShortWrite } if ew != nil { return } } if err != nil { // read is already closed - we need to close out
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0)