Lines Matching refs:cls
297 def _test_args(cls, q, arg):
313 def _test(cls, q, *args, **kwds):
314 current = cls.current_process()
318 if cls.TYPE != 'threads':
338 def _test_send_parent_process(cls, wconn):
368 def _test_create_grandchild_process(cls, wconn):
369 p = cls.Process(target=cls._test_report_parent_status, args=(wconn, ))
374 def _test_report_parent_status(cls, wconn):
438 def _test_process_mainthread_native_id(cls, q):
443 def _sleep_some(cls):
447 def _test_sleep(cls, delay):
533 def _test_recursion(cls, wconn, id):
537 p = cls.Process(
538 target=cls._test_recursion, args=(wconn, id+[i])
564 def _test_sentinel(cls, event):
584 def _test_close(cls, rc=0, q=None):
888 def _test_stderr_flush(cls, testfn):
895 def _test_sys_exit(cls, reason, testfn):
961 def _test_put(cls, queue, child_can_start, parent_can_continue):
1027 def _test_get(cls, queue, child_can_start, parent_can_continue):
1090 def _test_fork(cls, queue):
1142 def _test_task_done(cls, q):
1363 def f(cls, cond, sleeping, woken, timeout=None):
1559 def _test_waitfor_f(cls, cond, state):
1592 def _test_waitfor_timeout_f(cls, cond, state, success, sem):
1628 def _test_wait_result(cls, c, pid):
1659 def _test_event(cls, event):
1843 def multipass(cls, barrier, results, n):
1845 assert m == cls.N
1873 def _test_wait_return_f(cls, barrier, queue):
1888 def _test_action_f(cls, barrier, results):
1903 def _test_abort_f(cls, barrier, results1, results2):
1906 if i == cls.N//2:
1928 def _test_reset_f(cls, barrier, results1, results2, results3):
1930 if i == cls.N//2:
1932 while barrier.n_waiting < cls.N-1:
1959 def _test_abort_and_reset_f(cls, barrier, barrier2,
1963 if i == cls.N//2:
1974 if barrier2.wait() == cls.N//2:
1996 def _test_timeout_f(cls, barrier, results):
1998 if i == cls.N//2:
2015 def _test_default_timeout_f(cls, barrier, results):
2016 i = barrier.wait(cls.defaultTimeout)
2017 if i == cls.N//2:
2040 def _test_thousand_f(cls, barrier, passes, conn, lock):
2083 def _test(cls, values):
2084 for sv, cv in zip(values, cls.codes_values):
2141 def f(cls, seq):
2395 def __new__(cls):
2396 cls.n_instances += 1
2397 return object.__new__(cls)
2416 def setUpClass(cls):
2418 cls.pool = cls.Pool(4)
2421 def tearDownClass(cls):
2422 cls.pool.terminate()
2423 cls.pool.join()
2424 cls.pool = None
2654 def _test_traceback(cls):
2696 def _test_wrapped_exception(cls):
3005 def _putter(cls, address, authkey):
3012 queue.put(tuple(cls.values))
3047 def _putter(cls, address, authkey):
3107 def _echo(cls, conn):
3258 def _is_fd_assigned(cls, fd):
3269 def _writefd(cls, conn, data, create_dummy_fds=False):
3272 if not cls._is_fd_assigned(i):
3406 def _test(cls, address):
3407 conn = cls.connection.Client(address)
3461 def _child_strings(cls, conn, strings):
3483 def _child_boundaries(cls, r):
3503 def _child_dont_merge(cls, b):
3538 def tearDownClass(cls):
3543 def _listener(cls, conn, families):
3545 l = cls.connection.Listener(family=fam)
3562 def _remote(cls, conn):
3564 client = cls.connection.Client(address)
3623 def child_access(cls, conn):
3787 def _double(cls, x, y, z, foo, arr, string):
4368 def _test_finalize(cls, conn):
4533 def _test_level(cls, conn):
4594 def _killer(cls, pid):
4777 def _child_test_wait(cls, w, slow):
4815 def _child_test_wait_socket(cls, address, slow):
4889 def signal_and_sleep(cls, sem, period):
4969 def run_in_grandchild(cls, conn):
4973 def run_in_child(cls):
4976 p = multiprocessing.Process(target=cls.run_in_grandchild, args=(w,))
5001 def _test_timeout(cls, child, address):
5056 def child(cls, n, conn):
5058 p = multiprocessing.Process(target=cls.child, args=(n-1, conn))
5108 def _test_closefds(cls, conn, fd):
5153 def _test_ignore(cls, conn):
5160 conn.send_bytes(b'x' * cls.CONN_MAX_SIZE)
5186 def _test_ignore_listener(cls, conn):
5216 def _check_context(cls, conn):
5453 def _test_empty(cls, queue, child_can_start, parent_can_continue):
5554 def _test_list(cls, obj):
5581 def setUpClass(cls):
5612 def _test_event(cls, obj):
5626 def _test_lock(cls, obj):
5636 def _test_rlock(cls, obj):
5645 def _test_semaphore(cls, obj):
5657 def _test_condition(cls, obj):
5666 def _test_barrier(cls, obj):
5675 def _test_pool(cls, obj):
5685 def _test_queue(cls, obj):
5706 def _test_list(cls, obj):
5725 def _test_dict(cls, obj):
5743 def _test_value(cls, obj):
5755 def _test_array(cls, obj):
5766 def _test_namespace(cls, obj):
5819 def setUpClass(cls):
5820 cls.dangling = (multiprocessing.process._dangling.copy(),
5824 def tearDownClass(cls):
5829 processes = set(multiprocessing.process._dangling) - set(cls.dangling[0])
5835 threads = set(threading._dangling) - set(cls.dangling[1])
5886 def Pool(cls, *args, **kwds):
5887 return cls.manager.Pool(*args, **kwds)
5890 def setUpClass(cls):
5892 cls.manager = multiprocessing.Manager()
5895 def tearDownClass(cls):
5913 if cls.manager._number_of_objects() != 0:
5920 support.print_warning(cls.manager._debug_info())
5921 cls.manager.shutdown()
5922 cls.manager.join()
5923 cls.manager = None