Functions | |
void | append (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | close (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | combi_pread (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | create (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | exists (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | flush (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | length (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | mkdirs (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | open (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | pread (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | read (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | read_all (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | readdir (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | remove (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | rename (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | rmdir (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | seek (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | sync (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void | write (const ConnHandlerPtr &conn, const Event::Ptr &ev) |
void SWC::Comm::Protocol::FsBroker::Handler::append | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Append.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::fd, SWC::Env::FsBroker::fds(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::flags, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::FsBroker::Fds::select(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::append(), SWC::Config::Parser::args_to_strings(), SWC::DB::Specs::Fraction::decode(), and SWC::FS::FileSystem::default_write().
void SWC::Comm::Protocol::FsBroker::Handler::close | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Close.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::CloseReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::FsBroker::Fds::remove(), SWC::FsBroker::Fds::select(), SWC::Error::SERVER_NOT_READY, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::close(), SWC::FS::FileSystem::default_combi_pread(), SWC::FS::FileSystem::default_read(), SWC::FS::FileSystem::default_write(), and SWC::Comm::server::Acceptor::stop().
void SWC::Comm::Protocol::FsBroker::Handler::combi_pread | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file CombiPread.h.
References SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::amount, SWC::Core::Buffer< T >::base, SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::offset, SWC::Error::OK, SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::smartfd, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::combi_pread().
void SWC::Comm::Protocol::FsBroker::Handler::create | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 18 of file Create.h.
References SWC::FsBroker::Fds::add(), SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Env::FsBroker::fds(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::flags, SWC::Comm::Protocol::FsBroker::Params::CreateReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::FS::SmartFd::make_ptr(), SWC::Error::OK, SWC::Comm::Protocol::FsBroker::Params::CreateReq::replication, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::create(), and SWC::FS::FileSystem::default_write().
void SWC::Comm::Protocol::FsBroker::Handler::exists | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Exists.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::ExistsReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::Ranger::CompactRange::create_cs(), SWC::FS::FileSystem::default_read(), SWC::FS::FileSystem::exists(), SWC::Ranger::Range::load(), and SWC::Config::Settings::parse_file().
void SWC::Comm::Protocol::FsBroker::Handler::flush | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Flush.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::FlushReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::FsBroker::Fds::select(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::client::Query::Profiling::display(), SWC::FS::FileSystem::flush(), and SWC::Common::Stats::FlowRate::Data::print_cells_statistics().
void SWC::Comm::Protocol::FsBroker::Handler::length | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Length.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::LengthReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::Ranger::CellStore::Write::close_and_validate(), SWC::FS::FileSystem::default_read(), SWC::FS::FileSystem::default_write(), SWC::Comm::Serializable::encoded_length(), SWC::DB::Cell::Key::get(), SWC::DB::Cell::Key::get_string(), SWC::Comm::Protocol::FsBroker::Req::Length::handle(), SWC::Comm::Protocol::FsBroker::Req::Base::handle_length(), SWC::Comm::Protocol::FsBroker::Params::ReaddirRsp::internal_encoded_length(), SWC::FS::FileSystem::length(), SWC::Ranger::CellStore::Read::load_trailer(), SWC::DB::Specs::Fraction::operator==(), SWC::DB::Cells::TSV::FileReader::read(), and SWC::Manager::Schemas::store_load().
void SWC::Comm::Protocol::FsBroker::Handler::mkdirs | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Mkdirs.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::MkdirsReq::dirname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::mkdirs().
void SWC::Comm::Protocol::FsBroker::Handler::open | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Open.h.
References SWC::FsBroker::Fds::add(), SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Env::FsBroker::fds(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::flags, SWC::Comm::Protocol::FsBroker::Params::OpenReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::FS::SmartFd::make_ptr(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::default_combi_pread(), SWC::FS::FileSystem::default_read(), and SWC::FS::FileSystem::open().
void SWC::Comm::Protocol::FsBroker::Handler::pread | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Pread.h.
References SWC::Comm::Protocol::FsBroker::Params::PreadReq::amount, SWC::Core::Buffer< T >::base, SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::offset, SWC::Error::OK, SWC::Core::Buffer< T >::reallocate(), SWC::FsBroker::Fds::select(), SWC::Core::Buffer< T >::size, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::default_combi_pread(), SWC::FS::FileSystem::default_pread(), and SWC::FS::FileSystem::pread().
void SWC::Comm::Protocol::FsBroker::Handler::read | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Read.h.
References SWC::Comm::Protocol::FsBroker::Params::ReadReq::amount, SWC::Core::Buffer< T >::base, SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::ReadReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::Core::Buffer< T >::reallocate(), SWC::FsBroker::Fds::select(), SWC::Core::Buffer< T >::size, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
void SWC::Comm::Protocol::FsBroker::Handler::read_all | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 27 of file ReadAll.h.
References SWC::Core::Buffer< T >::base, SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Protocol::FsBroker::Params::ReadAllReq::name, SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
void SWC::Comm::Protocol::FsBroker::Handler::readdir | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Readdir.h.
References SWC::Core::Vector< T, SizeT, GROW_SZ >::clear(), SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::ReaddirReq::dirname, SWC::Env::FsInterface::fs(), SWC::Comm::Protocol::FsBroker::Params::ReaddirRsp::listing, SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::readdir().
void SWC::Comm::Protocol::FsBroker::Handler::remove | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Remove.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::RemoveReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
void SWC::Comm::Protocol::FsBroker::Handler::rename | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Rename.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::RenameReq::from, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, SWC_LOG_OUT, and SWC::Comm::Protocol::FsBroker::Params::RenameReq::to.
Referenced by SWC::FS::FileSystem::rename(), and SWC::FS::FileSystemLocal::rename().
void SWC::Comm::Protocol::FsBroker::Handler::rmdir | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Rmdir.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::RmdirReq::dname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::rmdir().
void SWC::Comm::Protocol::FsBroker::Handler::seek | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Seek.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::offset, SWC::Error::OK, SWC::FsBroker::Fds::select(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::seek().
void SWC::Comm::Protocol::FsBroker::Handler::sync | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Sync.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::SyncReq::fd, SWC::Env::FsBroker::fds(), SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::FsBroker::Fds::select(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.
Referenced by SWC::FS::FileSystem::sync().
void SWC::Comm::Protocol::FsBroker::Handler::write | ( | const ConnHandlerPtr & | conn, |
const Event::Ptr & | ev | ||
) |
Definition at line 17 of file Write.h.
References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::flags, SWC::Comm::Protocol::FsBroker::Params::WriteReq::fname, SWC::Env::FsInterface::fs(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::FS::SmartFd::make_ptr(), SWC::Error::OK, SWC::Comm::Protocol::FsBroker::Params::WriteReq::replication, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.