# Path: tuskar/openstack/common/excutils.py
# def save_and_reraise_exception():
# 
# Path: tuskar/openstack/common/gettextutils.py
# def _(msg):
#     return _t.ugettext(msg)
# 
# Path: tuskar/openstack/common/importutils.py
# def import_class(import_str):
# def import_object(import_str, *args, **kwargs):
# def import_object_ns(name_space, import_str, *args, **kwargs):
# def import_module(import_str):
# def try_import(import_str, default=None):
# 
# Path: tuskar/openstack/common/jsonutils.py
# def to_primitive(value, convert_instances=False, convert_datetime=True,
#                  level=0, max_depth=3):
# def dumps(value, default=to_primitive, **kwargs):
# def loads(s):
# def load(s):
# 
# Path: tuskar/openstack/common/processutils.py
# LOG = logging.getLogger(__name__)
#             _PIPE = subprocess.PIPE  # pylint: disable=E1101
# class InvalidArgumentError(Exception):
# class UnknownArgumentError(Exception):
# class ProcessExecutionError(Exception):
# class NoRootWrapSpecified(Exception):
#     def __init__(self, message=None):
#     def __init__(self, message=None):
#     def __init__(self, stdout=None, stderr=None, exit_code=None, cmd=None,
#                  description=None):
#     def __init__(self, message=None):
# def _subprocess_setup():
# def execute(*cmd, **kwargs):
# def trycmd(*args, **kwargs):
# def ssh_execute(ssh, cmd, process_input=None,
#                 addl_env=None, check_exit_code=True):
# 
# Path: tuskar/openstack/common/rpc/common.py
# CONF = cfg.CONF
# LOG = logging.getLogger(__name__)
# _RPC_ENVELOPE_VERSION = '2.0'
# _VERSION_KEY = 'oslo.version'
# _MESSAGE_KEY = 'oslo.message'
#     SANITIZE = {'set_admin_password': [('args', 'new_pass')],
#                 'run_instance': [('args', 'admin_password')],
#                 'route_message': [('args', 'message', 'args', 'method_info',
#                                    'method_kwargs', 'password'),
#                                   ('args', 'message', 'args', 'method_info',
#                                    'method_kwargs', 'admin_password')]}
# class RPCException(Exception):
# class RemoteError(RPCException):
# class Timeout(RPCException):
# class DuplicateMessageError(RPCException):
# class InvalidRPCConnectionReuse(RPCException):
# class UnsupportedRpcVersion(RPCException):
# class UnsupportedRpcEnvelopeVersion(RPCException):
# class RpcVersionCapError(RPCException):
# class Connection(object):
# class CommonRpcContext(object):
# class ClientException(Exception):
#     def __init__(self, message=None, **kwargs):
#     def __init__(self, exc_type=None, value=None, traceback=None):
#     def __init__(self, info=None, topic=None, method=None):
#     def close(self):
#     def create_consumer(self, topic, proxy, fanout=False):
#     def create_worker(self, topic, proxy, pool_name):
#     def join_consumer_pool(self, callback, pool_name, topic, exchange_name):
#     def consume_in_thread(self):
# def _safe_log(log_func, msg, msg_data):
# def serialize_remote_exception(failure_info, log_failure=True):
# def deserialize_remote_exception(conf, data):
#     def __init__(self, **kwargs):
#     def __getattr__(self, key):
#     def to_dict(self):
#     def from_dict(cls, values):
#     def deepcopy(self):
#     def update_store(self):
#     def elevated(self, read_deleted=None, overwrite=False):
#     def __init__(self):
# def catch_client_exception(exceptions, func, *args, **kwargs):
# def client_exceptions(*exceptions):
#     def outer(func):
#         def inner(*args, **kwargs):
# def version_is_compatible(imp_version, version):
# def serialize_msg(raw_msg):
# def deserialize_msg(msg):


import os
import pprint
import re
import socket
import sys
import types
import uuid
import eventlet
import greenlet
from oslo.config import cfg
from tuskar.openstack.common import excutils
from tuskar.openstack.common.gettextutils import _
from tuskar.openstack.common import importutils
from tuskar.openstack.common import jsonutils
from tuskar.openstack.common import processutils as utils
from tuskar.openstack.common.rpc import common as rpc_common
# vim: tabstop=4 shiftwidth=4 softtabstop=4

#    Copyright 2011 Cloudscaling Group, Inc
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.




zmq = importutils.try_import('eventlet.green.zmq')

# for convenience, are not modified.
pformat = pprint.pformat
Timeout = eventlet.timeout.Timeout

