def sendComm(self, hostname, port, msg_type, config_data):
try:
self.sock.connect((hostname, port))
- self.send(msg_type)
- response = self.recv_msg()
+ self.sendMsg(msg_type)
+ response = self.recvMsg()
if response == ACK_MSG:
self.sendMsg(pickle.dumps(config_data))
- response = self.recv_msg()
+ response = self.recvMsg()
print "->>>>>>>>>>>>>>>>>>>>>>>>>", response
except Exception as e:
print e
def startDaemon(self, node):
print node.daemon_dir
- comm = "PYTHONPATH=/home/p2p/cs-p2p-next/bt_comm:/home/p2p/cs-p2p-next/bt_comm/start-clients/ python /home/p2p/cs-p2p-next/bt_comm/server/Server.py start " + node.public_address + " " + node.listen_port
+ comm = "PYTHONPATH=/home/p2p/cs-p2p-next/bt_comm:/home/p2p/cs-p2p-next/bt_comm/start-clients/ python /home/p2p/cs-p2p-next/bt_comm/server/Server.py start " + node.private_address + " " + node.listen_port
print comm
#self.printDummyCommand(node.public_address, node.public_port, node.ssh_port, comm)
self.sendSSHComm(node.public_address, node.username, int(node.ssh_port), comm)