| /third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _handler.py | 58 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.py | 28 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 …]
|
| /third_party/grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _rpc_state.py | 24 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:
79 self._condition.wait()
85 with self._condition:
[all …]
|
| D | _channel_state.py | 25 self._condition = threading.Condition()
32 with self._condition:
34 self._condition.notify_all()
41 with self._condition:
47 self._condition.wait()
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/framework/common/ |
| D | test_control.py | 55 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 …]
|
| /third_party/grpc/src/python/grpcio/grpc/beta/ |
| D | utilities.py | 32 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.py | 107 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 …]
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _utilities.py | 65 self._condition = threading.Condition()
74 with self._condition:
82 self._condition.wait()
88 self._condition.wait(timeout=remaining)
91 with self._condition:
96 self._condition.notify_all()
109 with self._condition:
113 self._condition.notify_all()
128 with self._condition:
132 with self._condition:
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _read_some_but_not_all_responses_test.py | 29 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.py | 44 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.py | 111 self._condition = condition
122 with self._condition:
125 self._condition.notify_all()
134 with self._condition:
136 self._condition.wait()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | _base.py | 151 future._condition.acquire()
155 future._condition.release()
194 with f._condition:
260 with f._condition:
309 with f._condition:
320 self._condition = threading.Condition()
335 with self._condition:
360 with self._condition:
368 self._condition.notify_all()
375 with self._condition:
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _beta_features_test.py | 45 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.py | 29 self._condition = threading.Condition()
33 with self._condition:
35 self._condition.notify_all()
38 with self._condition:
40 self._condition.wait()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | status.h | 49 #define CHECK_FAIL_RETURN_UNEXPECTED(_condition, _e) \ argument
51 if (!(_condition)) { \
56 #define CHECK_FAIL_RETURN_SYNTAX_ERROR(_condition, _e) \ argument
58 if (!(_condition)) { \
71 #define RETURN_OK_IF_TRUE(_condition) \ argument
73 if (_condition) { \
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 46 self._condition = threading.Condition()
51 with self._condition:
54 self._condition.notify()
57 with self._condition:
59 self._condition.notify()
62 with self._condition:
66 self._condition.notify()
75 with self._condition:
77 self._condition.wait()
|
| /third_party/grpc/src/python/grpcio_health_checking/grpc_health/v1/ |
| D | health.py | 37 self._condition = threading.Condition()
45 with self._condition:
47 self._condition.wait()
60 with self._condition:
62 self._condition.notify()
65 with self._condition:
67 self._condition.notify()
|
| /third_party/grpc/src/python/grpcio_tests/tests/testing/ |
| D | _client_application.py | 67 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()
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_ready_future_test.py | 28 self._condition = threading.Condition()
32 with self._condition:
34 self._condition.notify_all()
37 with self._condition:
39 self._condition.wait()
|
| D | _channel_close_test.py | 77 self._condition = threading.Condition()
85 with self._condition:
87 self._condition.wait()
100 with self._condition:
102 self._condition.notify()
105 with self._condition:
107 self._condition.notify()
|
| D | _channel_connectivity_test.py | 37 self._condition = threading.Condition()
41 with self._condition:
43 self._condition.notify()
46 with self._condition:
50 with self._condition:
56 self._condition.wait()
|
| /third_party/jsframework/runtime/main/extend/mediaquery/ |
| D | pluginMediaQuery.ts | 29 private _condition: string; property in MediaQueryList
34 this._condition = condition;
48 return this._condition;
52 return this._condition;
|
| /third_party/grpc/src/python/grpcio_tests/tests/fork/ |
| D | methods.py | 80 self._condition = threading.Condition()
91 with self._condition:
93 self._condition.wait()
100 with self._condition:
102 self._condition.notify()
105 with self._condition:
107 self._condition.notify()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | fork_posix.pyx.pxi | 167 self._condition = threading.Condition()
170 with self._condition:
174 with self._condition:
177 self._condition.notify_all()
182 with self._condition:
185 self._condition.wait(wait_time)
|
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/include/ |
| D | shard_error.h | 46 #define CHECK_FAIL_RETURN_UNEXPECTED(_condition, _e) \ argument
48 if (!(_condition)) { \
|