We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 66d9f18 + 5cd2bd2 commit 6f5de38Copy full SHA for 6f5de38
go/pkg/libproxy/multiplexed.go
@@ -574,14 +574,20 @@ func (m *multiplexer) DumpState(w io.Writer) {
574
}
575
})
576
m.eventsM.Unlock()
577
+
578
+ var channels []*channel
579
m.metadataMutex.Lock()
- io.WriteString(w, "Active channels:\n")
580
for _, c := range m.channels {
581
+ channels = append(channels, c)
582
+ }
583
+ m.metadataMutex.Unlock()
584
585
+ io.WriteString(w, "Active channels:\n")
586
+ for _, c := range channels {
587
io.WriteString(w, c.String())
588
io.WriteString(w, "\n")
589
590
io.WriteString(w, "End of state dump\n")
- m.metadataMutex.Unlock()
591
592
593
// IsRunning returns whether the multiplexer is running or not
0 commit comments