Logo
Namespaces | Functions
task_manager_version1.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_version1.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)