| /third_party/flutter/engine/flutter/fml/ |
| D | message_loop.cc | 40 : loop_(MessageLoopImpl::Create()), in MessageLoop()
41 task_runner_(fml::MakeRefCounted<fml::TaskRunner>(loop_)) { in MessageLoop()
42 FML_CHECK(loop_); in MessageLoop()
49 loop_->DoRun(); in Run()
53 loop_->DoTerminate(); in Terminate()
61 return loop_; in GetLoopImpl()
65 loop_->AddTaskObserver(key, callback); in AddTaskObserver()
69 loop_->RemoveTaskObserver(key); in RemoveTaskObserver()
73 loop_->RunExpiredTasksNow(); in RunExpiredTasksNow()
|
| D | task_runner.cc | 19 : loop_(std::move(loop)) {} in TaskRunner()
24 loop_->PostTask(std::move(task), fml::TimePoint::Now()); in PostTask()
29 loop_->PostTask(std::move(task), target_time); in PostTaskForTime()
33 loop_->PostTask(std::move(task), fml::TimePoint::Now() + delay); in PostDelayedTask()
37 FML_DCHECK(loop_); in GetTaskQueueId()
38 return loop_->GetTaskQueueId(); in GetTaskQueueId()
47 const auto loop_queue_id = loop_->GetTaskQueueId(); in RunsTasksOnCurrentThread()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/opt/ |
| D | loop_unswitch_pass.cpp | 56 loop_(loop), in LoopUnswitch()
69 if (loop_->IsSafeToClone()) return false; in CanUnswitchLoop()
73 for (uint32_t bb_id : loop_->GetBlocks()) { in CanUnswitchLoop()
75 if (loop_->GetLatchBlock() == bb) { in CanUnswitchLoop()
148 assert(loop_->GetPreHeaderBlock() && "This loop has no pre-header block"); in PerformUnswitch()
149 assert(loop_->IsLCSSA() && "This loop is not in LCSSA form"); in PerformUnswitch()
155 LoopUtils loop_utils(context_, loop_); in PerformUnswitch()
167 BasicBlock* if_merge_block = loop_->GetMergeBlock(); in PerformUnswitch()
208 if (Loop* ploop = loop_->GetParent()) { in PerformUnswitch()
224 loop_->SetMergeBlock(loop_merge_block); in PerformUnswitch()
[all …]
|
| D | loop_utils.cpp | 320 Function* function = loop_->GetHeaderBlock()->GetParent(); in CreateLoopDedicatedExits()
331 loop_->GetExitBlocks(&exit_bb_set); in CreateLoopDedicatedExits()
342 [this](uint32_t id) { return loop_->IsInsideLoop(id); })) { in CreateLoopDedicatedExits()
363 if (loop_->IsInsideLoop(exit_pred_id)) { in CreateLoopDedicatedExits()
393 if (loop_->IsInsideLoop(incoming_id)) { in CreateLoopDedicatedExits()
427 loop_->SetMergeBlock(*new_loop_exits.begin()); in CreateLoopDedicatedExits()
440 Function* function = loop_->GetHeaderBlock()->GetParent(); in MakeLoopClosedSSA()
448 loop_->GetExitBlocks(&exit_bb_id); in MakeLoopClosedSSA()
455 loop_->GetMergeBlock()); in MakeLoopClosedSSA()
456 MakeSetClosedSSA(context_, function, loop_->GetBlocks(), exit_bb, in MakeLoopClosedSSA()
[all …]
|
| D | loop_peeling.cpp | 43 BasicBlock* pre_header = loop_->GetOrCreatePreHeaderBlock(); in DuplicateAndConnectLoop()
45 loop_->ComputeLoopStructuredOrder(&ordered_loop_blocks); in DuplicateAndConnectLoop()
63 cfg.RemoveEdge(pre_header->id(), loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
65 loop_->SetPreHeaderBlock(nullptr); in DuplicateAndConnectLoop()
73 for (uint32_t pred_id : cfg.preds(loop_->GetMergeBlock()->id())) { in DuplicateAndConnectLoop()
74 if (loop_->IsInsideLoop(pred_id)) continue; in DuplicateAndConnectLoop()
79 if (*succ == loop_->GetMergeBlock()->id()) in DuplicateAndConnectLoop()
80 *succ = loop_->GetHeaderBlock()->id(); in DuplicateAndConnectLoop()
85 cfg.RemoveNonExistingEdges(loop_->GetMergeBlock()->id()); in DuplicateAndConnectLoop()
86 cfg.AddEdge(cloned_loop_exit, loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
[all …]
|
| D | loop_fission.cpp | 62 : context_(context), loop_(loop), load_used_in_condition_(false) {} in LoopFissionImpl()
104 Loop* loop_; member in spvtools::opt::LoopFissionImpl
137 !loop_->IsInsideLoop(context_->get_instr_block(user))) { in TraverseUseDef()
193 BasicBlock* condition_block = loop_->FindConditionBlock(); in GroupInstructionsByUseDef()
201 Function& function = *loop_->GetHeaderBlock()->GetParent(); in GroupInstructionsByUseDef()
213 if (!loop_->IsInsideLoop(block.id())) continue; in GroupInstructionsByUseDef()
226 if (!loop_->IsInsideLoop(block.id()) || in GroupInstructionsByUseDef()
227 loop_->GetHeaderBlock()->id() == block.id()) in GroupInstructionsByUseDef()
279 Loop* parent_loop = loop_; in CanPerformSplit()
308 const size_t loop_depth = loop_->GetDepth(); in CanPerformSplit()
[all …]
|
| D | loop_peeling.h | 83 loop_(loop),
130 if (!loop_->IsLCSSA()) { in CanPeelLoop()
133 if (!loop_->GetMergeBlock()) { in CanPeelLoop()
136 if (cfg.preds(loop_->GetMergeBlock()->id()).size() != 1) { in CanPeelLoop()
160 Loop* GetOriginalLoop() { return loop_; } in GetOriginalLoop()
166 Loop* loop_; variable
283 loop_(loop), in LoopPeelingInfo()
320 Loop* loop_; variable
|
| D | loop_unroller.cpp | 983 if (!loop_->GetHeaderBlock()->GetMergeInst()) { in CanPerformUnroll()
988 const BasicBlock* condition = loop_->FindConditionBlock(); in CanPerformUnroll()
992 const Instruction* induction = loop_->FindConditionVariable(condition); in CanPerformUnroll()
996 if (!loop_->FindNumberOfIterations(induction, &*condition->ctail(), nullptr)) in CanPerformUnroll()
1001 const Instruction& branch = *loop_->GetLatchBlock()->ctail(); in CanPerformUnroll()
1004 branch.GetSingleWordInOperand(0) == loop_->GetHeaderBlock()->id(); in CanPerformUnroll()
1010 loop_->GetInductionVariables(inductions); in CanPerformUnroll()
1014 context_->cfg()->preds(loop_->GetMergeBlock()->id()); in CanPerformUnroll()
1021 context_->cfg()->preds(loop_->GetContinueBlock()->id()); in CanPerformUnroll()
1029 for (uint32_t label_id : loop_->GetBlocks()) { in CanPerformUnroll()
[all …]
|
| /third_party/skia/third_party/externals/spirv-tools/source/opt/ |
| D | loop_unswitch_pass.cpp | 56 loop_(loop), in LoopUnswitch()
69 if (loop_->IsSafeToClone()) return false; in CanUnswitchLoop()
73 for (uint32_t bb_id : loop_->GetBlocks()) { in CanUnswitchLoop()
75 if (loop_->GetLatchBlock() == bb) { in CanUnswitchLoop()
148 assert(loop_->GetPreHeaderBlock() && "This loop has no pre-header block"); in PerformUnswitch()
149 assert(loop_->IsLCSSA() && "This loop is not in LCSSA form"); in PerformUnswitch()
155 LoopUtils loop_utils(context_, loop_); in PerformUnswitch()
167 BasicBlock* if_merge_block = loop_->GetMergeBlock(); in PerformUnswitch()
208 if (Loop* ploop = loop_->GetParent()) { in PerformUnswitch()
224 loop_->SetMergeBlock(loop_merge_block); in PerformUnswitch()
[all …]
|
| D | loop_utils.cpp | 320 Function* function = loop_->GetHeaderBlock()->GetParent(); in CreateLoopDedicatedExits()
331 loop_->GetExitBlocks(&exit_bb_set); in CreateLoopDedicatedExits()
342 [this](uint32_t id) { return loop_->IsInsideLoop(id); })) { in CreateLoopDedicatedExits()
363 if (loop_->IsInsideLoop(exit_pred_id)) { in CreateLoopDedicatedExits()
393 if (loop_->IsInsideLoop(incoming_id)) { in CreateLoopDedicatedExits()
427 loop_->SetMergeBlock(*new_loop_exits.begin()); in CreateLoopDedicatedExits()
440 Function* function = loop_->GetHeaderBlock()->GetParent(); in MakeLoopClosedSSA()
448 loop_->GetExitBlocks(&exit_bb_id); in MakeLoopClosedSSA()
455 loop_->GetMergeBlock()); in MakeLoopClosedSSA()
456 MakeSetClosedSSA(context_, function, loop_->GetBlocks(), exit_bb, in MakeLoopClosedSSA()
[all …]
|
| D | loop_peeling.cpp | 43 BasicBlock* pre_header = loop_->GetOrCreatePreHeaderBlock(); in DuplicateAndConnectLoop()
45 loop_->ComputeLoopStructuredOrder(&ordered_loop_blocks); in DuplicateAndConnectLoop()
63 cfg.RemoveEdge(pre_header->id(), loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
65 loop_->SetPreHeaderBlock(nullptr); in DuplicateAndConnectLoop()
73 for (uint32_t pred_id : cfg.preds(loop_->GetMergeBlock()->id())) { in DuplicateAndConnectLoop()
74 if (loop_->IsInsideLoop(pred_id)) continue; in DuplicateAndConnectLoop()
79 if (*succ == loop_->GetMergeBlock()->id()) in DuplicateAndConnectLoop()
80 *succ = loop_->GetHeaderBlock()->id(); in DuplicateAndConnectLoop()
85 cfg.RemoveNonExistingEdges(loop_->GetMergeBlock()->id()); in DuplicateAndConnectLoop()
86 cfg.AddEdge(cloned_loop_exit, loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
[all …]
|
| D | loop_fission.cpp | 62 : context_(context), loop_(loop), load_used_in_condition_(false) {} in LoopFissionImpl()
104 Loop* loop_; member in spvtools::opt::LoopFissionImpl
137 !loop_->IsInsideLoop(context_->get_instr_block(user))) { in TraverseUseDef()
193 BasicBlock* condition_block = loop_->FindConditionBlock(); in GroupInstructionsByUseDef()
201 Function& function = *loop_->GetHeaderBlock()->GetParent(); in GroupInstructionsByUseDef()
213 if (!loop_->IsInsideLoop(block.id())) continue; in GroupInstructionsByUseDef()
226 if (!loop_->IsInsideLoop(block.id()) || in GroupInstructionsByUseDef()
227 loop_->GetHeaderBlock()->id() == block.id()) in GroupInstructionsByUseDef()
279 Loop* parent_loop = loop_; in CanPerformSplit()
308 const size_t loop_depth = loop_->GetDepth(); in CanPerformSplit()
[all …]
|
| D | loop_peeling.h | 83 loop_(loop),
130 if (!loop_->IsLCSSA()) { in CanPeelLoop()
133 if (!loop_->GetMergeBlock()) { in CanPeelLoop()
136 if (cfg.preds(loop_->GetMergeBlock()->id()).size() != 1) { in CanPeelLoop()
160 Loop* GetOriginalLoop() { return loop_; } in GetOriginalLoop()
166 Loop* loop_; variable
283 loop_(loop), in LoopPeelingInfo()
320 Loop* loop_; variable
|
| /third_party/spirv-tools/source/opt/ |
| D | loop_unswitch_pass.cpp | 56 loop_(loop), in LoopUnswitch()
69 if (loop_->IsSafeToClone()) return false; in CanUnswitchLoop()
73 for (uint32_t bb_id : loop_->GetBlocks()) { in CanUnswitchLoop()
75 if (loop_->GetLatchBlock() == bb) { in CanUnswitchLoop()
148 assert(loop_->GetPreHeaderBlock() && "This loop has no pre-header block"); in PerformUnswitch()
149 assert(loop_->IsLCSSA() && "This loop is not in LCSSA form"); in PerformUnswitch()
155 LoopUtils loop_utils(context_, loop_); in PerformUnswitch()
167 BasicBlock* if_merge_block = loop_->GetMergeBlock(); in PerformUnswitch()
208 if (Loop* ploop = loop_->GetParent()) { in PerformUnswitch()
224 loop_->SetMergeBlock(loop_merge_block); in PerformUnswitch()
[all …]
|
| D | loop_utils.cpp | 320 Function* function = loop_->GetHeaderBlock()->GetParent(); in CreateLoopDedicatedExits()
331 loop_->GetExitBlocks(&exit_bb_set); in CreateLoopDedicatedExits()
342 [this](uint32_t id) { return loop_->IsInsideLoop(id); })) { in CreateLoopDedicatedExits()
363 if (loop_->IsInsideLoop(exit_pred_id)) { in CreateLoopDedicatedExits()
393 if (loop_->IsInsideLoop(incoming_id)) { in CreateLoopDedicatedExits()
427 loop_->SetMergeBlock(*new_loop_exits.begin()); in CreateLoopDedicatedExits()
440 Function* function = loop_->GetHeaderBlock()->GetParent(); in MakeLoopClosedSSA()
448 loop_->GetExitBlocks(&exit_bb_id); in MakeLoopClosedSSA()
455 loop_->GetMergeBlock()); in MakeLoopClosedSSA()
456 MakeSetClosedSSA(context_, function, loop_->GetBlocks(), exit_bb, in MakeLoopClosedSSA()
[all …]
|
| D | loop_peeling.cpp | 43 BasicBlock* pre_header = loop_->GetOrCreatePreHeaderBlock(); in DuplicateAndConnectLoop()
45 loop_->ComputeLoopStructuredOrder(&ordered_loop_blocks); in DuplicateAndConnectLoop()
63 cfg.RemoveEdge(pre_header->id(), loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
65 loop_->SetPreHeaderBlock(nullptr); in DuplicateAndConnectLoop()
73 for (uint32_t pred_id : cfg.preds(loop_->GetMergeBlock()->id())) { in DuplicateAndConnectLoop()
74 if (loop_->IsInsideLoop(pred_id)) continue; in DuplicateAndConnectLoop()
79 if (*succ == loop_->GetMergeBlock()->id()) in DuplicateAndConnectLoop()
80 *succ = loop_->GetHeaderBlock()->id(); in DuplicateAndConnectLoop()
85 cfg.RemoveNonExistingEdges(loop_->GetMergeBlock()->id()); in DuplicateAndConnectLoop()
86 cfg.AddEdge(cloned_loop_exit, loop_->GetHeaderBlock()->id()); in DuplicateAndConnectLoop()
[all …]
|
| D | loop_fission.cpp | 62 : context_(context), loop_(loop), load_used_in_condition_(false) {} in LoopFissionImpl()
104 Loop* loop_; member in spvtools::opt::LoopFissionImpl
137 !loop_->IsInsideLoop(context_->get_instr_block(user))) { in TraverseUseDef()
193 BasicBlock* condition_block = loop_->FindConditionBlock(); in GroupInstructionsByUseDef()
201 Function& function = *loop_->GetHeaderBlock()->GetParent(); in GroupInstructionsByUseDef()
213 if (!loop_->IsInsideLoop(block.id())) continue; in GroupInstructionsByUseDef()
226 if (!loop_->IsInsideLoop(block.id()) || in GroupInstructionsByUseDef()
227 loop_->GetHeaderBlock()->id() == block.id()) in GroupInstructionsByUseDef()
279 Loop* parent_loop = loop_; in CanPerformSplit()
308 const size_t loop_depth = loop_->GetDepth(); in CanPerformSplit()
[all …]
|
| D | loop_peeling.h | 83 loop_(loop),
130 if (!loop_->IsLCSSA()) { in CanPeelLoop()
133 if (!loop_->GetMergeBlock()) { in CanPeelLoop()
136 if (cfg.preds(loop_->GetMergeBlock()->id()).size() != 1) { in CanPeelLoop()
160 Loop* GetOriginalLoop() { return loop_; } in GetOriginalLoop()
166 Loop* loop_; variable
283 loop_(loop), in LoopPeelingInfo()
320 Loop* loop_; variable
|
| D | loop_unroller.cpp | 984 if (!loop_->GetHeaderBlock()->GetMergeInst()) { in CanPerformUnroll()
989 const BasicBlock* condition = loop_->FindConditionBlock(); in CanPerformUnroll()
993 const Instruction* induction = loop_->FindConditionVariable(condition); in CanPerformUnroll()
997 if (!loop_->FindNumberOfIterations(induction, &*condition->ctail(), nullptr)) in CanPerformUnroll()
1007 loop_->FindNumberOfIterations(induction, &*condition->ctail(), in CanPerformUnroll()
1016 const Instruction& branch = *loop_->GetLatchBlock()->ctail(); in CanPerformUnroll()
1019 branch.GetSingleWordInOperand(0) == loop_->GetHeaderBlock()->id(); in CanPerformUnroll()
1025 loop_->GetInductionVariables(inductions); in CanPerformUnroll()
1029 context_->cfg()->preds(loop_->GetMergeBlock()->id()); in CanPerformUnroll()
1036 context_->cfg()->preds(loop_->GetContinueBlock()->id()); in CanPerformUnroll()
[all …]
|
| /third_party/nghttp2/src/ |
| D | shrpx_rate_limit.cc | 44 loop_(loop), in RateLimit()
53 ev_timer_again(loop_, &t_); in RateLimit()
57 RateLimit::~RateLimit() { ev_timer_stop(loop_, &t_); } in ~RateLimit()
73 ev_io_stop(loop_, w_); in drain()
88 ev_io_start(loop_, w_); in regen()
99 ev_io_start(loop_, w_); in startw()
107 ev_io_stop(loop_, w_); in stopw()
120 ev_feed_event(loop_, w_, EV_READ); in handle_tls_pending_read()
|
| D | shrpx_dns_resolver.cc | 119 loop_(loop),
132 stop_ev(loop_, revs_); in ~DNSResolver()
133 stop_ev(loop_, wevs_); in ~DNSResolver()
135 ev_timer_stop(loop_, &timer_); in ~DNSResolver()
224 ev_timer_again(loop_, &timer_); in reset_timeout()
277 start_ev(revs_, loop_, fd, EV_READ, readcb, this); in start_rev()
280 void DNSResolver::stop_rev(int fd) { stop_ev(revs_, loop_, fd, EV_READ); } in stop_rev()
283 start_ev(wevs_, loop_, fd, EV_WRITE, writecb, this); in start_wev()
286 void DNSResolver::stop_wev(int fd) { stop_ev(wevs_, loop_, fd, EV_WRITE); } in stop_wev()
289 stop_ev(loop_, revs_); in on_result()
[all …]
|
| D | shrpx_connect_blocker.cc | 48 loop_(loop), in ConnectBlocker()
55 ConnectBlocker::~ConnectBlocker() { ev_timer_stop(loop_, &timer_); } in ~ConnectBlocker()
98 ev_timer_start(loop_, &timer_); in on_failure()
114 ev_timer_stop(loop_, &timer_); in offline()
116 ev_timer_start(loop_, &timer_); in offline()
120 ev_timer_stop(loop_, &timer_); in online()
|
| D | shrpx_dns_tracker.cc | 40 : loop_(loop), family_(family) { in DNSTracker()
46 ev_timer_stop(loop_, &gc_timer_); in ~DNSTracker()
74 ent.expiry = ev_now(loop_) + dnsconf.timeout.cache; in make_entry()
95 ent.expiry = ev_now(loop_) + dnsconf.timeout.cache; in update_entry()
115 auto resolv = std::make_unique<DualDNSResolver>(loop_, family_); in resolve()
178 if (ent.status != DNSResolverStatus::RUNNING && ent.expiry < ev_now(loop_)) { in resolve()
184 auto resolv = std::make_unique<DualDNSResolver>(loop_, family_); in resolve()
255 auto loop = loop_; in add_to_qlist()
301 ev_timer_again(loop_, &gc_timer_); in start_gc_timer()
309 auto now = ev_now(loop_); in gc()
[all …]
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/flutter/ |
| D | thread.cc | 67 loop_.reset(MakeObservableLoop(false)); in Thread()
81 return loop_->dispatcher(); in dispatcher()
85 async_set_default_dispatcher(loop_->dispatcher()); in Main()
86 loop_->Run(); in Main()
90 loop_->Quit(); in Quit()
|
| /third_party/flutter/engine/flutter/fml/platform/darwin/ |
| D | message_loop_darwin.mm | 17 : running_(false), loop_((CFRunLoopRef)CFRetain(CFRunLoopGetCurrent())) {
18 FML_DCHECK(loop_ != nullptr);
31 CFRunLoopAddTimer(loop_, delayed_wake_timer_, kCFRunLoopCommonModes);
36 CFRunLoopRemoveTimer(loop_, delayed_wake_timer_, kCFRunLoopCommonModes);
40 FML_DCHECK(loop_ == CFRunLoopGetCurrent());
61 CFRunLoopStop(loop_);
|