minor fix
This commit is contained in:
1 parent
00fec9b46c
commit
20f4cc124d
1 file changed
+4
-4
+4
-4
@@ -64,7 +64,7 @@ def worker_1():
|
|||||||
join_id = (join_ip, join_port, join_timestamp)
|
join_id = (join_ip, join_port, join_timestamp)
|
||||||
|
|
||||||
with members_list_lock:
|
with members_list_lock:
|
||||||
if join_id in dead_ids:
|
if join_id in dead_members:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
if join_id not in members_list:
|
if join_id not in members_list:
|
||||||
@@ -111,13 +111,13 @@ def worker_1():
|
|||||||
incoming_state = member['state']
|
incoming_state = member['state']
|
||||||
incoming_hb = member['heart_beat']
|
incoming_hb = member['heart_beat']
|
||||||
|
|
||||||
if member_id in dead_ids:
|
if member_id in dead_members:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
if member_id not in members_list:
|
if member_id not in members_list:
|
||||||
|
|
||||||
if incoming_state == "failed":
|
if incoming_state == "failed":
|
||||||
dead_ids.add(member_id)
|
dead_members.add(member_id)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
members_list[member_id] = {
|
members_list[member_id] = {
|
||||||
@@ -221,7 +221,7 @@ def worker_4():
|
|||||||
to_remove.append(member_id)
|
to_remove.append(member_id)
|
||||||
|
|
||||||
for member_id in to_remove:
|
for member_id in to_remove:
|
||||||
dead_ids.add(member_id)
|
dead_members.add(member_id)
|
||||||
del members_list[member_id]
|
del members_list[member_id]
|
||||||
|
|
||||||
time.sleep(0.5)
|
time.sleep(0.5)
|
||||||
|
|||||||
Reference in new issue
Block a user