def handle_write(self):
while len(self.buffer) > 0:
payload, params = self.buffer.pop(0)
sndrcvinfo = sctp.sndrcvinfo()
sndrcvinfo.ppid = socket.htonl(params.get('ppid',0))
fromaddr,flags,msg,notif="",128,payload[:1460],sndrcvinfo
sent = self.sctp_send(msg,ppid=sndrcvinfo.ppid,flags=notif.flags)
评论列表
文章目录