- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for flushRet (0.18 sec)
-
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/asmdecl/asmdecl.go
fnName string abi string localSize, argSize int wroteSP bool noframe bool haveRetArg bool retLine []int ) flushRet := func() { if fn != nil && fn.vars["ret"] != nil && !haveRetArg && len(retLine) > 0 { v := fn.vars["ret"] resultStr := fmt.Sprintf("%d-byte ret+%d(FP)", v.size, v.off) if abi == "ABIInternal" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 22.8K bytes - Viewed (0) -
src/runtime/mcache.go
// to avoid spilling mark bits into the *next* GC cycle. sg := mheap_.sweepgen flushGen := c.flushGen.Load() if flushGen == sg { return } else if flushGen != sg-2 { println("bad flushGen", flushGen, "in prepareForSweep; sweepgen", sg) throw("bad flushGen") } c.releaseAll() stackcache_clear(c) c.flushGen.Store(mheap_.sweepgen) // Synchronizes with gcStart
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flushwriter/writer.go
package flushwriter import ( "io" "net/http" ) // Wrap wraps an io.Writer into a writer that flushes after every write if // the writer implements the Flusher interface. func Wrap(w io.Writer) io.Writer { fw := &flushWriter{ writer: w, } if flusher, ok := w.(http.Flusher); ok { fw.flusher = flusher } return fw } // flushWriter provides wrapper for responseWriter with HTTP streaming capabilities
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 16:09:42 UTC 2017 - 1.3K bytes - Viewed (0) -
src/runtime/tracestring.go
s = s[:maxTraceStringLen] } lock(&t.lock) w := unsafeTraceWriter(gen, t.buf) // Ensure we have a place to write to. var flushed bool w, flushed = w.ensure(2 + 2*traceBytesPerNumber + len(s) /* traceEvStrings + traceEvString + ID + len + string data */) if flushed { // Annotate the batch as containing strings. w.byte(byte(traceEvStrings)) } // Write out the string. w.byte(byte(traceEvString))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flushwriter/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package flushwriter implements a wrapper for a writer that flushes on every // write if that writer implements the io.Flusher interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 16:14:27 UTC 2017 - 780 bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0) -
src/cmd/internal/gcprog/gcprog.go
if w.nb == progMaxLiteral { w.flushlit() } w.b[w.nb] = x w.nb++ w.index++ } // varint emits the varint encoding of x. func (w *Writer) varint(x int64) { if x < 0 { panic("gcprog: negative varint") } for x >= 0x80 { w.byte(byte(0x80 | x)) x >>= 7 } w.byte(byte(x)) } // flushlit flushes any pending literal bits. func (w *Writer) flushlit() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 7.4K bytes - Viewed (0) -
pkg/scheduler/metrics/metric_recorder.go
// if bufferSize is reached, incoming metrics will be discarded. bufferSize int // how often the recorder runs to flush the metrics. interval time.Duration // stopCh is used to stop the goroutine which periodically flushes metrics. stopCh <-chan struct{} // IsStoppedCh indicates whether the goroutine is stopped. It's used in tests only to make sure // the metric flushing goroutine is stopped so that tests can collect metrics for verification.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 16 07:27:08 UTC 2023 - 4.4K bytes - Viewed (0) -
src/compress/zlib/writer.go
return err } z.digest = adler32.New() } return nil } // Write writes a compressed form of p to the underlying io.Writer. The // compressed bytes are not necessarily flushed until the Writer is closed or // explicitly flushed. func (z *Writer) Write(p []byte) (n int, err error) { if !z.wroteHeader { z.err = z.writeHeader() } if z.err != nil { return 0, z.err } if len(p) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 27 18:51:27 UTC 2023 - 5.2K bytes - Viewed (0) -
src/net/http/httptest/recorder.go
rw.HeaderMap = make(http.Header) } rw.snapHeader = rw.HeaderMap.Clone() } // Flush implements [http.Flusher]. To test whether Flush was // called, see rw.Flushed. func (rw *ResponseRecorder) Flush() { if !rw.wroteHeader { rw.WriteHeader(200) } rw.Flushed = true } // Result returns the response generated by the handler. // // The returned Response will have at least its StatusCode,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7K bytes - Viewed (0)