SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
SWC::Comm::Protocol::FsBroker::Handler Namespace Reference

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)
 

Function Documentation

◆ append()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ close()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ combi_pread()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ create()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ exists()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ flush()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ length()

◆ mkdirs()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ open()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ pread()

void SWC::Comm::Protocol::FsBroker::Handler::pread ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

◆ read()

◆ read_all()

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.

+ Here is the call graph for this function:

◆ readdir()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ remove()

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.

+ Here is the call graph for this function:

◆ rename()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ rmdir()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ seek()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ sync()

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ write()

void SWC::Comm::Protocol::FsBroker::Handler::write ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)