diff options
| author | Mahadev Konar <mahadev@apache.org> | 2012-09-10 05:26:34 +0000 |
|---|---|---|
| committer | Mahadev Konar <mahadev@apache.org> | 2012-09-10 05:26:34 +0000 |
| commit | 0c74d8120ad5469cb67ba243c81acaa552afe3be (patch) | |
| tree | f31b4ed300de6a731bf1a0822b90591dd2afeb67 /ambari-agent | |
| parent | 39b327df9e82c72f984e3eff7158f98e646aed65 (diff) | |
AMBARI-710. Basic registration and heartbeat protocol implementation between the server and the agent. (mahadev)
git-svn-id: https://svn.apache.org/repos/asf/incubator/ambari/branches/AMBARI-666@1382641 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'ambari-agent')
| -rw-r--r-- | ambari-agent/src/main/python/ambari_agent/Controller.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ambari-agent/src/main/python/ambari_agent/Controller.py b/ambari-agent/src/main/python/ambari_agent/Controller.py index 30ea9d77ab..3dc3560b0d 100644 --- a/ambari-agent/src/main/python/ambari_agent/Controller.py +++ b/ambari-agent/src/main/python/ambari_agent/Controller.py @@ -50,7 +50,7 @@ class Controller(threading.Thread): # self.credential = { 'user' : config.get('controller', 'user'), # 'password' : config.get('controller', 'password') # } - self.url = config.get('server', 'url') + '/agent/heartbeat/' + socket.gethostname() + self.url = config.get('server', 'url') + '/agent/register/' + socket.gethostname() def start(self): self.actionQueue = ActionQueue(self.config) @@ -70,7 +70,7 @@ class Controller(threading.Thread): try: if retry==False: data = json.dumps(self.heartbeat.build(id)) - logger.debug(data) + logger.info(data) req = urllib2.Request(self.url, data, {'Content-Type': 'application/json'}) f = urllib2.urlopen(req) response = f.read() |