xgboost.tracker.WorkerEntry Class Reference

Public Member Functions
	__init__ (self, socket.socket sock, Tuple[str, int] s_addr)
None	print (self, bool use_logger)
int	decide_rank (self, Dict[str, int] job_map)
List[int]	assign_rank (self, int rank, Dict[int, "WorkerEntry"] wait_conn, _TreeMap tree_map, Dict[int, int] parent_map, _RingMap ring_map)

Data Fields
	sock
	host
	rank
	world_size
	task_id
	cmd
	wait_accept
	port

Protected Member Functions
List[int]	_get_remote (self, Dict[int, "WorkerEntry"] wait_conn, Set[int] nnset)

Detailed Description

Hanlder to each worker.

Member Function Documentation

assign_rank()

List[int] xgboost.tracker.WorkerEntry.assign_rank	(		self,
		int	rank,
		Dict[int, "WorkerEntry"]	wait_conn,
		_TreeMap	tree_map,
		Dict[int, int]	parent_map,
		_RingMap	ring_map
	)

Assign the rank for current entry.

decide_rank()

int xgboost.tracker.WorkerEntry.decide_rank	(		self,
		Dict[str, int]	job_map
	)

Get the rank of current entry.

print()

None xgboost.tracker.WorkerEntry.print	(		self,
		bool	use_logger
	)

Execute the print command from worker.

---

The documentation for this class was generated from the following file:

• External/xgboost/python-package/xgboost/tracker.py