Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class ContainerFS():
- def sync(self):
- #contains stuffs, has its methods
- pass
- def dump(self):
- stuff()
- class DataManager(BaseManager):
- def get_data(self):
- pass
- class DataProcess(Process):
- def __init__(self, serverobj, authkey, public=False, port=11111):
- Process.__init__(self)
- self.authkey = authkey
- self.Obj = serverobj
- self.daemon = True
- self.port = port
- self.addr = '127.0.0.1'
- if public:
- self.addr = '0.0.0.0'
- def run(self):
- DataManager.register('get_data',
- callable=lambda: self.Obj)
- manager = DataManager(
- address=(self.addr, self.port),
- authkey=self.authkey)
- srv = datamgr.get_server()
- srv.serve_forever()
- class DataClient(object):
- def __init__(self):
- pass
- def create(self, authkey):
- try:
- DataManager.register('get_data')
- self.m = DataManager(address=('127.0.0.1', 11111), authkey=authkey)
- return True
- except:
- return False
- def connect(self):
- try:
- self.m.connect()
- q = self.m.get_data()
- return q
- except:
- return False
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement