velox Namespace Reference

Namespaces
	model

Classes
class	DFS
class	file
class	vdfs

Typedefs
using	vec_str = std::vector< std::string >

Functions
shared_ptr< FileDescription >	get_file_description (std::function< unique_ptr< tcp::socket >(uint32_t)> connect, std::string &fname, bool logical_block=false)
void	read_from_disk (char *buf, BlockInfo chunk, uint64_t *read_bytes, uint64_t cursor, uint64_t length)
void	read_from_remote (char *buf, BlockInfo chunk, uint64_t *read_bytes, uint64_t cursor, uint64_t length, int which_node)
uint64_t	read_physical (std::string &file_name, char *buf, uint64_t off, uint64_t len, FileDescription *fd)
uint64_t	read_logical (std::string &file_name, char *buf, uint64_t off, uint64_t len, FileDescription *fd)
uint64_t	parsing_input (const char *buf, uint64_t to_write_bytes, uint64_t written_bytes, bool is_equal_sized)
model::metadata	make_metadata (FileInfo *fi)

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

Typedef Documentation

vec_str

using velox::vec_str = typedef std::vector<std::string>

Function Documentation

get_file_description()

shared_ptr< FileDescription > velox::get_file_description	(	std::function< unique_ptr< tcp::socket >(uint32_t)>	connect,
		std::string &	fname,
		bool	logical_block = false
	)

make_metadata()

model::metadata velox::make_metadata

(

FileInfo *

fi

)

parsing_input()

uint64_t velox::parsing_input	(	const char *	buf,
		uint64_t	to_write_bytes,
		uint64_t	written_bytes,
		bool	is_equal_sized
	)

read_from_disk()

void velox::read_from_disk	(	char *	buf,
		BlockInfo	chunk,
		uint64_t *	read_bytes,
		uint64_t	cursor,
		uint64_t	length
	)

read_from_remote()

void velox::read_from_remote	(	char *	buf,
		BlockInfo	chunk,
		uint64_t *	read_bytes,
		uint64_t	cursor,
		uint64_t	length,
		int	which_node
	)

read_logical()

uint64_t velox::read_logical	(	std::string &	file_name,
		char *	buf,
		uint64_t	off,
		uint64_t	len,
		FileDescription *	fd
	)

read_physical()

uint64_t velox::read_physical	(	std::string &	file_name,
		char *	buf,
		uint64_t	off,
		uint64_t	len,
		FileDescription *	fd
	)

Variable Documentation

BLOCK_SIZE

uint64_t velox::BLOCK_SIZE

failed_cnt

int velox::failed_cnt

file_description_cache

std::map< std::string, std::shared_ptr< FileDescription > > velox::file_description_cache

is_likely_finish

bool velox::is_likely_finish

likely

int velox::likely

primary_fd

std::map< std::string, std::shared_ptr< ifstream > > velox::primary_fd

processed_chunk

int velox::processed_chunk

sema

struct semaphore * velox::sema

total_read_time

double velox::total_read_time = 0.0