Mirrors/m1n1
2
0
Fork 0
mirror of https://github.com/AsahiLinux/m1n1 synced 2024-11-21 14:23:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

afk.epic: Support sending direct notify messages

Browse source 
Much simpler than the command messages. We just write directly into the
TX ringbuffer.

Signed-off-by: Eileen Yoon <eyn@gmx.com>
This commit is contained in:
Eileen Yoon 2024-01-23 20:12:08 +09:00 committed by Hector Martin
parent 5f59c5460c
commit e430874a2a
1 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
proxyclient/m1n1/fw/afk/epic.py
View file

@ -195,6 +195,15 @@ class EPICService:
self.ep.asc.work()
return self.reply
def send_notify(self, type, data, **kwargs):
self.reply = None
self.iface.writemem(self.txbuf, data)
self.ep.send_epic(self.chan, EPICType.NOTIFY, EPICCategory.NOTIFY, type, self.seq, data, **kwargs)
self.seq += 1
while self.reply is None:
self.ep.asc.work()
return self.reply
class EPICStandardService(EPICService):
def call(self, group, cmd, data=b'', replen=None):
msg = struct.pack("<2xHIII48x", group, cmd, len(data), 0x69706378) + data
@ -325,6 +334,15 @@ class EPICEndpoint(AFKRingBufEndpoint):
def handle_cmd(self, hdr, sub, fd):
self.chan_map[hdr.channel].handle_cmd(sub.category, sub.type, sub.seq, fd)
def send_roundtrip(self, chan, call, **kwargs):
self.serv_map[chan].last_call = call
ret = self.serv_map[chan].send_notify(call.TYPE, call.ARGS.build(call.args), **kwargs)
self.serv_map[chan].last_call = None
return ret
def send_notify(self, chan, call, **kwargs):
return self.serv_map[chan].send_notify(call.TYPE, call.ARGS.build(call.args), **kwargs)
def send_epic(self, chan, ptype, category, type, seq, data, inline_len=0):
hdr = Container()
hdr.channel = chan