task_manager.cc File Reference

#include "task_manager.hh"
#include <zookeeper/zookeeper.h>
#include <iostream>
#include <algorithm>
#include <sys/time.h>

Include dependency graph for task_manager.cc:

Namespaces
	eclipse

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

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