Guest User

Untitled

a guest
Nov 13th, 2011
145
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.69 KB | None | 0 0
  1. 354 context = zmq.Context()
  2. 355 socket = context.socket(zmq.REQ)
  3. 356 socket.connect('tcp://{0[interface]}:{0[ret_port]}'.format(self.opts))
  4. 357 socket.send(package)
  5. 358 payload = None
  6. 359 for ind in range(50):
  7. 360 try:
  8. 361 payload = salt.payload.unpackage(socket.recv(zmq.NOBLOCK))
  9. 362 break
  10. 363 except zmq.core.error.ZMQError:
  11. 364 print ind
  12. 365 time.sleep(0.01)
  13. 366 print payload
  14. 367 if not payload:
  15. 368 return {'jid': 0, 'minions': []}
  16. 369 return {'jid': payload['load']['jid'],
  17. 370 'minions': minions}
  18.  
  19.  
Advertisement
Add Comment
Please, Sign In to add comment