eclipse Namespace Reference

Namespaces
	logical_blocks_schedulers
	messages
	network

Classes
class	BlockNode
class	BlockNodeRouter
class	Local_io
	Represents the local disk. More...
struct	ChunkMetadata
struct	BlockMetadata
struct	logical_block_metadata
class	Directory
class	FileLeader
class	FileLeaderRouter
class	Router
class	RouterDecorator
class	SimpleRouter
class	Machine
class	Node
class	stats_listener
class	zk_listener
class	TaskManager
class	TaskManagerRouter

Typedefs
using	vec_str = std::vector< std::string >
template<typename T >
using	u_ptr = std::unique_ptr< T >

Functions
DistLockStatus	get_Dlock (zhandle_t *zh, string znode, bool isPrimary)
DistLockStatus	get_dist_lock (zhandle_t *zh, string target_node, string znode, bool isPrimary, bool *Stealing)
bool	read_chunk_to_shm (ifstream &ifs, messages::BlockInfo &md, struct shm_buf **cur_chunk, int idx)
void	task_worker (std::string file, struct logical_block_metadata &lblock_metadata, string _job_id, int _task_id)
void	static_worker (std::string file, struct logical_block_metadata &lblock_metadata, string _job_id, int _task_id)
bool	produce (ifstream &ifs, semaphore_t *semap, messages::BlockInfo &md, struct shm_buf **shm)
bool	produce2 (string disk_path, struct semaphore *semap, messages::BlockInfo &md, struct shm_buf **shm)
void	static_worker_by_idv (std::string file, struct logical_block_metadata &lblock_metadata, string _job_id, int _task_id)

Variables
struct timeval zk_start	zk_end
struct timeval io_start	io_end
struct timeval total_start	total_end
double	zk_time = 0.0
double	io_time = 0.0
double	total_time = 0.0

Typedef Documentation

u_ptr

template<typename T >

using eclipse::u_ptr = typedef std::unique_ptr<T>

vec_str

typedef std::vector< std::string > eclipse::vec_str

Function Documentation

get_dist_lock()

DistLockStatus eclipse::get_dist_lock	(	zhandle_t *	zh,
		string	target_node,
		string	znode,
		bool	isPrimary,
		bool *	Stealing
	)

get_Dlock()

DistLockStatus eclipse::get_Dlock	(	zhandle_t *	zh,
		string	znode,
		bool	isPrimary
	)

produce()

bool eclipse::produce	(	ifstream &	ifs,
		semaphore_t *	semap,
		messages::BlockInfo &	md,
		struct shm_buf **	shm
	)

produce2()

bool eclipse::produce2	(	string	disk_path,
		struct semaphore *	semap,
		messages::BlockInfo &	md,
		struct shm_buf **	shm
	)

read_chunk_to_shm()

bool eclipse::read_chunk_to_shm	(	ifstream &	ifs,
		messages::BlockInfo &	md,
		struct shm_buf **	cur_chunk,
		int	idx
	)

static_worker()

void eclipse::static_worker	(	std::string	file,
		struct logical_block_metadata &	lblock_metadata,
		string	_job_id,
		int	_task_id
	)

static_worker_by_idv()

void eclipse::static_worker_by_idv	(	std::string	file,
		struct logical_block_metadata &	lblock_metadata,
		string	_job_id,
		int	_task_id
	)

task_worker()

void eclipse::task_worker	(	std::string	file,
		struct logical_block_metadata &	lblock_metadata,
		string	_job_id,
		int	_task_id
	)

Variable Documentation

io_end

struct timeval io_start eclipse::io_end

io_time

double eclipse::io_time = 0.0

total_end

struct timeval total_start eclipse::total_end

total_time

double eclipse::total_time = 0.0

zk_end

struct timeval zk_start eclipse::zk_end

zk_time

double eclipse::zk_time = 0.0