Home
last modified time | relevance | path

Searched refs:_condition (Results 1 – 25 of 39) sorted by relevance

12

/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_handler.py58 self._condition = threading.Condition()
71 with self._condition:
73 self._condition.notify_all()
76 with self._condition:
81 self._condition.notify_all()
86 self._condition.wait()
91 with self._condition:
95 with self._condition:
97 self._condition.notify_all()
100 with self._condition:
[all …]
D_rpc.py28 self._condition = threading.Condition()
63 self._condition.notify_all()
81 with self._condition:
85 with self._condition:
90 with self._condition:
98 with self._condition:
102 self._condition.notify_all()
105 with self._condition:
111 with self._condition:
116 with self._condition:
[all …]
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_rpc_state.py24 self._condition = threading.Condition()
35 with self._condition:
39 self._condition.wait()
46 with self._condition:
49 self._condition.notify_all()
55 with self._condition:
58 self._condition.notify_all()
61 with self._condition:
78 self._condition.wait()
84 with self._condition:
[all …]
D_channel_state.py25 self._condition = threading.Condition()
32 with self._condition:
34 self._condition.notify_all()
41 with self._condition:
47 self._condition.wait()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/framework/common/
Dtest_control.py55 self._condition = threading.Condition()
61 with self._condition:
67 self._condition.notify_all()
68 self._condition.wait()
74 with self._condition:
77 with self._condition:
79 self._condition.notify_all()
86 with self._condition:
88 self._condition.wait()
93 with self._condition:
[all …]
/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dutilities.py32 self._condition = threading.Condition()
41 with self._condition:
49 self._condition.wait()
55 self._condition.wait(timeout=remaining)
58 with self._condition:
63 self._condition.notify_all()
74 with self._condition:
78 self._condition.notify_all()
91 with self._condition:
95 with self._condition:
[all …]
D_server_adaptations.py107 self._condition = threading.Condition()
113 with self._condition:
115 self._condition.notify_all()
118 with self._condition:
120 self._condition.notify_all()
123 with self._condition:
126 self._condition.notify_all()
129 with self._condition:
131 self._condition.notify_all()
134 with self._condition:
[all …]
/external/grpc-grpc/src/python/grpcio/grpc/
D_utilities.py63 self._condition = threading.Condition()
72 with self._condition:
80 self._condition.wait()
86 self._condition.wait(timeout=remaining)
89 with self._condition:
94 self._condition.notify_all()
105 with self._condition:
109 self._condition.notify_all()
122 with self._condition:
126 with self._condition:
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
D_read_some_but_not_all_responses_test.py29 self._condition = threading.Condition()
40 with self._condition:
42 self._condition.notify()
51 with self._condition:
55 with self._condition:
57 self._condition.wait()
61 with self._condition:
63 self._condition.wait()
70 self._condition = condition
81 with self._condition:
[all …]
D_common.py44 self._condition = condition
55 with self._condition:
58 self._condition.notify_all()
70 with self._condition:
75 self._condition.wait()
D_cancel_many_calls_test.py111 self._condition = condition
122 with self._condition:
125 self._condition.notify_all()
134 with self._condition:
136 self._condition.wait()
/external/python/cpython3/Lib/concurrent/futures/
D_base.py146 future._condition.acquire()
150 future._condition.release()
189 with f._condition:
255 with f._condition:
303 with f._condition:
314 self._condition = threading.Condition()
329 with self._condition:
354 with self._condition:
362 self._condition.notify_all()
369 with self._condition:
[all …]
/external/python/futures/concurrent/futures/
D_base.py148 future._condition.acquire()
152 future._condition.release()
191 with f._condition:
261 with f._condition:
309 with f._condition:
320 self._condition = threading.Condition()
352 with self._condition:
377 with self._condition:
385 self._condition.notify_all()
392 with self._condition:
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py45 self._condition = threading.Condition()
50 with self._condition:
56 self._condition.notify_all()
60 with self._condition:
66 self._condition.notify_all()
73 with self._condition:
78 self._condition.notify_all()
83 with self._condition:
87 with self._condition:
90 self._condition.notify_all()
[all …]
D_utilities_test.py29 self._condition = threading.Condition()
33 with self._condition:
35 self._condition.notify_all()
38 with self._condition:
40 self._condition.wait()
/external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/
Dstream_util.py47 self._condition = threading.Condition()
52 with self._condition:
55 self._condition.notify()
58 with self._condition:
60 self._condition.notify()
63 with self._condition:
67 self._condition.notify()
76 with self._condition:
78 self._condition.wait()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_channel_close_test.py57 self._condition = threading.Condition()
65 with self._condition:
67 self._condition.wait()
80 with self._condition:
82 self._condition.notify()
85 with self._condition:
87 self._condition.notify()
D_channel_ready_future_test.py27 self._condition = threading.Condition()
31 with self._condition:
33 self._condition.notify_all()
36 with self._condition:
38 self._condition.wait()
D_channel_connectivity_test.py36 self._condition = threading.Condition()
40 with self._condition:
42 self._condition.notify()
45 with self._condition:
49 with self._condition:
55 self._condition.wait()
D_invocation_defects_test.py40 self._condition = threading.Condition()
45 with self._condition:
48 self._condition.notify_all()
51 with self._condition:
53 self._condition.wait()
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_client_application.py67 self._condition = threading.Condition()
75 with self._condition:
82 self._condition.wait()
91 with self._condition:
93 self._condition.notify_all()
96 with self._condition:
98 self._condition.notify_all()
/external/chromium-trace/catapult/common/py_utils/py_utils/
Dcontextlib_ext.py10 self._condition = condition
13 if self._condition:
18 if self._condition:
/external/grpc-grpc/src/python/grpcio_tests/tests/fork/
Dmethods.py78 self._condition = threading.Condition()
89 with self._condition:
91 self._condition.wait()
98 with self._condition:
100 self._condition.notify()
103 with self._condition:
105 self._condition.notify()
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dfork_posix.pyx.pxi157 self._condition = threading.Condition()
160 with self._condition:
164 with self._condition:
167 self._condition.notify_all()
172 with self._condition:
175 self._condition.wait(wait_time)
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py47 self._condition = threading.Condition()
53 with self._condition:
56 with self._condition:
58 self._condition.notify_all()
62 with self._condition:
65 with self._condition:
69 with self._condition:
73 self._condition.wait()

12