#include "dfs.hh"#include "../messages/boost_impl.hh"#include "../messages/fileinfo.hh"#include "../messages/factory.hh"#include "../messages/fileexist.hh"#include "../messages/filedescription.hh"#include "../messages/filerequest.hh"#include "../messages/filelist.hh"#include "../messages/reply.hh"#include "../messages/blockrequest.hh"#include "../common/context.hh"#include "../common/hash.hh"#include "../common/histogram.hh"#include "../common/block.hh"#include "../common/blockmetadata.hh"#include "../messages/IOoperation.hh"#include <boost/asio.hpp>#include <iostream>#include <fstream>#include <sstream>#include <iomanip>#include <fcntl.h>#include <ext/stdio_filebuf.h>#include <algorithm>#include <stack>#include <future>#include "../common/context_singleton.hh"#include <sys/resource.h>#include <ctime>#include <chrono>
Namespaces | |
| velox | |
Functions | |
| shared_ptr< FileDescription > | velox::get_file_description (std::function< unique_ptr< tcp::socket >(uint32_t)> connect, std::string &fname, bool logical_block=false) |
| void | velox::read_from_disk (char *buf, BlockInfo chunk, uint64_t *read_bytes, uint64_t cursor, uint64_t length) |
| void | velox::read_from_remote (char *buf, BlockInfo chunk, uint64_t *read_bytes, uint64_t cursor, uint64_t length, int which_node) |
| uint64_t | velox::read_physical (std::string &file_name, char *buf, uint64_t off, uint64_t len, FileDescription *fd) |
| uint64_t | velox::read_logical (std::string &file_name, char *buf, uint64_t off, uint64_t len, FileDescription *fd) |
| model::metadata | velox::make_metadata (FileInfo *fi) |
Variables | |
| std::map< std::string, std::shared_ptr < FileDescription > > | velox::file_description_cache |
1.8.6