(self, m)
Decorate a message with a reply attribute, and send it to the
            master.  then wait for a response.
Decorate a message with a reply attribute, and send it to the
            master.  then wait for a response.
Decorate a message with a reply attribute and send it to the master . then wait for a response .
def ask(self, m):
        """
            Decorate a message with a reply attribute, and send it to the
            master.  then wait for a response.
        """
        m.reply = Reply(m)
        self.q.put(m)
        while not should_exit:
            try:
                # The timeout is here so we can handle a should_exit event.
                g = m.reply.q.get(timeout=0.5)
            except Queue.Empty: # pragma: nocover
                continue
            return g
def ask ( self , m ) : m . reply = Reply ( m ) self . q . put ( m ) while not should_exit : try : # The timeout is here so we can handle a should_exit event. g = m . reply . q . get ( timeout = 0.5 ) except Queue . Empty : # pragma: nocover continue return g