Advertisement
Guest User

Untitled

a guest
Feb 12th, 2016
52
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.26 KB | None | 0 0
  1. class ContainerFS():
  2. def sync(self):
  3. #contains stuffs, has its methods
  4. pass
  5. def dump(self):
  6. stuff()
  7.  
  8. class DataManager(BaseManager):
  9. def get_data(self):
  10. pass
  11.  
  12.  
  13. class DataProcess(Process):
  14. def __init__(self, serverobj, authkey, public=False, port=11111):
  15. Process.__init__(self)
  16. self.authkey = authkey
  17. self.Obj = serverobj
  18. self.daemon = True
  19. self.port = port
  20. self.addr = '127.0.0.1'
  21. if public:
  22. self.addr = '0.0.0.0'
  23.  
  24. def run(self):
  25. DataManager.register('get_data',
  26. callable=lambda: self.Obj)
  27. manager = DataManager(
  28. address=(self.addr, self.port),
  29. authkey=self.authkey)
  30.  
  31. srv = datamgr.get_server()
  32. srv.serve_forever()
  33.  
  34. class DataClient(object):
  35. def __init__(self):
  36. pass
  37.  
  38. def create(self, authkey):
  39. try:
  40. DataManager.register('get_data')
  41. self.m = DataManager(address=('127.0.0.1', 11111), authkey=authkey)
  42. return True
  43. except:
  44. return False
  45.  
  46. def connect(self):
  47. try:
  48. self.m.connect()
  49. q = self.m.get_data()
  50. return q
  51. except:
  52. return False
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement