dfs-modify2.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 "../common/shared_memory.hh"
#include "../messages/IOoperation.hh"
#include "../messages/task_operation.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 <sys/resource.h>
#include <ctime>
#include <chrono>
#include <cstdio>
#include <unistd.h>

Include dependency graph for dfs-modify2.cc:

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)
uint64_t	velox::parsing_input (const char *buf, uint64_t to_write_bytes, uint64_t written_bytes, bool is_equal_sized)
model::metadata	velox::make_metadata (FileInfo *fi)

Variables
std::map< std::string, std::shared_ptr< FileDescription > >	velox::file_description_cache
std::map< std::string, std::shared_ptr< ifstream > >	velox::primary_fd
double	velox::total_read_time = 0.0
uint64_t	velox::BLOCK_SIZE
int	velox::processed_chunk
struct semaphore *	velox::sema