Logo
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Groups Pages
Namespaces | Functions | Variables
dfs.cc File Reference
#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>
Include dependency graph for dfs.cc:

Namespaces

 velox
 

Functions

shared_ptr< FileDescriptionvelox::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