diff --git a/confluent_server/confluent/sockapi.py b/confluent_server/confluent/sockapi.py index aa0b8a9f..061317f9 100644 --- a/confluent_server/confluent/sockapi.py +++ b/confluent_server/confluent/sockapi.py @@ -127,6 +127,8 @@ def sessionhdl(connection, authname, skipauth=False, cert=None): while not authenticated: # prompt for name and passphrase send_data(connection, {'authpassed': 0}) response = tlvdata.recv(connection) + if not response: + return if 'collective' in response: return collective.handle_connection(connection, cert, response['collective'])