#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 |