mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-25 19:10:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add file_type method to the reactor

Browse Source 
This method check the file type and retrun an optional value, if the
file does not exists no value is return.

On other errors an exception will be thrown.

Signed-off-by: Amnon Heiman <amnon@cloudius-systems.com>
This commit is contained in:
Amnon Heiman
2015-03-22 19:38:00 +02:00
parent 6512d7f7fb
commit cb535f1fa9
2 changed files with 40 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
core/reactor.cc
View File

@@ -392,6 +392,45 @@ reactor::open_file_dma(sstring name, open_flags flags) {
});
}
directory_entry_type stat_to_entry_type(__mode_t type) {
if (S_ISDIR(type)) {
return directory_entry_type::directory;
}
if (S_ISBLK(type)) {
return directory_entry_type::block_device;
}
if (S_ISCHR(type)) {
return directory_entry_type::char_device;
}
if (S_ISFIFO(type)) {
return directory_entry_type::fifo;
}
if (S_ISLNK(type)) {
return directory_entry_type::link;
}
return directory_entry_type::regular;
}
future<std::experimental::optional<directory_entry_type>>
reactor::file_type(sstring name) {
return _thread_pool.submit<syscall_result_extra<struct stat>>([name] {
struct stat st;
auto ret = stat(name.c_str(), &st);
return wrap_syscall(ret, st);
}).then([] (syscall_result_extra<struct stat> sr) {
if (long(sr.result) == -1) {
if (sr.result != ENOENT && sr.result != ENOTDIR) {
sr.throw_if_error();
}
return make_ready_future<std::experimental::optional<directory_entry_type> >
(std::experimental::optional<directory_entry_type>() );
}
return make_ready_future<std::experimental::optional<directory_entry_type> >
(std::experimental::optional<directory_entry_type>(stat_to_entry_type(sr.extra.st_mode)) );
});
}
future<file>
reactor::open_directory(sstring name) {
return _thread_pool.submit<syscall_result<int>>([name] {

1
core/reactor.hh
View File

@@ -749,6 +749,7 @@ public:
future<file> open_file_dma(sstring name, open_flags flags);
future<file> open_directory(sstring name);
future<std::experimental::optional<directory_entry_type>> file_type(sstring name);
template <typename Func>
future<io_event> submit_io(Func prepare_io);