Mirrors/cloud-game
1
0
Fork 0
mirror of https://github.com/giongto35/cloud-game.git synced 2026-01-23 02:34:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

Revert "Add user input caching"

Browse source 
This reverts commit 859d0c8f1a.
This commit is contained in:
sergystepanov 2025-11-22 17:46:07 +03:00
parent 859d0c8f1a
commit 09a0c9c3f2
1 changed files with 4 additions and 56 deletions
Download patch file Download diff file Expand all files Collapse all files

60
pkg/worker/caged/libretro/frontend.go
View file

@ -70,8 +70,6 @@ type Frontend struct {
// skipVideo used when new frame was too late
skipVideo bool
inputs [maxPort]inputCache
mu sync.Mutex
mui sync.Mutex
@ -83,16 +81,6 @@ type Frontend struct {
type Device byte
type inputCache struct {
mu sync.Mutex
pad []byte
key []byte
mouse []byte
dirty uint8 // bitmask: 1=Pad, 2=Key, 4=Mouse
}
const maxPort = 8
const (
RetroPad = Device(nanoarch.RetroPad)
Keyboard = Device(nanoarch.Keyboard)
@ -407,58 +395,18 @@ func (f *Frontend) SetAudioCb(cb func(app.Audio)) { f.onAudio = cb }
func (f *Frontend) SetSessionId(name string) { f.storage.SetMainSaveName(name) }
func (f *Frontend) SetDataCb(cb func([]byte)) { f.onData = cb }
func (f *Frontend) SetVideoCb(ff func(app.Video)) { f.onVideo = ff }
func (f *Frontend) Tick() { f.syncInputs(); f.mu.Lock(); f.nano.Run(); f.mu.Unlock() }
func (f *Frontend) Tick() { f.mu.Lock(); f.nano.Run(); f.mu.Unlock() }
func (f *Frontend) ViewportRecalculate() { f.mu.Lock(); f.vw, f.vh = f.ViewportCalc(); f.mu.Unlock() }
func (f *Frontend) ViewportSize() (int, int) { return f.vw, f.vh }
func (f *Frontend) Input(port int, device byte, data []byte) {
if port >= maxPort {
return
}
c := &f.inputs[port]
c.mu.Lock()
switch Device(device) {
case RetroPad:
c.pad = append(c.pad[:0], data...)
c.dirty |= 1
f.nano.InputRetropad(port, data)
case Keyboard:
c.key = append(c.key[:0], data...)
c.dirty |= 2
f.nano.InputKeyboard(port, data)
case Mouse:
c.mouse = append(c.mouse[:0], data...)
c.dirty |= 4
}
c.mu.Unlock()
}
func (f *Frontend) syncInputs() {
for i := 0; i < maxPort; i++ {
c := &f.inputs[i]
c.mu.Lock()
if c.dirty == 0 {
c.mu.Unlock()
continue
}
d := c.dirty
c.dirty = 0
if d&1 != 0 {
f.nano.InputRetropad(i, c.pad)
}
if d&2 != 0 {
f.nano.InputKeyboard(i, c.key)
}
if d&4 != 0 {
f.nano.InputMouse(i, c.mouse)
}
c.mu.Unlock()
f.nano.InputMouse(port, data)
}
}