- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 115 for flushed (0.27 sec)
-
doc/next/6-stdlib/99-minor/runtime/trace/65319.md
<!-- go.dev/issue/65319 --> The runtime now explicitly flushes trace data when a program crashes due to an uncaught panic. This means that more complete trace data will be available in a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:37:09 UTC 2024 - 241 bytes - Viewed (0) -
cmd/listen-notification-handlers.go
if err != nil { return } if len(mergeCh) == 0 { // Flush if nothing is queued w.(http.Flusher).Flush() } grid.PutByteBuffer(ev) case <-emptyEventTicker: if err := enc.Encode(struct{ Records []event.Event }{}); err != nil { return } w.(http.Flusher).Flush() case <-keepAliveTicker: if _, err := w.Write([]byte(" ")); err != nil { return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
src/net/http/serve_test.go
return errors.New("header appeared from after WriteHeader") } return nil }, }, { name: "flush then write", handler: func(rw ResponseWriter, r *Request) { rw.(Flusher).Flush() rw.Write([]byte("post-flush")) rw.Header().Set("Too-Late", "Write already wrote headers") }, check: func(got, logs string) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
} return tw.w.Write(p) } func (tw *baseTimeoutWriter) Flush() { tw.mu.Lock() defer tw.mu.Unlock() if tw.timedOut { return } // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements // http.Flusher if the inner object (tw.w) implements http.Flusher. tw.w.(http.Flusher).Flush() } func (tw *baseTimeoutWriter) WriteHeader(code int) { tw.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
src/cmd/link/internal/ld/outbuf_mmap.go
//go:build unix package ld import ( "syscall" ) // Mmap maps the output file with the given size. It unmaps the old mapping // if it is already mapped. It also flushes any in-heap data to the new // mapping. func (out *OutBuf) Mmap(filesize uint64) (err error) { oldlen := len(out.buf) if oldlen != 0 { out.munmap() } for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:20:31 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Connection decorator that synchronizes dispatching and always flushes after each message. * * The plan is to replace this with a Connection implementation that queues outgoing messages and dispatches them from a worker thread. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
src/net/http/h2_bundle.go
return err } } if sentEnd { // Already sent END_STREAM (which implies we have no // trailers) and flushed, because currently all // WriteData frames above get a flush. So we're done. return nil } // Since the RoundTrip contract permits the caller to "mutate or reuse" // a request after the Response's Body is closed, verify that this hasn't
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/clientserver_test.go
func TestH12_FlushBeforeBody(t *testing.T) { h12Compare{Handler: func(w ResponseWriter, r *Request) { w.(Flusher).Flush() io.WriteString(w, "foo") }}.run(t) } func TestH12_FlushMidBody(t *testing.T) { h12Compare{Handler: func(w ResponseWriter, r *Request) { io.WriteString(w, "foo") w.(Flusher).Flush() io.WriteString(w, "bar") }}.run(t) } func TestH12_Head_ExplicitLen(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/BuildTreeConfigurationCache.kt
*/ fun loadOrCreateProjectMetadata(identityPath: Path, creator: () -> LocalComponentGraphResolveState): LocalComponentGraphResolveState /** * Flushes any remaining state to the cache and closes any resources */ fun finalizeCacheEntry() // This is a temporary property to allow migration from a root build scoped cache to a build tree scoped cache
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.5K bytes - Viewed (0) -
src/cmd/trace/gen.go
Resource: trace.GCP, Stack: ctx.Stack(viewerFrames(ar.stack)), EndStack: ctx.Stack(viewerFrames(ev.Stack())), }) } delete(g.ranges, r.Name) } } // Finish flushes any outstanding ranges at the end of the trace. func (g *globalRangeGenerator) Finish(ctx *traceContext) { for name, ar := range g.ranges { if !strings.Contains(name, "GC") { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.5K bytes - Viewed (0)