Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import socketserver as soss
- import testhostmain as hmain
- import multiprocessing as mp
- def joinpacket(flag, data):
- return f"{flag}{hmain.packetdelim}{data}"
- def splitpacket(msg):
- msg = msg.split(hmain.packetdelim)
- flag, data = msg[0], msg[1]
- return flag, data
- class ConnHandler(soss.BaseRequestHandler):
- def handle(self):
- # request handler to spawn processes
- print(hmain.servermanager, "in connhandler")
- # collecting peritype and name
- msg = self.request.recv(hmain.buffer).decode("utf-8")
- flag, data = splitpacket(msg)
- data = data.split(hmain.datadelim)
- self.peritype, self.macid = data[0], data[1]
- #print(data)
- # checks the header flag
- if flag == hmain.newconflag:
- hmain.servermanager.procdict[self.macid] = "connected"
- print(hmain.servermanager.procdict, "from connhandler")
Add Comment
Please, Sign In to add comment