Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(5)  |  Call(5)  |  Derive(0)  |  Import(0)

src/o/p/openquake-packages-HEAD/pika-0.9.5/pika/adapters/base_connection.py   openquake-packages(Download)
        # Socket is closed, so lets just go to our handle_close method
        elif error_code == errno.EBADF:
            pika.log.error("%s: Socket is closed", self.__class__.__name__)
        else:
            # Haven't run into this one yet, log it.
            pika.log.error("%s: Socket Error on %d: %s",
        """
        if not self.socket:
            pika.log.error("%s: Got events for closed stream %d",
                           self.__class__.__name__, self.socket.fileno())
            return

src/o/p/openquake-packages-HEAD/pika-0.9.5/pika/channel.py   openquake-packages(Download)
            self._basic_get_ok_callback = None
        else:
            pika.log.error("%s._on_basic_get: No callback defined.",
                            self.__class__.__name__)
 
            self._on_flow_ok_callback = None
        else:
            pika.log.error("%s._on_flow_ok: No callback defined.",
                           self.__class__.__name__)