- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for syncEvent (0.14 sec)
-
src/internal/trace/event_test.go
// license that can be found in the LICENSE file. package trace import "testing" func TestPanicEvent(t *testing.T) { // Use a sync event for this because it doesn't have any extra metadata. ev := syncEvent(nil, 0) mustPanic(t, func() { _ = ev.Range() }) mustPanic(t, func() { _ = ev.Metric() }) mustPanic(t, func() { _ = ev.Log() }) mustPanic(t, func() { _ = ev.Task() })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 784 bytes - Viewed (0) -
src/internal/trace/reader.go
return ev, nil } // Check if we need to refresh the generation. if len(r.frontier) == 0 && len(r.cpuSamples) == 0 { if !r.emittedSync { r.emittedSync = true return syncEvent(r.gen.evTable, r.lastTs), nil } if r.spillErr != nil { return Event{}, r.spillErr } if r.gen != nil && r.spill == nil { // If we have a generation from the last read,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
internal/event/targetlist.go
currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)