Home
last modified time | relevance | path

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

/system/iorap/src/inode2filename/
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);
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,
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 <<()
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()
258 void EmitFromCommandWithArgv(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandWithArgv()
337 std::optional<InodeResult> res = ParseFromLine(inode2filename_line); in EmitFromCommandWithArgv()
369 rxcpp::observable<InodeResult>
371 return rxcpp::observable<>::create<InodeResult>( in FindFilenamesFromInodes()
374 rxcpp::subscriber<InodeResult> s) { in FindFilenamesFromInodes()
[all …]
Dsearch_directories.cc891 return InodeResult::makeSuccess(search_match.inode, std::move(search_match.filename)); in SearchDirectoriesForMatchingInodes()
904 return InodeResult::makeFailure(inode, InodeResult::kCouldNotFindFilename); in SearchDirectoriesForMatchingInodes()
922 rxcpp::observable<InodeResult> SearchDirectories::FindFilenamesFromInodes( in FindFilenamesFromInodes()
967 std::pair<rxcpp::observable<InodeResult>, std::unique_ptr<SearchDirectories::RxAnyConnectable>>
985 rxcpp::observable<InodeResult>
1029 return InodeResult::makeSuccess(Inode::FromDeviceAndInode(-1, e.d_ino), std::move(e.filename)); in EmitAllInodesFromDirectories()
1033 rxcpp::observable<InodeResult>
1048 std::optional<InodeResult> match;
1069 rxcpp::observable<InodeResult> SearchDirectories::FilterFilenamesForSpecificInodes( in FilterFilenamesForSpecificInodes()
1070 rxcpp::observable<InodeResult> all_inodes, in FilterFilenamesForSpecificInodes()
[all …]
Dinode_resolver.h78 rxcpp::observable<InodeResult>
82 virtual rxcpp::observable<InodeResult>
94 virtual rxcpp::observable<InodeResult>
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()
Dout_of_process_inode_resolver.h29 virtual rxcpp::observable<InodeResult>
32 virtual rxcpp::observable<InodeResult>
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()
Ddata_source.h60 virtual rxcpp::observable<InodeResult> EmitInodes() const = 0;
Dmain.cc380 /*on_next*/[&return_code, output_format, &fout](const InodeResult& result) { in main()
/system/iorap/src/compiler/
Dcompiler.cc49 using InodeResult = iorap::inode2filename::InodeResult; typedef
459 rxcpp::observable<InodeResult> inode_results) { in ReduceResolvedInodesToMap()
462 [](InodeMap m, InodeResult result) { in ReduceResolvedInodesToMap()