Merge pull request #10548 from s0undt3ch/hotfix/remove-sockets

Remove existing IPC sockets
This commit is contained in:
Thomas S Hatch 2014-02-18 14:08:49 -07:00
commit cee74334b8

View File

@ -316,10 +316,14 @@ class MinionBase(object):
self.opts['sock_dir'],
'minion_event_{0}_pub.ipc'.format(id_hash)
)
if os.path.exists(epub_sock_path):
os.unlink(epub_sock_path)
epull_sock_path = os.path.join(
self.opts['sock_dir'],
'minion_event_{0}_pull.ipc'.format(id_hash)
)
if os.path.exists(epull_sock_path):
os.unlink(epull_sock_path)
self.epub_sock = self.context.socket(zmq.PUB)