def __init__(self, peer="127.0.0.1"):
SuperSocket.__init__(self, socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
self.outs = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
self.tx_addr = (peer, 52001)
self.rx_addr = (peer, 52002)
self.ins.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
self.outs.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
try:
self.ins.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
self.outs.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
except AttributeError:
pass
self.ins.bind(self.rx_addr)
评论列表
文章目录