Home
last modified time | relevance | path

Searched refs:observable (Results 1 – 14 of 14) sorted by relevance

/system/iorap/src/inode2filename/
Dsearch_directories.h65 rxcpp::observable<InodeResult>
91 std::pair<rxcpp::observable<InodeResult>, std::unique_ptr<RxAnyConnectable>>
102 rxcpp::observable<InodeResult>
104 rxcpp::observable<Inode> inodes,
107 rxcpp::observable<InodeResult>
110 rxcpp::observable<InodeResult> FilterFilenamesForSpecificInodes(
112 rxcpp::observable<InodeResult> all_inodes,
119 rxcpp::observable<InodeResult> EmitAllFilenames(
121 rxcpp::observable<InodeResult> all_inodes,
Dinode_resolver.h78 rxcpp::observable<InodeResult>
79 FindFilenamesFromInodes(rxcpp::observable<Inode> inodes) const;
82 virtual rxcpp::observable<InodeResult>
94 virtual rxcpp::observable<InodeResult>
Dout_of_process_inode_resolver.h29 virtual rxcpp::observable<InodeResult>
32 virtual rxcpp::observable<InodeResult>
Dinode_resolver.cc126 rxcpp::observable<InodeResult>
127 InodeResolver::FindFilenamesFromInodes(rxcpp::observable<Inode> inodes) const { in FindFilenamesFromInodes()
146 rxcpp::observable<InodeResult>
152 rxcpp::observable<InodeResult> all_inodes = impl_->data_source_->EmitInodes(); in FindFilenamesFromInodes()
165 rxcpp::observable<InodeResult>
171 rxcpp::observable<InodeResult> all_inodes = impl_->data_source_->EmitInodes(); in EmitAll()
Dsearch_directories.cc123 return rxcpp::observable<>::iterate(set_).map( // XX: should we use identity_immediate here? in IterateValues()
301 using ObservableT = rx::observable<ResultT>;
567 auto MapExpectedOrLog(T&& observable, in MapExpectedOrLog() argument
569 return observable.filter([log_level](const auto& result) { in MapExpectedOrLog()
582 auto MapExpectedOrLogError(T&& observable) { in MapExpectedOrLogError() argument
583 return MapExpectedOrLog(std::forward<T>(observable), ::android::base::ERROR); in MapExpectedOrLogError()
587 auto MapOptionalOrDrop(T&& observable) { in MapOptionalOrDrop() argument
588 return observable.filter([](const auto& result) { in MapOptionalOrDrop()
669 return rx::observable<>::create<T_simple>( in TreeTraversalPreOrderObservable()
922 rxcpp::observable<InodeResult> SearchDirectories::FindFilenamesFromInodes( in FindFilenamesFromInodes()
[all …]
Ddata_source.cc71 virtual rxcpp::observable<InodeResult> EmitInodes() const override { in EmitInodes()
100 virtual rxcpp::observable<InodeResult> EmitInodes() const override { in EmitInodes()
103 return rx::observable<>::create<InodeResult>( in EmitInodes()
Dout_of_process_inode_resolver.cc369 rxcpp::observable<InodeResult>
371 return rxcpp::observable<>::create<InodeResult>( in FindFilenamesFromInodes()
379 rxcpp::observable<InodeResult>
385 return rxcpp::observable<>::create<InodeResult>( in EmitAll()
Ddata_source.h60 virtual rxcpp::observable<InodeResult> EmitInodes() const = 0;
/system/iorap/src/common/
Drx_async.h36 T&& observable, in SubscribeAsync() argument
41 observable=std::forward<T>(observable), in SubscribeAsync()
43 observable in SubscribeAsync()
55 T&& observable, in SubscribeAsync() argument
61 observable=std::forward<T>(observable), in SubscribeAsync()
64 observable in SubscribeAsync()
/system/iorap/src/compiler/
Dcompiler.cc92 rxcpp::observable<CompilationInput> file_infos) { in ReadProtosFromFileNames()
174 auto filename_obs = rxcpp::observable<>::iterate(std::move(file_infos)); in ReadPerfettoTraceProtos()
175 rxcpp::observable<PerfettoTracePtrInfo> obs = in ReadPerfettoTraceProtos()
304 return rxcpp::observable<>::create<PageCacheFtraceEvent>( in SelectPageCacheFtraceEvents()
425 rxcpp::observable<PerfettoTracePtrInfo> traces) { in SelectDistinctInodesFromTraces()
429 rxcpp::observable<PageCacheFtraceEvent> obs = SelectPageCacheFtraceEvents(std::move(trace)); in SelectDistinctInodesFromTraces()
450 rxcpp::observable<Inode> inodes, in ResolveInodesToFileNames()
459 rxcpp::observable<InodeResult> inode_results) { in ReduceResolvedInodesToMap()
556 rxcpp::observable<PerfettoTracePtrInfo> traces, in ResolvePageCacheEntriesFromProtos()
563 rxcpp::observable<Inode> distinct_inodes_obs = distinct_inodes.as_dynamic(); in ResolvePageCacheEntriesFromProtos()
[all …]
/system/iorap/src/perfetto/
Drx_producer.h187 rxcpp::observable<PerfettoTraceProto> CreateTraceStream(
188 rxcpp::observable<PerfettoStreamCommand> commands);
Dmain.cc100 rxcpp::observable<>::just(PerfettoStreamCommand::kStartTracing) in CollectPerfettoTraceBufferViaAbstractions()
105 rxcpp::observable<>::interval(std::chrono::milliseconds(arg_duration_ms * 2)) in CollectPerfettoTraceBufferViaAbstractions()
Drx_producer.cc476 auto obs = rxcpp::observable<>::create<PerfettoStateChange>( in CreatePerfettoStateStream()
747 CreatePerfettoStream(rxcpp::observable<PerfettoStreamCommand> input, in CreatePerfettoStream()
816 return rxcpp::observable<>::just(std::move(wire_proto)).as_dynamic(); in CreatePerfettoStream()
818 return rxcpp::observable<>::empty<PerfettoTraceProto>().as_dynamic(); in CreatePerfettoStream()
846 rxcpp::observable<PerfettoTraceProto> RxProducerFactory::CreateTraceStream( in CreateTraceStream()
847 rxcpp::observable<PerfettoStreamCommand> commands) { in CreateTraceStream()
/system/iorap/src/manager/
Devent_manager.cc126 rxcpp::observable<int> history_id_observable_;
220 auto history_id_observable = rxcpp::observable<>::create<int>( in OnNewEvent()
483 rxcpp::observable<>::just(PerfettoStreamCommand::kStartTracing) in StartTracing()
488 rxcpp::observable<>::interval(std::chrono::milliseconds(10000)) in StartTracing()
1049 app_launch_events_ = rxcpp::observable<>::create<AppLaunchEventRefWrapper>( in InitializeRxGraph()
1138 job_scheduled_events_ = rxcpp::observable<>::create<RequestAndJobEvent>( in InitializeRxGraphForJobScheduledEvents()
1306 rxcpp::observable<AppLaunchEventRefWrapper> app_launch_events_;
1310 rxcpp::observable<std::pair<RequestId, JobScheduledEvent>> job_scheduled_events_;
1313 rxcpp::observable<RequestId> completed_requests_;