aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/system
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-02-07 13:16:54 +0900
committerOphestra <cat@gensokyo.uk>2025-02-07 13:16:54 +0900
commit2e521914042ec427cae3c429b448c4bc3eed61de (patch)
tree87707e201da62d9133e4b194adedeba8432cff45 /internal/system
parent568d7758d5308457967672997d9d2e786c7403f1 (diff)
system/dbus: dump method prints msgbuf
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/system')
-rw-r--r--internal/system/dbus.go10
1 files changed, 6 insertions, 4 deletions
diff --git a/internal/system/dbus.go b/internal/system/dbus.go
index 886ba77f..859fa029 100644
--- a/internal/system/dbus.go
+++ b/internal/system/dbus.go
@@ -23,7 +23,7 @@ func (sys *I) MustProxyDBus(sessionPath string, session *dbus.Config, systemPath
}
}
-func (sys *I) ProxyDBus(session, system *dbus.Config, sessionPath, systemPath string) (func(f func(msgbuf []string)), error) {
+func (sys *I) ProxyDBus(session, system *dbus.Config, sessionPath, systemPath string) (func(), error) {
d := new(DBus)
// used by waiting goroutine to notify process exit
@@ -65,7 +65,7 @@ func (sys *I) ProxyDBus(session, system *dbus.Config, sessionPath, systemPath st
// seal dbus proxy
d.out = &scanToFmsg{msg: new(strings.Builder)}
- return d.out.F, fmsg.WrapErrorSuffix(d.proxy.Seal(session, system),
+ return d.out.Dump, fmsg.WrapErrorSuffix(d.proxy.Seal(session, system),
"cannot seal message bus proxy:")
}
@@ -195,8 +195,10 @@ func (s *scanToFmsg) write(p []byte, a int) (int, error) {
}
}
-func (s *scanToFmsg) F(f func(msgbuf []string)) {
+func (s *scanToFmsg) Dump() {
s.mu.RLock()
- f(s.msgbuf)
+ for _, msg := range s.msgbuf {
+ fmsg.Println(msg)
+ }
s.mu.RUnlock()
}