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::produce (ifstream &ifs, semaphore_t *semap, messages::BlockInfo &md, struct shm_buf **shm)
bool	eclipse::produce2 (string disk_path, struct semaphore *semap, messages::BlockInfo &md, struct shm_buf **shm)
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)
void	eclipse::static_worker_by_idv (std::string file, struct logical_block_metadata &lblock_metadata, string _job_id, int _task_id)