Did I find the right examples for you? yes no

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

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/proxy.py   cloudbase-init(Download)
        except rpc.common.Timeout as exc:
            raise rpc.common.Timeout(
                exc.info, real_topic, msg.get('method'))
 
    def multicall(self, context, msg, topic=None, version=None, timeout=None):
        except rpc.common.Timeout as exc:
            raise rpc.common.Timeout(
                exc.info, real_topic, msg.get('method'))
 
    def cast(self, context, msg, topic=None, version=None):

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/impl_zmq.py   cloudbase-init(Download)
        # While not strictly a timeout, callers know how to handle
        # this exception and a timeout isn't too big a lie.
        raise rpc_common.Timeout(_("No match from matchmaker."))
 
    # This supports brokerless fanout (addresses > 1)

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/impl_fake.py   cloudbase-init(Download)
                if (cur_time - start_time) > timeout:
                    thread.kill()
                    raise rpc_common.Timeout()
 
        return done.wait()
        consumer = CONSUMERS[topic][0]
    except (KeyError, IndexError):
        raise rpc_common.Timeout("No consumers available")
    else:
        return consumer.call(context, version, method, namespace, args,

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/amqp.py   cloudbase-init(Download)
            except queue.Empty:
                self.done()
                raise rpc_common.Timeout()
            except Exception:
                with excutils.save_and_reraise_exception():

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/impl_kombu.py   cloudbase-init(Download)
        def _error_callback(exc):
            if isinstance(exc, socket.timeout):
                LOG.debug(_('Timed out waiting for RPC response: %s') %
                          str(exc))
                raise rpc_common.Timeout()

src/c/l/cloudbase-init-HEAD/cloudbaseinit/openstack/common/rpc/impl_qpid.py   cloudbase-init(Download)
        def _error_callback(exc):
            if isinstance(exc, qpid_exceptions.Empty):
                LOG.debug(_('Timed out waiting for RPC response: %s') %
                          str(exc))
                raise rpc_common.Timeout()