import quincy beta 17.1.0

[ceph.git] / ceph / src / jaegertracing / thrift / test / crossrunner / test.py

diff --git a/ceph/src/jaegertracing/thrift/test/crossrunner/test.py b/ceph/src/jaegertracing/thrift/test/crossrunner/test.py
deleted file mode 100644 (file)
index 0e91284..0000000
--- a/ceph/src/jaegertracing/thrift/test/crossrunner/test.py
+++ /dev/null
@@ -1,149 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you 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.
-#
-
-import copy
-import multiprocessing
-import os
-import sys
-from .compat import path_join
-from .util import merge_dict, domain_socket_path
-
-
-class TestProgram(object):
-    def __init__(self, kind, name, protocol, transport, socket, workdir, stop_signal, command, env=None,
-                 extra_args=[], extra_args2=[], join_args=False, **kwargs):
-
-        self.kind = kind
-        self.name = name
-        self.protocol = protocol
-        self.transport = transport
-        self.socket = socket
-        self.workdir = workdir
-        self.stop_signal = stop_signal
-        self.command = None
-        self._base_command = self._fix_cmd_path(command)
-        if env:
-            self.env = copy.copy(os.environ)
-            self.env.update(env)
-        else:
-            self.env = os.environ
-        self._extra_args = extra_args
-        self._extra_args2 = extra_args2
-        self._join_args = join_args
-
-    def _fix_cmd_path(self, cmd):
-        # if the arg is a file in the current directory, make it path
-        def abs_if_exists(arg):
-            p = path_join(self.workdir, arg)
-            return p if os.path.exists(p) else arg
-
-        if cmd[0] == 'python':
-            cmd[0] = sys.executable
-        else:
-            cmd[0] = abs_if_exists(cmd[0])
-        return cmd
-
-    def _socket_args(self, socket, port):
-        return {
-            'ip-ssl': ['--ssl'],
-            'domain': ['--domain-socket=%s' % domain_socket_path(port)],
-            'abstract': ['--abstract-namespace', '--domain-socket=%s' % domain_socket_path(port)],
-        }.get(socket, None)
-
-    def _transport_args(self, transport):
-        return {
-            'zlib': ['--zlib'],
-        }.get(transport, None)
-
-    def build_command(self, port):
-        cmd = copy.copy(self._base_command)
-        args = copy.copy(self._extra_args2)
-        args.append('--protocol=' + self.protocol)
-        args.append('--transport=' + self.transport)
-        transport_args = self._transport_args(self.transport)
-        if transport_args:
-            args += transport_args
-        socket_args = self._socket_args(self.socket, port)
-        if socket_args:
-            args += socket_args
-        args.append('--port=%d' % port)
-        if self._join_args:
-            cmd.append('%s' % " ".join(args))
-        else:
-            cmd.extend(args)
-        if self._extra_args:
-            cmd.extend(self._extra_args)
-        self.command = cmd
-        return self.command
-
-
-class TestEntry(object):
-    def __init__(self, testdir, server, client, delay, timeout, **kwargs):
-        self.testdir = testdir
-        self._log = multiprocessing.get_logger()
-        self._config = kwargs
-        self.protocol = kwargs['protocol']
-        self.transport = kwargs['transport']
-        self.socket = kwargs['socket']
-        srv_dict = self._fix_workdir(merge_dict(self._config, server))
-        cli_dict = self._fix_workdir(merge_dict(self._config, client))
-        cli_dict['extra_args2'] = srv_dict.pop('remote_args', [])
-        srv_dict['extra_args2'] = cli_dict.pop('remote_args', [])
-        self.server = TestProgram('server', **srv_dict)
-        self.client = TestProgram('client', **cli_dict)
-        self.delay = delay
-        self.timeout = timeout
-        self._name = None
-        # results
-        self.success = None
-        self.as_expected = None
-        self.returncode = None
-        self.expired = False
-        self.retry_count = 0
-
-    def _fix_workdir(self, config):
-        key = 'workdir'
-        path = config.get(key, None)
-        if not path:
-            path = self.testdir
-        if os.path.isabs(path):
-            path = os.path.realpath(path)
-        else:
-            path = os.path.realpath(path_join(self.testdir, path))
-        config.update({key: path})
-        return config
-
-    @classmethod
-    def get_name(cls, server, client, protocol, transport, socket, *args, **kwargs):
-        return '%s-%s_%s_%s-%s' % (server, client, protocol, transport, socket)
-
-    @property
-    def name(self):
-        if not self._name:
-            self._name = self.get_name(
-                self.server.name, self.client.name, self.protocol, self.transport, self.socket)
-        return self._name
-
-    @property
-    def transport_name(self):
-        return '%s-%s' % (self.transport, self.socket)
-
-
-def test_name(server, client, protocol, transport, socket, **kwargs):
-    return TestEntry.get_name(server['name'], client['name'], protocol, transport, socket)