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

hv/trace_dcp: Fix afk/epic API breakage

Browse source 
Signed-off-by: Eileen Yoon <eyn@gmx.com>
This commit is contained in:
Eileen Yoon 2024-01-23 23:33:19 +09:00 committed by Hector Martin
parent 7298f42ce7
commit a4fb7af657
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
proxyclient/hv/trace_dcp.py
View file

@ -58,7 +58,7 @@ class AFKRingBufSniffer(AFKRingBuf):
raise NotImplementedError() raise NotImplementedError()
def get_wptr(self): def get_wptr(self):
return struct.unpack("<I", self.read_buf(2 * self.BLOCK_SIZE, 4))[0] return struct.unpack("<I", self.read_buf(2 * self.BLOCK_STEP, 4))[0]
def read_buf(self, off, size): def read_buf(self, off, size):
return self.ep.dart.ioread(self.ep.stream, self.base + off, size) return self.ep.dart.ioread(self.ep.stream, self.base + off, size)
@ -144,15 +144,15 @@ class AFKEp(EP):
@msg(0x8a, DIR.RX, AFKEP_InitRB) @msg(0x8a, DIR.RX, AFKEP_InitRB)
def InitTX(self, msg): def InitTX(self, msg):
off = msg.OFFSET * AFKRingBuf.BLOCK_SIZE off = msg.OFFSET * AFKRingBuf.BLOCK_STEP
size = msg.SIZE * AFKRingBuf.BLOCK_SIZE size = msg.SIZE * AFKRingBuf.BLOCK_STEP
self.state.txbuf_info = (off, size) self.state.txbuf_info = (off, size)
self.create_bufs() self.create_bufs()
@msg(0x8b, DIR.RX, AFKEP_InitRB) @msg(0x8b, DIR.RX, AFKEP_InitRB)
def InitRX(self, msg): def InitRX(self, msg):
off = msg.OFFSET * AFKRingBuf.BLOCK_SIZE off = msg.OFFSET * AFKRingBuf.BLOCK_STEP
size = msg.SIZE * AFKRingBuf.BLOCK_SIZE size = msg.SIZE * AFKRingBuf.BLOCK_STEP
self.state.rxbuf_info = (off, size) self.state.rxbuf_info = (off, size)
self.create_bufs() self.create_bufs()
@ -307,7 +307,7 @@ class EPICEp(AFKEp):
sub = EPICSubHeader.parse_stream(fd) sub = EPICSubHeader.parse_stream(fd)
self.log(f"{dir}Ch {hdr.channel} Type {hdr.type} Ver {hdr.version} Tag {hdr.seq}") self.log(f"{dir}Ch {hdr.channel} Type {hdr.type} Ver {hdr.version} Tag {hdr.seq}")
self.log(f" Len {sub.length} Ver {sub.version} Cat {sub.category} Type {sub.type:#x} Seq {sub.seq}") self.log(f" Len {sub.length} Ver {sub.version} Cat {sub.category} Type {int(sub.type):#x}/{sub.type} Seq {sub.seq}")
# chexdump(data, print_fn=self.log) # chexdump(data, print_fn=self.log)
if sub.category == EPICCategory.REPORT: if sub.category == EPICCategory.REPORT: