We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 0021efc + c92e68e commit e17f3f8Copy full SHA for e17f3f8
src/DIRAC/Core/DISET/private/MessageBroker.py
@@ -134,6 +134,7 @@ def __listenAutoReceiveConnections(self):
134
continue
135
sel.register(mt["transport"].getSocket(), selectors.EVENT_READ, trid)
136
if not sel.get_map():
137
+ sel.close()
138
self.__listeningForMessages = False
139
return
140
finally:
@@ -148,6 +149,8 @@ def __listenAutoReceiveConnections(self):
148
149
except Exception as e:
150
gLogger.exception("Exception while selecting persistent connections", lException=e)
151
152
+ finally:
153
154
155
for key, event in events:
156
if event & selectors.EVENT_READ:
0 commit comments