# Path: tuskar/openstack/common/excutils.py
# def save_and_reraise_exception():
# 
# Path: tuskar/openstack/common/gettextutils.py
# def _(msg):
#     return _t.ugettext(msg)
# 
# Path: tuskar/openstack/common/importutils.py
# def import_class(import_str):
# def import_object(import_str, *args, **kwargs):
# def import_object_ns(name_space, import_str, *args, **kwargs):
# def import_module(import_str):
# def try_import(import_str, default=None):
# 
# Path: tuskar/openstack/common/jsonutils.py
# def to_primitive(value, convert_instances=False, convert_datetime=True,
#                  level=0, max_depth=3):
# def dumps(value, default=to_primitive, **kwargs):
# def loads(s):
# def load(s):
# 
# Path: tuskar/openstack/common/processutils.py
# LOG = logging.getLogger(__name__)
#             _PIPE = subprocess.PIPE  # pylint: disable=E1101
# class InvalidArgumentError(Exception):
# class UnknownArgumentError(Exception):
# class ProcessExecutionError(Exception):
# class NoRootWrapSpecified(Exception):
#     def __init__(self, message=None):
#     def __init__(self, message=None):
#     def __init__(self, stdout=None, stderr=None, exit_code=None, cmd=None,
#                  description=None):
#     def __init__(self, message=None):
# def _subprocess_setup():
# def execute(*cmd, **kwargs):
# def trycmd(*args, **kwargs):
# def ssh_execute(ssh, cmd, process_input=None,
#                 addl_env=None, check_exit_code=True):
# 
# Path: tuskar/openstack/common/rpc/common.py
# CONF = cfg.CONF
# LOG = logging.getLogger(__name__)
# _RPC_ENVELOPE_VERSION = '2.0'
# _VERSION_KEY = 'oslo.version'
# _MESSAGE_KEY = 'oslo.message'
#     SANITIZE = {'set_admin_password': [('args', 'new_pass')],
#                 'run_instance': [('args', 'admin_password')],
#                 'route_message': [('args', 'message', 'args', 'method_info',
#                                    'method_kwargs', 'password'),
#                                   ('args', 'message', 'args', 'method_info',
#                                    'method_kwargs', 'admin_password')]}
# class RPCException(Exception):
# class RemoteError(RPCException):
# class Timeout(RPCException):
# class DuplicateMessageError(RPCException):
# class InvalidRPCConnectionReuse(RPCException):
# class UnsupportedRpcVersion(RPCException):
# class UnsupportedRpcEnvelopeVersion(RPCException):
# class RpcVersionCapError(RPCException):
# class Connection(object):
# class CommonRpcContext(object):
# class ClientException(Exception):
#     def __init__(self, message=None, **kwargs):
#     def __init__(self, exc_type=None, value=None, traceback=None):
#     def __init__(self, info=None, topic=None, method=None):
#     def close(self):
#     def create_consumer(self, topic, proxy, fanout=False):
#     def create_worker(self, topic, proxy, pool_name):
#     def join_consumer_pool(self, callback, pool_name, topic, exchange_name):
#     def consume_in_thread(self):
# def _safe_log(log_func, msg, msg_data):
# def serialize_remote_exception(failure_info, log_failure=True):
# def deserialize_remote_exception(conf, data):
#     def __init__(self, **kwargs):
#     def __getattr__(self, key):
#     def to_dict(self):
#     def from_dict(cls, values):
#     def deepcopy(self):
#     def update_store(self):
#     def elevated(self, read_deleted=None, overwrite=False):
#     def __init__(self):
# def catch_client_exception(exceptions, func, *args, **kwargs):
# def client_exceptions(*exceptions):
#     def outer(func):
#         def inner(*args, **kwargs):
# def version_is_compatible(imp_version, version):
# def serialize_msg(raw_msg):
# def deserialize_msg(msg):


# Path: tuskar/openstack/common/rpc/impl_zmq.py
import os
import pprint
import re
import socket
import sys
import types
import uuid
import eventlet
import greenlet
from oslo.config import cfg
from tuskar.openstack.common import excutils
from tuskar.openstack.common.gettextutils import _
from tuskar.openstack.common import importutils
from tuskar.openstack.common import jsonutils
from tuskar.openstack.common import processutils as utils
from tuskar.openstack.common.rpc import common as rpc_common

# vim: tabstop=4 shiftwidth=4 softtabstop=4

#    Copyright 2011 Cloudscaling Group, Inc
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.




zmq = importutils.try_import('eventlet.green.zmq')

# for convenience, are not modified.
pformat = pprint.pformat
Timeout = eventlet.timeout.Timeout

LOG = rpc_common.LOG