| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| D | test_threading.py | 9 threading = test.test_support.import_module('threading') variable
29 class TestThread(threading.Thread):
31 threading.Thread.__init__(self, name=name)
80 sema = threading.BoundedSemaphore(value=3)
81 mutex = threading.RLock()
107 self.assertFalse(threading.currentThread().ident is None)
109 ident.append(threading.currentThread().ident)
111 done = threading.Event()
117 del threading._active[ident[0]]
124 threading.stack_size(262144)
[all …]
|
| D | test_capi.py | 11 import threading
13 threading = None variable
16 @unittest.skipUnless(threading, 'Threading required for this test.')
63 context.lock = threading.Lock()
64 context.event = threading.Event()
67 t = threading.Thread(target=self.pendingcalls_thread, args = (context,))
129 if threading:
133 t=threading.Thread(target=TestThreadState)
|
| D | test_threading_local.py | 9 threading = test_support.import_module('threading') variable
32 t = threading.Thread(target=target, args=(local, weaklist))
68 t = threading.Thread(target=f, args=(i,))
81 e1 = threading.Event()
82 e2 = threading.Event()
100 t = threading.Thread(target=f)
131 e1 = threading.Event()
132 e2 = threading.Event()
152 t1 = threading.Thread(target=f1)
155 t2 = threading.Thread(target=f2)
|
| D | threaded_import_hangers.py | 10 import threading
21 class Worker(threading.Thread):
23 threading.Thread.__init__(self)
|
| D | test_smtplib.py | 15 import threading
17 threading = None variable
43 @unittest.skipUnless(threading, 'Threading required for this test.')
48 self.evt = threading.Event()
53 self.thread = threading.Thread(target=server, args=servargs)
146 @unittest.skipUnless(threading, 'Threading required for this test.')
156 self.serv_evt = threading.Event()
157 self.client_evt = threading.Event()
163 self.thread = threading.Thread(target=debugging_server, args=serv_args)
265 @unittest.skipUnless(threading, 'Threading required for this test.')
[all …]
|
| D | test_asynchat.py | 8 import threading
10 threading = None variable
15 if threading:
16 class echo_server(threading.Thread):
22 threading.Thread.__init__(self)
90 event = threading.Event()
99 @unittest.skipUnless(threading, 'Threading required for this test.')
110 event = threading.Event()
214 s.start_resend_event = threading.Event()
|
| D | test_contextlib.py | 9 import threading
11 threading = None variable
270 @unittest.skipUnless(threading, 'Threading required for this test.')
285 lock = threading.Lock()
289 lock = threading.RLock()
293 lock = threading.Condition()
299 lock = threading.Semaphore()
309 lock = threading.BoundedSemaphore()
|
| D | test_threadedtempfile.py | 22 threading = import_module('threading') variable
27 startEvent = threading.Event()
29 class TempFileGreedy(threading.Thread):
|
| D | test_fork1.py | 12 threading = import_module('threading') variable
32 import_started = threading.Event()
43 t = threading.Thread(target=importer)
|
| D | test_poplib.py | 17 threading = test_support.import_module('threading') variable
107 class DummyPOP3Server(asyncore.dispatcher, threading.Thread):
112 threading.Thread.__init__(self)
118 self.active_lock = threading.Lock()
123 self.__flag = threading.Event()
124 threading.Thread.start(self)
282 self.evt = threading.Event()
286 threading.Thread(target=self.server, args=(self.evt,self.sock)).start()
|
| D | test_socketserver.py | 18 import threading
20 threading = None variable
64 @unittest.skipUnless(threading, 'Threading required for this test.')
126 @unittest.skipUnless(threading, 'Threading required for this test.')
138 t = threading.Thread(
262 t = threading.Thread(
|
| D | test_queue.py | 7 threading = test_support.import_module('threading') variable
12 class _TriggerThread(threading.Thread):
16 self.startedEvent = threading.Event()
17 threading.Thread.__init__(self)
85 self.cumlock = threading.Lock()
153 threading.Thread(target=self.worker, args=(q,)).start()
|
| D | test_ssl.py | 360 import threading
366 class ThreadedEchoServer(threading.Thread):
368 class ConnectionHandler(threading.Thread):
380 threading.Thread.__init__(self)
515 threading.Thread.__init__(self)
520 threading.Thread.start(self)
546 class AsyncoreEchoServer(threading.Thread):
618 threading.Thread.__init__(self)
626 threading.Thread.start(self)
639 class SocketServerHTTPSServer(threading.Thread):
[all …]
|
| D | test_docxmlrpc.py | 5 threading = test_support.import_module('threading') variable
76 self.evt = threading.Event()
77 threading.Thread(target=server, args=(self.evt, 1)).start()
|
| D | test_hashlib.py | 14 import threading
16 threading = None variable
320 @unittest.skipUnless(threading, 'Threading required for this test.')
347 event = threading.Event()
349 threading.Thread(target=hash_in_chunks,
|
| D | test_telnetlib.py | 8 threading = test_support.import_module('threading') variable
48 self.evt = threading.Event()
52 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
100 self.evt = threading.Event()
105 self.thread = threading.Thread(target=server, args=(self.evt,self.sock, self.dataq))
|
| D | test_ftplib.py | 21 threading = test_support.import_module('threading') variable
207 class DummyFTPServer(asyncore.dispatcher, threading.Thread):
212 threading.Thread.__init__(self)
218 self.active_lock = threading.Lock()
223 self.__flag = threading.Event()
224 threading.Thread.start(self)
668 self.evt = threading.Event()
672 threading.Thread(target=self.server, args=(self.evt,self.sock)).start()
|
| D | test_xmlrpc.py | 17 import threading
19 threading = None variable
417 @unittest.skipUnless(threading, 'Threading required for this test.')
427 self.evt = threading.Event()
430 threading.Thread(target=self.threadFunc, args=serv_args).start()
742 if threading:
769 @unittest.skipUnless(threading, 'Threading required for this test.')
772 self.evt = threading.Event()
775 threading.Thread(target=http_server, args=serv_args).start()
|
| D | test_urllib2_localnet.py | 10 threading = test_support.import_module('threading') variable
40 class LoopbackHttpServerThread(threading.Thread):
44 threading.Thread.__init__(self)
46 self.ready = threading.Event()
|
| D | test_imaplib.py | 5 threading = support.import_module('threading') variable
123 t = threading.Thread(
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Tools/ccbench/ |
| D | ccbench.py | 16 import threading
215 ready_cond = threading.Condition()
216 start_cond = threading.Condition()
231 threads.append(threading.Thread(target=run))
314 start_cond = threading.Condition()
323 ready_cond = threading.Condition()
335 threads.append(threading.Thread(target=run))
445 start_cond = threading.Condition()
454 ready_cond = threading.Condition()
466 threads.append(threading.Thread(target=run))
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Tools/scripts/ |
| D | analyze_dxp.py | 27 import threading
34 _profile_lock = threading.RLock()
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| D | SocketServer.py | 137 import threading
139 import dummy_threading as threading namespace
200 self.__is_shut_down = threading.Event()
590 t = threading.Thread(target = self.process_request_thread,
|
| D | dummy_threading.py | 45 import threading
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Lib/ |
| D | SocketServer.py | 138 import threading
140 import dummy_threading as threading namespace
210 self.__is_shut_down = threading.Event()
607 t = threading.Thread(target = self.process_request_thread,
|