Home
last modified time | relevance | path

Searched refs:InodeResult (Results 1 – 12 of 12) sorted by relevance

/aosp12/system/iorap/src/inode2filename/
H A Dinode_result.h32 struct InodeResult { struct
46 static InodeResult makeSuccess(Inode inode, std::string filename) { in makeSuccess() argument
47 return InodeResult{inode, std::move(filename)}; in makeSuccess()
50 static InodeResult makeFailure(Inode inode, int err_no) { in makeFailure() argument
51 return InodeResult{inode, iorap::unexpected{err_no}}; in makeFailure()
58 constexpr bool operator==(const InodeResult& other) const {
70 constexpr bool operator!=(const InodeResult& other) const {
78 std::ostream& operator<<(std::ostream& os, const InodeResult& result);
H A Dsearch_directories.h65 rxcpp::observable<InodeResult>
91 std::pair<rxcpp::observable<InodeResult>, std::unique_ptr<RxAnyConnectable>>
102 rxcpp::observable<InodeResult>
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,
H A Dout_of_process_inode_resolver.cc121 std::optional<InodeResult> ParseFromLine(const std::string& line) { in ParseFromLine()
169 return InodeResult::makeFailure(inode, error_code); in ParseFromLine()
184 return InodeResult::makeSuccess(inode, file_name); in ParseFromLine()
235 void EmitFromCommandFind(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandFind()
251 void EmitFromCommandAll(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandAll()
369 rxcpp::observable<InodeResult>
371 return rxcpp::observable<>::create<InodeResult>( in FindFilenamesFromInodes()
374 rxcpp::subscriber<InodeResult> s) { in FindFilenamesFromInodes()
379 rxcpp::observable<InodeResult>
385 return rxcpp::observable<>::create<InodeResult>( in EmitAll()
[all …]
H A Dsearch_directories.cc904 return InodeResult::makeFailure(inode, InodeResult::kCouldNotFindFilename); in SearchDirectoriesForMatchingInodes()
985 rxcpp::observable<InodeResult>
1033 rxcpp::observable<InodeResult>
1048 std::optional<InodeResult> match;
1070 rxcpp::observable<InodeResult> all_inodes, in FilterFilenamesForSpecificInodes()
1207 return InodeResult::makeFailure(inode, InodeResult::kCouldNotFindFilename); in FilterFilenamesForSpecificInodes()
1237 return InodeResult::makeFailure(result.inode, InodeResult::kVerificationFailed); in FilterFilenamesForSpecificInodes()
1245 error_code = InodeResult::kVerificationFailed; in FilterFilenamesForSpecificInodes()
1266 rxcpp::observable<InodeResult> all_inodes, in EmitAllFilenames()
1276 using EmitAllState = std::optional<InodeResult>; in EmitAllFilenames()
[all …]
H A Dinode_result.cc21 std::optional<std::string_view> InodeResult::ErrorMessage() const { in ErrorMessage()
30 case InodeResult::kCouldNotFindFilename: in ErrorMessage()
32 case InodeResult::kVerificationFailed: in ErrorMessage()
41 std::ostream& operator<<(std::ostream& os, const InodeResult& result) { in operator <<()
H A 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()
104 [file_name](rx::subscriber<InodeResult> dest) { in EmitInodes()
150 dest.on_next(InodeResult::makeSuccess(inode, value_filename)); in EmitInodes()
H A Dinode_resolver.cc126 rxcpp::observable<InodeResult>
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()
H A Dinode_resolver.h78 rxcpp::observable<InodeResult>
82 virtual rxcpp::observable<InodeResult>
94 virtual rxcpp::observable<InodeResult>
H A Dout_of_process_inode_resolver.h29 virtual rxcpp::observable<InodeResult>
32 virtual rxcpp::observable<InodeResult>
H A Ddata_source.h60 virtual rxcpp::observable<InodeResult> EmitInodes() const = 0;
H A Dmain.cc380 /*on_next*/[&return_code, output_format, &fout](const InodeResult& result) { in main()
/aosp12/system/iorap/src/compiler/
H A Dcompiler.cc49 using InodeResult = iorap::inode2filename::InodeResult; typedef
459 rxcpp::observable<InodeResult> inode_results) { in ReduceResolvedInodesToMap()
462 [](InodeMap m, InodeResult result) { in ReduceResolvedInodesToMap()