Superminaren
/
kvm
mirror of https://github.com/jetkvm/kvm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add log for rpc queue

This commit is contained in:
Siyuan Miao 2025-08-28 23:11:37 +02:00
parent 66cccfe9e1
commit 3bc74b1ce5
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
webrtc.go
View File

@ -6,6 +6,7 @@ import (
"encoding/json" "encoding/json"
"net" "net"
"strings" "strings"
"time"
"github.com/coder/websocket" "github.com/coder/websocket"
"github.com/coder/websocket/wsjson" "github.com/coder/websocket/wsjson"
@ -110,7 +111,9 @@ func newSession(config SessionConfig) (*Session, error) {
session.rpcQueue = make(chan webrtc.DataChannelMessage, 256) session.rpcQueue = make(chan webrtc.DataChannelMessage, 256)
go func() { go func() {
for msg := range session.rpcQueue { for msg := range session.rpcQueue {
start := time.Now()
onRPCMessage(msg, session) onRPCMessage(msg, session)
scopedLogger.Info().Dur("duration", time.Since(start)).Interface("msg", msg).Msg("RPC message processed")
} }
}() }()
@ -121,6 +124,7 @@ func newSession(config SessionConfig) (*Session, error) {
session.RPCChannel = d session.RPCChannel = d
d.OnMessage(func(msg webrtc.DataChannelMessage) { d.OnMessage(func(msg webrtc.DataChannelMessage) {
// Enqueue to ensure ordered processing // Enqueue to ensure ordered processing
scopedLogger.Info().Interface("msg", msg).Msg("Enqueuing RPC message")
session.rpcQueue <- msg session.rpcQueue <- msg
}) })
triggerOTAStateUpdate() triggerOTAStateUpdate()