xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-16 18:49:04 +00:00
Code Issues Projects Releases Wiki Activity

Fix getpeername invocation in async

Browse Source
This commit is contained in:
Jarrod Johnson 2024-05-07 17:00:43 -04:00
parent 056a41c985
commit b3e0117944
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
confluent_server/confluent/collective/manager.py
View File

@ -723,7 +723,8 @@ async def try_assimilate(drone, followcount, remote):
log.log({'info': 'Deferring to {0} due to target being a better leader'.format(
drone), 'subsystem': 'collective'})
await retire_as_leader(drone)
if not await connect_to_leader(None, None, leader=remote.getpeername()[0]):
cnn = remote[1].transport.get_extra_info('socket')
if not await connect_to_leader(None, None, leader=cnn.getpeername()[0]):
if retrythread is None:
retrythread = util.spawn_after(random.random(),
start_collective)