Mirrors/m1n1
2
0
Fork 0
mirror of https://github.com/AsahiLinux/m1n1 synced 2025-02-16 05:38:29 +00:00
Code Issues Projects Releases Packages Wiki Activity

m1n1.fw.afk: Add more hello handlers used by aop

Browse source 
Signed-off-by: Eileen Yoon <eyn@gmx.com>
This commit is contained in:
Eileen Yoon 2024-01-21 02:30:04 +09:00 • committed by Hector Martin
parent eb3710edb1
commit bf5a3a6e98
1 changed files with 25 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
proxyclient/m1n1/fw/afk/rbep.py
View file

@ -150,11 +150,30 @@ class AFKRingBufEndpoint(ASCBaseEndpoint):
def start(self): def start(self):
self.send(AFKEP_Init()) self.send(AFKEP_Init())
def stop(self):
self.log("Shutting down")
self.send(AFKEP_Shutdown())
while self.alive:
self.asc.work()
@msg_handler(0xa0, AFKEP_Init_Ack) @msg_handler(0xa0, AFKEP_Init_Ack)
def Init_Ack(self, msg): def Init_Ack(self, msg):
self.alive = True self.alive = True
return True return True
@msg_handler(0xc1, AFKEP_Shutdown_Ack)
def Shutdown_Ack(self, msg):
self.alive = False
self.log("Shutdown ACKed")
return True
@msg_handler(0x80, AFKEP_Init)
def Hello(self, msg):
self.rxbuf, self.rxbuf_dva = self.asc.ioalloc(0x10000)
self.txbuf, self.txbuf_dva = self.asc.ioalloc(0x10000)
self.send(AFKEP_Init_Ack())
return True
@msg_handler(0x89, AFKEP_GetBuf) @msg_handler(0x89, AFKEP_GetBuf)
def GetBuf(self, msg): def GetBuf(self, msg):
size = msg.SIZE * AFKRingBuf.BLOCK_SIZE size = msg.SIZE * AFKRingBuf.BLOCK_SIZE
@ -168,18 +187,6 @@ class AFKRingBufEndpoint(ASCBaseEndpoint):
self.log(f"Buffer: phys={self.iobuffer:#x} dva={self.iobuffer_dva:#x} size={size:#x}") self.log(f"Buffer: phys={self.iobuffer:#x} dva={self.iobuffer_dva:#x} size={size:#x}")
return True return True
def stop(self):
self.log("Shutting down")
self.send(AFKEP_Shutdown())
while self.alive:
self.asc.work()
@msg_handler(0xc1, AFKEP_Shutdown_Ack)
def Shutdown_Ack(self, msg):
self.alive = False
self.log("Shutdown ACKed")
return True
@msg_handler(0x8a, AFKEP_InitRB) @msg_handler(0x8a, AFKEP_InitRB)
def InitTX(self, msg): def InitTX(self, msg):
self.txq = self.init_rb(msg) self.txq = self.init_rb(msg)
@ -194,10 +201,13 @@ class AFKRingBufEndpoint(ASCBaseEndpoint):
self.start_queues() self.start_queues()
return True return True
@msg_handler(0x8c, AFKEP_InitRB)
def InitUnk(self, msg):
return True # no op
def init_rb(self, msg): def init_rb(self, msg):
off = msg.OFFSET * AFKRingBuf.BLOCK_SIZE off = msg.OFFSET * AFKRingBuf.BLOCK_SIZE
size = msg.SIZE * AFKRingBuf.BLOCK_SIZE size = msg.SIZE * AFKRingBuf.BLOCK_SIZE
return AFKRingBuf(self, self.iobuffer + off, size) return AFKRingBuf(self, self.iobuffer + off, size)
def start_queues(self): def start_queues(self):