Backups/multi-user
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(client): close #74

Browse Source
This commit is contained in:
Swann Martinez
2019-05-02 16:05:06 +02:00
parent d454c95a9b
commit 5ae044bd31
2 changed files with 6 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
client.py
View File

@ -96,6 +96,7 @@ class RCFClient(object):
id, str) else id), (address.encode() if isinstance( id, str) else id), (address.encode() if isinstance(
address, str) else address), b'%d' % port]) address, str) else address), b'%d' % port])
def init(self): def init(self):
""" """
Scene initialisation Scene initialisation
@ -111,7 +112,6 @@ class RCFClient(object):
self.pipe.send_multipart( self.pipe.send_multipart(
[b"DISCONNECT"]) [b"DISCONNECT"])
def set(self, key, value=None, override=False): def set(self, key, value=None, override=False):
"""Set new value in distributed hash table """Set new value in distributed hash table
Sends [SET][key][value] to the agent Sends [SET][key][value] to the agent
@ -145,6 +145,7 @@ class RCFClient(object):
else: else:
return True return True
def exit(self): def exit(self):
if self.net_agent.is_alive(): if self.net_agent.is_alive():
self.disconnect() self.disconnect()
@ -171,16 +172,7 @@ class RCFClient(object):
value.append([k, self.store.get(k).body]) value.append([k, self.store.get(k).body])
return value return value
# if not self.is_busy():
# self.pipe.send_multipart([b"GET", umsgpack.packb(key)])
# try:
# reply = self.pipe.recv_multipart()
# except KeyboardInterrupt:
# return
# else:
# return umsgpack.unpackb(reply[0])
# else:
# return None
def list(self): def list(self):
dump_list = [] dump_list = []
@ -194,16 +186,6 @@ class RCFClient(object):
pass pass
return dump_list return dump_list
# if not self.is_busy():
# self.pipe.send_multipart([b"LIST"])
# try:
# reply = self.pipe.recv_multipart()
# except KeyboardInterrupt:
# return
# else:
# return umsgpack.unpackb(reply[0])
# else:
# return None
def state(self): def state(self):
if not self.is_busy(): if not self.is_busy():

5
operators.py
View File

@ -199,14 +199,14 @@ def register_ticks():
# REGISTER Updaters # REGISTER Updaters
bpy.app.timers.register(draw_tick) bpy.app.timers.register(draw_tick)
bpy.app.timers.register(sync) bpy.app.timers.register(sync)
bpy.app.timers.register(default_tick) # bpy.app.timers.register(default_tick)
pass pass
def unregister_ticks(): def unregister_ticks():
# REGISTER Updaters # REGISTER Updaters
global drawer global drawer
drawer.unregister_handlers() drawer.unregister_handlers()
bpy.app.timers.unregister(draw_tick) # bpy.app.timers.unregister(draw_tick)
bpy.app.timers.unregister(sync) bpy.app.timers.unregister(sync)
bpy.app.timers.unregister(default_tick) bpy.app.timers.unregister(default_tick)
pass pass
@ -562,6 +562,7 @@ def depsgraph_update(scene):
username = bpy.context.scene.session_settings.username username = bpy.context.scene.session_settings.username
update_selected_object(bpy.context) update_selected_object(bpy.context)
# selected_objects = helpers.get_selected_objects(scene) # selected_objects = helpers.get_selected_objects(scene)