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

afk.epic: Enum for EPICSubtype & service init v2

Browse source 
Consistently use an enum for EPICSubtype (used later) and support the v2
EPICService intializer protocol used by AOP.

Signed-off-by: Eileen Yoon <eyn@gmx.com>
This commit is contained in:
Eileen Yoon 2024-01-23 19:03:44 +09:00 committed by Hector Martin
parent bf5a3a6e98
commit 6426bdf6a5
1 changed files with 40 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -23,6 +23,12 @@ EPICCategory = "EPICCategory" / Enum(Int8ul,
COMMAND = 0x30,
)
EPICSubtype = "EPICSubtype" / Enum(Int16ul,
ANNOUNCE = 0x30,
TEARDOWN = 0x32,
STD_SERVICE = 0xc0,
)
EPICHeader = Struct(
"channel" / Int32ul,
"type" / EPICType,
@ -37,18 +43,30 @@ EPICSubHeader = Struct(
"length" / Int32ul,
"version" / Default(Int8ul, 4),
"category" / EPICCategory,
"type" / Hex(Int16ul),
"type" / EPICSubtype,
"timestamp" / Default(Int64ul, 0),
"seq" / Int16ul,
"unk" / Default(Hex(Int16ul), 0),
"inline_len" / Hex(Int32ul),
)
# dcp's announce
EPICAnnounce = Struct(
"name" / Padded(32, CString("utf8")),
"props" / Optional(OSSerialize())
)
# aop's announce
EPICServiceAnnounce = Struct(
"name" / Padded(20, CString("utf8")),
"unk1" / Hex(Int32ul),
"retcode" / Hex(Int32ul), # 0xE00002C2
"unk3" / Hex(Int32ul),
"channel" / Hex(Int32ul),
"unk5" / Hex(Int32ul),
"unk6" / Hex(Int32ul),
)
EPICSetProp = Struct(
"name_len" / Int32ul,
"name" / Aligned(4, CString("utf8")),
@ -234,7 +252,7 @@ class EPICEndpoint(AFKRingBufEndpoint):
self.asc.work()
def handle_report(self, hdr, sub, fd):
if sub.type == 0x30:
if sub.type == EPICSubtype.ANNOUNCE: # dcp's announce
init = EPICAnnounce.parse_stream(fd)
if init.props is None:
init.props = {}
@ -253,6 +271,22 @@ class EPICEndpoint(AFKRingBufEndpoint):
self.log(f"New service: {key} on channel {hdr.channel} (short name: {short})")
else:
self.log(f"Unknown service {key} on channel {hdr.channel}")
elif sub.type == EPICSubtype.STD_SERVICE: # aop's announce
props = EPICServiceAnnounce.parse_stream(fd)
name = props.name
key = props.name
chan = props.channel # aop uses channel parsed from prop, not from header
if name in self.serv_names:
srv = self.serv_names[name](self)
short = srv.SHORT # aop has no EPICUnit stuff
#setattr(self, short, srv)
srv.init(props)
srv.chan = chan
self.chan_map[chan] = srv
self.serv_map[key] = srv
self.log(f"New service: {key} on channel {chan} (short name: {short})")
else:
self.log(f"Unknown service {key} on channel {chan}")
else:
if hdr.channel not in self.chan_map:
self.log(f"Ignoring report on channel {hdr.channel}")