Remove clean up of push socket in publisher to fix race condition

The clean up was causing an inconsistency in the pull socket,
this will need some more refinement, but for now the problem is
fixed
This commit is contained in:
Thomas S Hatch 2013-01-20 00:52:20 -07:00
parent 080ddf14c2
commit c291904a80

View File

@ -1676,17 +1676,10 @@ class ClearFuncs(object):
load['tgt'],
load.get('tgt_type', 'glob')
)
try:
return {
'enc': 'clear',
'load': {
'jid': clear_load['jid'],
'minions': minions
}
return {
'enc': 'clear',
'load': {
'jid': clear_load['jid'],
'minions': minions
}
finally:
if pub_sock.closed is False:
pub_sock.setsockopt(zmq.LINGER, 1)
pub_sock.close()
if context.closed is False:
context.term()
}