ionelmc / python-manhole

                    wait_for_strings(client.read, TIMEOUT, '3579')

def test_sig_usr2():

    with TestProcess(sys.executable, '-u', HELPER, 'test_oneshot_on_usr2') as service:

        with dump_on_error(service.read):

            wait_for_strings(service.read, TIMEOUT,

                             'Not patching os.fork and os.forkpty. Oneshot activation is done by signal')

            with TestProcess('manhole-cli', '--signal=USR2', str(service.proc.pid), bufsize=0,

                             stdin=subprocess.PIPE) as client:

                with dump_on_error(client.read):

                    wait_for_strings(client.read, TIMEOUT, '(ManholeConsole)', '>>>')

                    client.proc.stdin.write(b"1234+2345\n")

                    wait_for_strings(client.read, TIMEOUT, '3579')

def test_sig_usr2_full():

                    wait_for_strings(client.read, TIMEOUT, '3579')

def test_path():

    with TestProcess(sys.executable, HELPER, 'test_simple') as service:

        with dump_on_error(service.read):

            wait_for_strings(service.read, TIMEOUT, '/tmp/manhole-')

            with TestProcess('manhole-cli', '/tmp/manhole-%s' % service.proc.pid, bufsize=0,

                             stdin=subprocess.PIPE) as client:

                with dump_on_error(client.read):

                    wait_for_strings(client.read, TIMEOUT, '(ManholeConsole)', '>>>')

                    client.proc.stdin.write(b"1234+2345\n")

                    wait_for_strings(client.read, TIMEOUT, '3579')

def test_sig_usr2():

                    wait_for_strings(client.read, TIMEOUT, '3579')

def test_sig_usr2_number():

    with TestProcess(sys.executable, '-u', HELPER, 'test_oneshot_on_usr2') as service:

        with dump_on_error(service.read):

            wait_for_strings(service.read, TIMEOUT,

                             'Not patching os.fork and os.forkpty. Oneshot activation is done by signal')

            with TestProcess('manhole-cli', '-s', str(int(signal.SIGUSR2)), str(service.proc.pid), bufsize=0,

                             stdin=subprocess.PIPE) as client:

                with dump_on_error(client.read):

                    wait_for_strings(client.read, TIMEOUT, '(ManholeConsole)', '>>>')

                    client.proc.stdin.write(b"1234+2345\n")

                    wait_for_strings(client.read, TIMEOUT, '3579')