Lines Matching refs:ffrt
61 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
62 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAKE;
67 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
68 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).timerHandle_ = -1;
69 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).timerMap_.clear();
70 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).executedHandle_.clear();
71 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::TEARDOWN;
79 ffrt::submit([&]() {
80 ffrt::sync_io(testFd);
87 ffrt::submit([&]() {
92 ffrt::wait();
99 ffrt::submit([&]() {
106 ffrt::submit([&]() {
107 ffrt::sync_io(testFd);
115 ffrt::wait();
135 ffrt::submit([fd, i]() {
136 ffrt::sync_io(fd);
145 ffrt::submit([&, i]() {
152 ffrt::wait();
191 ffrt::submit([&]() {
196 ffrt::wait();
212 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
213 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::TEARDOWN;
225 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
230 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAIT;
238 ffrt::submit([&]() {
243 ffrt::wait();
253 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
259 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAKE;
265 ffrt::submit([&]() {
270 ffrt::wait();
277 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
287 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAKE;
293 ffrt::submit([&]() {
298 ffrt::wait();
311 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
324 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAIT;
330 ffrt::submit([&]() {
335 ffrt::wait();
341 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
351 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAIT;
359 ffrt::submit([&]() {
364 ffrt::wait();
370 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
380 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAKE;
389 ffrt::submit([&]() {
394 ffrt::wait();
400 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
408 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::TEARDOWN;
417 ffrt::submit([&]() {
422 ffrt::wait();
446 ffrt::submit([&]() {
451 ffrt::wait();
476 ffrt::submit([&]() {
481 ffrt::wait();
498 ffrt::submit([&]() {
507 ffrt::wait();
523 ffrt::submit([&]() {
532 ffrt::wait();
548 ffrt::submit([&]() {
557 ffrt::wait();
610 ffrt::submit([&]() {
638 ffrt::submit([&]() {
667 ffrt::submit([&]() {
695 ffrt::submit([&]() {
765 ffrt::submit([&]() {