| /external/tensorflow/tensorflow/lite/delegates/gpu/cl/ |
| D | cl_command_queue.cc | 173 events_.reserve(128); in ProfilingCommandQueue()
178 events_(std::move(queue.events_)), in ProfilingCommandQueue()
184 events_ = std::move(queue.events_); in operator =()
195 void ProfilingCommandQueue::ResetMeasurements() { events_.clear(); } in ResetMeasurements()
200 events_.push_back(CLEvent()); in Dispatch()
203 &events_[events_.size() - 1])); in Dispatch()
204 events_.back().SetName(current_label_); in Dispatch()
210 result.dispatches.resize(events_.size()); in GetProfilingInfo()
211 for (int i = 0; i < events_.size(); ++i) { in GetProfilingInfo()
212 result.dispatches[i].label = events_[i].GetName(); in GetProfilingInfo()
[all …]
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_kqueue.cc | 109 EventVector::iterator event = events_.begin(); in AreKeventValuesValid()
110 for (; event != events_.end(); ++event) { in AreKeventValuesValid()
116 if (event != events_.end()) { in AreKeventValuesValid()
145 for (; local_event != events_.end(); ++local_event) { in HandleAttributesChange()
164 for (; local_event != events_.end(); ++local_event) { in HandleDeleteOrMoveChange()
201 for (valid = 0; valid < events_.size(); ++valid) { in UpdateWatches()
202 if (!IsKeventFileDescriptorOpen(events_[valid])) { in UpdateWatches()
212 int count = HANDLE_EINTR(kevent(kqueue_, &events_[0], valid, &updates[0], in UpdateWatches()
218 for (; valid < events_.size(); ++valid) { in UpdateWatches()
219 EventData* event_data = EventDataForKevent(events_[valid]); in UpdateWatches()
[all …]
|
| D | file_path_watcher_kqueue.h | 111 EventVector events_; variable
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | ChannelTrace.java | 24 events_ = java.util.Collections.emptyList(); in ChannelTrace()
78 events_ = new java.util.ArrayList<io.grpc.channelz.v1.ChannelTraceEvent>(); in ChannelTrace()
81 events_.add( in ChannelTrace()
94 events_ = java.util.Collections.unmodifiableList(events_); in ChannelTrace()
162 private java.util.List<io.grpc.channelz.v1.ChannelTraceEvent> events_; field in ChannelTrace
171 return events_; in getEventsList()
182 return events_; in getEventsOrBuilderList()
192 return events_.size(); in getEventsCount()
202 return events_.get(index); in getEvents()
213 return events_.get(index); in getEventsOrBuilder()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | test_utils.h | 49 events_.erase(stream); in Monitor()
54 events_.erase(stream); in Unmonitor()
71 events_.erase(socket); in Monitor()
78 events_.erase(socket); in Unmonitor()
106 EventMap::iterator it = events_.find(obj); in AddEvents()
107 if (events_.end() == it) { in AddEvents()
108 events_.insert(EventMap::value_type(obj, events)); in AddEvents()
114 EventMap::iterator it = events_.find(obj); in DoCheck()
115 if ((events_.end() == it) || (0 == (it->second & event))) { in DoCheck()
124 EventMap::iterator it = events_.find(obj); in DoEvents()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | sync_handle_registry.cc | 69 auto it = events_.find(event); in RegisterEvent()
70 if (it == events_.end()) { in RegisterEvent()
71 auto result = events_.emplace(event, EventCallbackList{}); in RegisterEvent()
85 auto it = events_.find(event); in UnregisterEvent()
86 if (it == events_.end()) in UnregisterEvent()
108 events_.erase(it); in UnregisterEvent()
149 const auto iter = events_.find(ready_event); in Wait()
150 DCHECK(iter != events_.end()); in Wait()
185 for (auto it = events_.begin(); it != events_.end();) { in RemoveInvalidEventCallbacks()
192 events_.erase(it++); in RemoveInvalidEventCallbacks()
|
| /external/perfetto/src/trace_processor/ |
| D | trace_sorter.cc | 38 PERFETTO_DCHECK(sort_start_idx_ < events_.size()); in Sort()
47 auto sort_end = events_.begin() + static_cast<ssize_t>(sort_start_idx_); in Sort()
48 PERFETTO_DCHECK(std::is_sorted(events_.begin(), sort_end)); in Sort()
49 auto sort_begin = std::lower_bound(events_.begin(), sort_end, sort_min_ts_, in Sort()
51 std::sort(sort_begin, events_.end()); in Sort()
56 PERFETTO_DCHECK(std::is_sorted(events_.begin(), events_.end())); in Sort()
98 if (queue.events_.empty()) in SortAndExtractEventsBeyondWindow()
118 auto& events = queue.events_; in SortAndExtractEventsBeyondWindow()
171 queue.min_ts_ = queue.events_.front().timestamp; in SortAndExtractEventsBeyondWindow()
|
| D | trace_sorter.h | 188 events_.emplace_back(std::move(ttp)); in Append()
201 PERFETTO_DCHECK(events_.size() >= 2); in Append()
202 sort_start_idx_ = events_.size() - 1; in Append()
215 base::CircularQueue<TimestampedTracePiece> events_; member
|
| /external/libchrome/base/message_loop/ |
| D | message_pump_glib_unittest.cc | 48 if (events_.empty()) in HandlePrepare()
50 TimeDelta delta = events_[0].time - Time::NowFromSystemTime(); in HandlePrepare()
55 if (events_.empty()) in HandleCheck()
57 return events_[0].time <= Time::NowFromSystemTime(); in HandleCheck()
61 if (events_.empty()) in HandleDispatch()
63 Event event = std::move(events_[0]); in HandleDispatch()
64 events_.erase(events_.begin()); in HandleDispatch()
88 events_.clear(); in Reset()
106 if (!events_.empty()) in AddEventHelper()
107 last_time = (events_.end()-1)->time; in AddEventHelper()
[all …]
|
| /external/usrsctp/usrsctplib/netinet/ |
| D | sctp_userspace.c | 342 cv->events_[C_SIGNAL] = CreateEvent (NULL, FALSE, FALSE, NULL); in InitializeXPConditionVariable()
343 cv->events_[C_BROADCAST] = CreateEvent (NULL, TRUE, FALSE, NULL); in InitializeXPConditionVariable()
349 CloseHandle(cv->events_[C_BROADCAST]); in DeleteXPConditionVariable()
350 CloseHandle(cv->events_[C_SIGNAL]); in DeleteXPConditionVariable()
363 result = WaitForMultipleObjects(2, cv->events_, FALSE, INFINITE); in SleepXPConditionVariable()
372 ResetEvent(cv->events_[C_BROADCAST]); in SleepXPConditionVariable()
385 SetEvent (cv->events_[C_BROADCAST]); in WakeAllXPConditionVariable()
|
| /external/tensorflow/tensorflow/core/profiler/internal/cpu/ |
| D | host_tracer.cc | 73 TraceMeRecorder::Events events_; member in tensorflow::profiler::__anon3ba6ca540111::HostTracer
101 events_ = TraceMeRecorder::Stop(); in Stop()
117 for (TraceMeRecorder::ThreadEvents& thread : events_) { in CollectData()
144 events_.clear(); in CollectData()
154 ConvertCompleteEventsToXPlane(start_timestamp_ns_, std::exchange(events_, {}), in CollectData()
|
| /external/libchrome/base/threading/ |
| D | thread_perftest.cc | 185 events_.push_back(std::make_unique<WaitableEventType>( in Init()
191 void Reset() override { events_.clear(); } in Reset()
194 size_t next_event = (event + 1) % events_.size(); in WaitAndSignalOnThread()
197 events_[event]->Wait(); in WaitAndSignalOnThread()
199 events_[next_event]->Signal(); in WaitAndSignalOnThread()
216 events_.front()->Signal(); in PingPong()
220 std::vector<std::unique_ptr<WaitableEventType>> events_; member in base::__anon0179c7fc0111::EventPerfTest
|
| /external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/ |
| D | pod_tpu_driver.cc | 88 : PodEvent(driver, operation_id), events_(events) { in CombinedEvent()
89 for (auto& event : events_) { in CombinedEvent()
95 for (auto& event : events_) { in Await()
103 for (auto& event : events_) { in AwaitWithTimeout()
121 all_events_completed = events_completed_ == events_.size(); in AddCallback()
139 if (events_completed_ == events_.size()) { in IncrementAndCheckComplete()
154 std::vector<std::shared_ptr<Event>> events_; member in tpu_driver::__anon2989b0910111::CombinedEvent
726 auto event = events_.find(event_id); in WaitForEvent()
728 if (event == events_.end()) { in WaitForEvent()
741 return events_.count(event_id) == 0 || in WaitForEvent()
[all …]
|
| D | grpc_tpu_driver.cc | 299 absl::flat_hash_map<EventId, EventInfo> events_
477 for (const auto& e : events_) { in ~GrpcTpuStream()
512 events_[operation_id] = event_info; in InitializeRequest()
516 auto it = events_.find(id); in UpdateEventStatus()
521 if (it == events_.end()) { in UpdateEventStatus()
548 events_.erase(it); in UpdateEventStatus()
554 auto it = events_.find(id); in DeleteEvent()
555 CHECK(it != events_.end()); in DeleteEvent()
560 events_.erase(it); in DeleteEvent()
567 auto it = events_.find(id); in WaitForEvent()
[all …]
|
| /external/libchrome/base/test/launcher/ |
| D | test_launcher_tracer.cc | 23 event.name = StringPrintf("process #%zu", events_.size()); in RecordProcessExecution()
27 events_.push_back(event); in RecordProcessExecution()
34 for (const Event& event : events_) { in Dump()
|
| D | test_launcher_tracer.h | 45 std::vector<Event> events_; variable
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | proto_translation_table.cc | 483 events_(BuildEventsDeque(events)), in ProtoTranslationTable()
484 largest_id_(events_.size() - 1), in ProtoTranslationTable()
491 &events_.at(event.ftrace_event_id); in ProtoTranslationTable()
492 name_to_events_[event.name].push_back(&events_.at(event.ftrace_event_id)); in ProtoTranslationTable()
493 group_to_events_[event.group].push_back(&events_.at(event.ftrace_event_id)); in ProtoTranslationTable()
513 events_.resize(ftrace_event.id + 1); in GetOrCreateEvent()
518 Event* e = &events_.at(ftrace_event.id); in GetOrCreateEvent()
534 group_and_name_to_event_[group_and_name] = &events_.at(e->ftrace_event_id); in GetOrCreateEvent()
535 name_to_events_[e->name].push_back(&events_.at(e->ftrace_event_id)); in GetOrCreateEvent()
536 group_to_events_[e->group].push_back(&events_.at(e->ftrace_event_id)); in GetOrCreateEvent()
|
| D | proto_translation_table.h | 127 const Event* evt = &events_[id]; in GetEventById()
139 const std::deque<Event>& events() { return events_; } in events()
184 std::deque<Event> events_; variable
|
| /external/tensorflow/tensorflow/core/profiler/utils/ |
| D | event_span.cc | 329 void StepDetails::AddEvent(const EventTypeSpan& e) { events_.push_back(e); } in AddEvent()
336 events_.insert(events_.end(), other_events.begin(), other_events.end()); in AppendEvents()
426 for (int i = 0, end = events_.size(); i < end; i++) { in DebugString()
428 absl::StrAppend(&result, PrintEventTypeSpan(events_[i])); in DebugString()
440 if (events_.size() != other_events.size()) return false; in operator ==()
441 for (uint64 i = 0; i < events_.size(); i++) { in operator ==()
442 if (events_[i] != other_events[i]) return false; in operator ==()
|
| D | event_span.h | 153 const std::vector<EventTypeSpan>& Events() const { return events_; } in Events()
163 std::vector<EventTypeSpan>* MutableEvents() { return &events_; } in MutableEvents()
206 std::vector<EventTypeSpan> events_; variable
|
| /external/libchrome/base/test/ |
| D | sequenced_task_runner_test_template.cc | 76 events_.push_back(TaskEvent(i, TaskEvent::POST)); in TaskPosted()
81 events_.push_back(TaskEvent(i, TaskEvent::START)); in TaskStarted()
86 events_.push_back(TaskEvent(i, TaskEvent::END)); in TaskEnded()
93 return events_; in GetTaskEvents()
|
| /external/tensorflow/tensorflow/core/profiler/internal/gpu/ |
| D | cupti_collector.cc | 319 events_.emplace_back(std::move(event)); in AddEvent()
322 events_.emplace_back(std::move(event)); in AddEvent()
336 for (const CuptiTracerEvent& event : events_) { in Flush()
447 events_.clear(); in Flush()
456 for (auto& event : events_) { in Flush()
482 size_t num_events = events_.size(); in Flush()
483 events_.clear(); in Flush()
588 std::vector<CuptiTracerEvent> events_ TF_GUARDED_BY(m_);
|
| /external/tensorflow/tensorflow/core/profiler/internal/ |
| D | tfprof_timeline.cc | 80 events_.push_back(event); in EmitFlowStart()
87 events_.push_back(event); in EmitFlowEnd()
98 events_.push_back(event); in EmitCounter()
124 events_.push_back(event2); in EmitCounter()
133 for (const Json::Value& v : events_) { in Format()
|
| /external/libchrome/ipc/ |
| D | ipc_sync_channel_unittest.cc | 1423 events_(events), in RestrictedDispatchDeadlockServer()
1427 events_[3]->Signal(); in OnDoServerTask()
1428 events_[2]->Wait(); in OnDoServerTask()
1429 events_[0]->Signal(); in OnDoServerTask()
1465 WaitableEvent** events_; member in IPC::__anon60820dc30111::RestrictedDispatchDeadlockServer
1478 events_(events), in RestrictedDispatchDeadlockClient2()
1488 events_[3]->Wait(); in OnDoClient2Task()
1489 events_[1]->Signal(); in OnDoClient2Task()
1490 events_[2]->Signal(); in OnDoClient2Task()
1523 WaitableEvent** events_; member in IPC::__anon60820dc30111::RestrictedDispatchDeadlockClient2
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | sync_handle_registry.h | 73 EventMap events_; variable
|