Home
last modified time | relevance | path

Searched refs:Alarm (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc/include/grpcpp/
Dalarm.h36 class Alarm : private GrpcLibraryCodegen {
39 Alarm();
42 ~Alarm();
52 Alarm(CompletionQueue* cq, const T& deadline, void* tag) : Alarm() { in Alarm() function
66 Alarm(const Alarm&) = delete;
67 Alarm& operator=(const Alarm&) = delete;
70 Alarm(Alarm&& rhs) : alarm_(rhs.alarm_) { rhs.alarm_ = nullptr; } in Alarm() function
71 Alarm& operator=(Alarm&& rhs) {
86 explicit experimental_type(Alarm* alarm) : alarm_(alarm) {} in experimental_type()
97 Alarm* alarm_;
/external/grpc-grpc/test/cpp/common/
Dalarm_test.cc37 Alarm alarm; in TEST()
57 Alarm alarm; in TEST()
75 Alarm alarm; in TEST()
92 Alarm alarm; in TEST()
116 Alarm alarm; in TEST()
137 Alarm alarm(&cq, grpc_timeout_seconds_to_deadline(1), junk); in TEST()
152 Alarm first; in TEST()
154 Alarm second(std::move(first)); in TEST()
167 Alarm first; in TEST()
169 Alarm second(std::move(first)); in TEST()
[all …]
/external/grpc-grpc/src/cpp/common/
Dalarm.cc119 Alarm::Alarm() : alarm_(new internal::AlarmImpl()) { in Alarm() function in grpc::Alarm
123 void Alarm::SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag) { in SetInternal()
132 void Alarm::SetInternal(gpr_timespec deadline, std::function<void(bool)> f) { in SetInternal()
141 Alarm::~Alarm() { in ~Alarm()
147 void Alarm::Cancel() { static_cast<internal::AlarmImpl*>(alarm_)->Cancel(); } in Cancel()
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc122 std::unique_ptr<Alarm> alarm_;
143 alarm_.reset(new Alarm); in StartInternal()
372 alarm_.reset(new Alarm); in RunNextState()
437 std::unique_ptr<Alarm> alarm_;
556 alarm_.reset(new Alarm); in RunNextState()
592 std::unique_ptr<Alarm> alarm_;
712 std::unique_ptr<Alarm> alarm_;
802 alarm_.reset(new Alarm); in RunNextState()
857 std::unique_ptr<Alarm> alarm_;
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.h169 std::unique_ptr<Alarm> next_report_alarm_;
188 std::unique_ptr<Alarm> next_fetch_and_sample_alarm_;
Dload_reporter_async_service_impl.cc69 next_fetch_and_sample_alarm_.reset(new Alarm); in ScheduleNextFetchAndSample()
269 next_report_alarm_.reset(new Alarm); in ScheduleNextReport()
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service.h51 ::grpc::Alarm* shutdown_alarm_;
Dgrpc_verbs_service.cc52 new ::grpc::Alarm(cq_, gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc78 shutdown_alarm_ = MakeUnique<::grpc::Alarm>( in Shutdown()
Dgrpc_eager_service_impl.h71 std::unique_ptr<::grpc::Alarm> shutdown_alarm_;
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service.cc76 new ::grpc::Alarm(cq_.get(), gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
143 ::grpc::Alarm* shutdown_alarm_ = nullptr;
/external/ltp/testcases/kernel/device-drivers/rtc/
DREADME8 2. Alarm Test: Sets the alarm to 5 seconds in future and makes sure it rings.
/external/python/cpython2/Lib/test/
Dtest_socket.py1531 class Alarm(Exception): class
1534 raise Alarm
1542 except Alarm:
1552 except Alarm:
/external/python/cpython3/Lib/test/
Dtest_socket.py4871 class Alarm(Exception): class
4874 raise Alarm
4882 except Alarm:
4892 except Alarm:
/external/strace/
DChangeLog49677 --- {si_signo=SIGALRM, si_code=SI_KERNEL} (Alarm clock) ---
49684 --- {si_signo=SIGALRM, si_code=SI_KERNEL} (Alarm clock) ---