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

fix: snapshot command store

Browse Source
This commit is contained in:
Swann
2019-07-23 11:49:38 +02:00
parent eec0d899dc
commit 4f51941b36
2 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
replication_client.py
View File

@ -164,8 +164,8 @@ class ClientNetService(threading.Thread):
if 'SNAPSHOT_END' in datablock.buffer: if 'SNAPSHOT_END' in datablock.buffer:
self.state = STATE_ACTIVE self.state = STATE_ACTIVE
logger.debug('{} : snapshot done'.format(self._id)) logger.debug('{} : snapshot done'.format(self._id))
else:
datablock.store(self._store_reference) datablock.store(self._store_reference)
# We receive updates from the server ! # We receive updates from the server !
if self.subscriber in items: if self.subscriber in items:

9
test_replication.py
View File

@ -183,13 +183,20 @@ class TestClient(unittest.TestCase):
test_map_result = SampleData() test_map_result = SampleData()
#Waiting for server to receive the datas #Waiting for server to receive the datas
time.sleep(1) time.sleep(.1)
client2._rep_store[data_sample_key].load(target=test_map_result) client2._rep_store[data_sample_key].load(target=test_map_result)
client.unregister(data_sample_key) client.unregister(data_sample_key)
time.sleep(.1)
logger.debug("client store:")
logger.debug(client._rep_store) logger.debug(client._rep_store)
logger.debug("client2 store:")
logger.debug(client2._rep_store)
logger.debug("server store:")
logger.debug(server._rep_store)
client.disconnect() client.disconnect()
client2.disconnect() client2.disconnect()
server.stop() server.stop()