- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 527 for frame_0 (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/goaway_test.go
if tc.expectConnections != len(localAddr) { t.Fatalf("expect TCP connection: %d, actual: %d", tc.expectConnections, len(localAddr)) } // check if watch request is broken by GOAWAY frame watchTimeout := time.NewTimer(time.Second * 10) defer watchTimeout.Stop() for _, watchCh := range watchChs { select { case watchResp := <-watchCh: if watchResp.err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:54 UTC 2021 - 13.9K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
StkID uint32 // unique stack ID P int32 // P on which the event happened (can be a real P or one of TimerP, NetpollP, SyscallP) Type event.Type // one of Ev* } // Frame is a frame in stack traces. type Frame struct { PC uint64 // string ID of the function name Fn uint64 // string ID of the file name File uint64 Line int } const ( // Special P identifiers:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/json/json.go
if s.options.Yaml { // we could potentially look for '---' return false, true, nil } return utilyaml.IsJSONBuffer(data), false, nil } // Framer is the default JSON framing behavior, with newlines delimiting individual objects. var Framer = jsonFramer{} type jsonFramer struct{} // NewFrameWriter implements stream framing for this serializer func (jsonFramer) NewFrameWriter(w io.Writer) io.Writer {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 25 16:08:07 UTC 2022 - 12K bytes - Viewed (0) -
pkg/kubelet/server/server_websocket_test.go
assert.Len(t, portsForwarded, len(ports), "all ports forwarded") } func wsWrite(conn *websocket.Conn, channel byte, data []byte) error { frame := make([]byte, len(data)+1) frame[0] = channel copy(frame[1:], data) err := websocket.Message.Send(conn, frame) return err } func wsRead(conn *websocket.Conn) (byte, []byte, error) { for { var data []byte err := websocket.Message.Receive(conn, &data)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 8.2K bytes - Viewed (0) -
src/internal/runtime/atomic/atomic_arm.s
// we have to cooperate with stack unwinding. In the normal case, the // functions tail-call into the appropriate implementation, which // means they must not open a frame. Hence, when they go down the // panic path, at that point they push the LR to create a real frame // (they don't need to pop it because panic won't return; however, we // do need to set the SP delta back). // Check if R1 is 8-byte aligned, panic if not.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.7K bytes - Viewed (0) -
src/image/decode_test.go
t.Errorf("%s: at (%d, %d):\ngot %v\nwant %v", it.filename, x, y, rgba(m.At(x, y)), rgba(g.At(x, y))) continue loop } } } if imageFormat == "gif" { // Each frame of a GIF can have a frame-local palette override the // GIF-global palette. Thus, image.Decode can yield a different ColorModel // than image.DecodeConfig. continue } c, _, err := decodeConfig(it.filename)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 15:51:48 UTC 2019 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
return NewClientConnectionWithPings(conn, 0) } // NewClientConnectionWithPings creates a new SPDY client connection. // // If pingPeriod is non-zero, a background goroutine will send periodic Ping // frames to the server. Use this to keep idle connections through certain load // balancers alive longer. func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/interfaces.go
// EncodeParameters encodes the provided object as query parameters or returns an error. EncodeParameters(obj Object, to schema.GroupVersion) (url.Values, error) } // Framer is a factory for creating readers and writers that obey a particular framing pattern. type Framer interface { NewFrameReader(r io.ReadCloser) io.ReadCloser NewFrameWriter(w io.Writer) io.Writer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 19K bytes - Viewed (0) -
src/cmd/cgo/internal/test/callback_windows.go
t.Skip("skipping for non-gc toolchain") } if runtime.GOARCH != "amd64" { // TODO: support SEH on other architectures. t.Skip("skipping on non-amd64") } // Only frames in the test package are checked. want := []string{ "test._Cfunc_backtrace", "test.testCallbackCallersSEH.func1.1", "test.testCallbackCallersSEH.func1", "test.goCallback", "test._Cfunc_callback",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 29 16:01:37 UTC 2023 - 2.6K bytes - Viewed (0) -
src/cmd/internal/obj/ppc64/obj9.go
q.To.Reg = REGSP q.Spadj = autosize } else { // Frame size is too large for a MOVDU instruction. // Store link register before decrementing SP, so if a signal comes // during the execution of the function prologue, the traceback // code will not see a half-updated stack frame. // This sequence is not async preemptible, as if we open a frame // at the current SP, it will clobber the saved LR.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 18:17:17 UTC 2024 - 40.8K bytes - Viewed (0)