- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for debugPrintf (0.23 sec)
-
src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go
state = c.state.load() } debugPrintf("Add %q += %d: nil extra=%d\n", c.name, n, state.extra()) } else { sum := c.add(uint64(n)) debugPrintf("Add %q += %d: count=%d\n", c.name, n, sum) } c.releaseReader(state) return case state.locked(): if !c.state.update(&state, state.addExtra(uint64(n))) { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 10.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go
if next == nil { next = &f.end } debugPrintf("register %s next %p\n", c.Name(), next) if !wroteNext { if !c.next.CompareAndSwap(nil, next) { debugPrintf("register %s cas failed %p\n", c.Name(), c.next.Load()) continue } wroteNext = true } else { c.next.Store(next) } if f.counters.CompareAndSwap(head, c) { debugPrintf("registered %s %p\n", c.Name(), f.counters.Load()) return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 18.2K bytes - Viewed (0) -
internal/grid/muxclient.go
// m.respMu must be held. func (m *muxClient) sendLocked(msg message) error { dst := GetByteBufferCap(msg.Msgsize()) msg.Seq = m.SendSeq msg.MuxID = m.MuxID msg.Flags |= m.BaseFlags if debugPrint { fmt.Println("Client sending", &msg, "to", m.parent.Remote) } m.SendSeq++ dst, err := msg.MarshalMsg(dst) if err != nil { return err } if msg.Flags&FlagSubroute != 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/grid/muxserver.go
start := time.Now() defer func() { if debugPrint { fmt.Println("Mux", m.ID, "Handler took", time.Since(start).Round(time.Millisecond)) } if r := recover(); r != nil { gridLogIf(ctx, fmt.Errorf("grid handler (%v) panic: %v", msg.Handler, r)) err := RemoteErr(fmt.Sprintf("handler panic: %v", r)) handlerErr = &err } if debugPrint {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/grid/connection.go
} dialer.TLSConfig = c.tlsConfig dialStarted := time.Now() if debugPrint { fmt.Println(c.Local, "Connecting to ", toDial) } conn, br, _, err := dialer.Dial(c.ctx, toDial) if br != nil { ws.PutReader(br) } c.connMu.Lock() c.debugOutConn = conn c.connMu.Unlock() retry := func(err error) { if debugPrint { fmt.Printf("%v Connecting to %v: %v. Retrying.\n", c.Local, toDial, err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
internal/grid/manager.go
defer func() { if debugPrint { fmt.Printf("grid: Handler returning from: %v %v\n", req.Method, req.URL) } if r := recover(); r != nil { debug.PrintStack() err := fmt.Errorf("grid: panic: %v\n", r) gridLogIf(context.Background(), err, err.Error()) w.WriteHeader(http.StatusInternalServerError) } }() if debugPrint {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
internal/grid/debug.go
"github.com/minio/mux" ) //go:generate stringer -type=debugMsg $GOFILE // debugMsg is a debug message for testing purposes. // may only be used for tests. type debugMsg int const ( debugPrint = false debugReqs = false ) const ( debugShutdown debugMsg = iota debugKillInbound debugKillOutbound debugWaitForExit debugSetConnPingDuration debugSetClientPingDuration debugAddToDeadline
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0) -
tests/fuzz/crd_roundtrip_fuzzer.go
func dataAsString(data []byte) string { dataString := string(data) if !strings.HasPrefix(dataString, "{") { dataString = "\n" + hex.Dump(data) legacyproto.NewBuffer(make([]byte, 0, 1024)).DebugPrint("decoded object", data) } return dataString } // checkForNilValues is a helper to check for nil // values in the runtime objects. // This part only converts the interface to a reflect.Value.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/roundtrip.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 16.8K bytes - Viewed (0)