def NewConnection(self, path, fd, properties):
self.fd = fd.take()
print("NewConnection(%s, %d)" % (path, self.fd))
server_sock = socket.fromfd(self.fd, socket.AF_UNIX, socket.SOCK_STREAM)
server_sock.setblocking(1)
server_sock.send("This is Edison SPP loopback test\nAll data will be loopback\nPlease start:\n")
myfifo.openFifo()
print('enter recv loop\n')
try:
while True:
data = server_sock.recv(1024)
print("received: %s" % data)
myfifo.writeFifo(data)
#server_sock.send("looping back: %s\n" % data)
except IOError as err:
print (err)
pass
server_sock.close()
print("all done")
评论列表
文章目录