From 39f2dcdfef1fe6481b61ae9524921d71833a07d2 Mon Sep 17 00:00:00 2001 From: Tianqi Chen Date: Mon, 8 Dec 2014 08:36:55 -0800 Subject: [PATCH 1/3] Update rabit_tracker.py --- src/rabit_tracker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/rabit_tracker.py b/src/rabit_tracker.py index c7068e31d..910db18b1 100644 --- a/src/rabit_tracker.py +++ b/src/rabit_tracker.py @@ -211,9 +211,9 @@ class Tracker: shutdown[s.rank] = s continue assert s.cmd == 'start' or s.cmd == 'recover' - if s.cmd == 'recover': + if s.cmd == 'recover' assert s.rank >= 0 - print 'Recieve recover signal from %d' % s.rank + print 'Recieve %s signal from %d' % (s.cmd, s.rank) rank = s.decide_rank(job_map) if rank == -1: assert len(todo_nodes) != 0 From dfb3961eea957a1b2c7f57047dc7b20bf72d289c Mon Sep 17 00:00:00 2001 From: root Date: Mon, 8 Dec 2014 17:13:42 +0000 Subject: [PATCH 2/3] changing port --- src/rabit_tracker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/rabit_tracker.py b/src/rabit_tracker.py index 910db18b1..7c5dfa1d2 100644 --- a/src/rabit_tracker.py +++ b/src/rabit_tracker.py @@ -121,7 +121,7 @@ class SlaveEntry: return rmset class Tracker: - def __init__(self, port = 9000, port_end = 9999): + def __init__(self, port = 9091, port_end = 9999): sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) for port in range(port, port_end): try: From 5aff7fab29abf44ed8f1bc2f9035df763ee4fc1d Mon Sep 17 00:00:00 2001 From: root Date: Mon, 8 Dec 2014 17:15:49 +0000 Subject: [PATCH 3/3] adding : --- src/rabit_tracker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/rabit_tracker.py b/src/rabit_tracker.py index 7c5dfa1d2..025b5938a 100644 --- a/src/rabit_tracker.py +++ b/src/rabit_tracker.py @@ -211,7 +211,7 @@ class Tracker: shutdown[s.rank] = s continue assert s.cmd == 'start' or s.cmd == 'recover' - if s.cmd == 'recover' + if s.cmd == 'recover': assert s.rank >= 0 print 'Recieve %s signal from %d' % (s.cmd, s.rank) rank = s.decide_rank(job_map)