diff --git a/webrtc.go b/webrtc.go index 27d8e454..51e15f78 100644 --- a/webrtc.go +++ b/webrtc.go @@ -29,12 +29,12 @@ type Session struct { rpcQueue chan webrtc.DataChannelMessage - hidRPCAvailable bool - lastKeepAliveArrivalTime time.Time // Track when last keep-alive packet arrived - lastTimerResetTime time.Time // Track when auto-release timer was last reset - keepAliveJitterLock sync.Mutex // Protect jitter compensation timing state - hidQueueLock sync.Mutex - hidQueue []chan hidQueueMessage + hidRPCAvailable bool + lastKeepAliveArrivalTime time.Time // Track when last keep-alive packet arrived + lastTimerResetTime time.Time // Track when auto-release timer was last reset + keepAliveJitterLock sync.Mutex // Protect jitter compensation timing state + hidQueueLock sync.Mutex + hidQueue []chan hidQueueMessage keysDownStateQueue chan usbgadget.KeysDownState } @@ -159,7 +159,6 @@ func getOnHidMessageHandler(session *Session, scopedLogger *zerolog.Logger, chan l.Trace().Msg("received data in HID RPC message handler") - // Enqueue to ensure ordered processing queueIndex := hidrpc.GetQueueIndex(hidrpc.MessageType(msg.Data[0])) if queueIndex >= len(session.hidQueue) || queueIndex < 0 {