Searched refs:result_handler (Results 1 – 12 of 12) sorted by relevance
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | resolver.h | 129 std::unique_ptr<ResultHandler> result_handler);
138 ResultHandler* result_handler() const { return result_handler_.get(); } in result_handler() function
|
| D | resolver_registry.cc | 159 std::unique_ptr<Resolver::ResultHandler> result_handler) { in CreateResolver() argument
168 resolver_args.result_handler = std::move(result_handler); in CreateResolver()
|
| D | resolver.cc | 33 std::unique_ptr<ResultHandler> result_handler) in Resolver() argument
38 result_handler_(std::move(result_handler)) {} in Resolver()
|
| D | resolver_factory.h | 46 std::unique_ptr<Resolver::ResultHandler> result_handler; member
|
| D | resolver_registry.h | 73 std::unique_ptr<Resolver::ResultHandler> result_handler);
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/native/ |
| D | dns_resolver.cc | 102 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in NativeDnsResolver()
189 result_handler()->ReturnResult(std::move(result)); in OnResolvedLocked()
199 result_handler()->ReturnError(grpc_error_set_int( in OnResolvedLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 92 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in FakeResolver()
143 result_handler()->ReturnError(grpc_error_set_int( in MaybeSendResultLocked()
158 result_handler()->ReturnResult(std::move(result)); in MaybeSendResultLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/sockaddr/ |
| D | sockaddr_resolver.cc | 62 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in SockaddrResolver()
76 result_handler()->ReturnResult(std::move(result)); in StartLocked()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 492 worker_handler, task_handler, result_handler, cache): argument
502 assert result_handler.is_alive() or len(cache) == 0
504 result_handler._state = TERMINATE
525 if threading.current_thread() is not result_handler:
526 result_handler.join(1e100)
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | dns_resolver_ares.cc | 129 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in AresDnsResolver()
358 result_handler()->ReturnResult(std::move(result)); in OnResolvedLocked()
369 result_handler()->ReturnError(grpc_error_set_int( in OnResolvedLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/xds/ |
| D | xds_resolver.cc | 50 std::move(args.result_handler)), in XdsResolver()
573 result_handler()->ReturnError(error); in StartLocked()
665 result_handler()->ReturnResult(std::move(result)); in OnError()
679 result_handler()->ReturnResult(std::move(result)); in OnResourceDoesNotExist()
737 result_handler()->ReturnResult(std::move(result)); in GenerateResult()
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | pool.py | 679 worker_handler, task_handler, result_handler, cache): argument
694 if (not result_handler.is_alive()) and (len(cache) != 0):
698 result_handler._state = TERMINATE
720 if threading.current_thread() is not result_handler:
721 result_handler.join()
|