| ashu | ef3490b | 2015-02-17 11:01:04 -0600 | [diff] [blame] | 1 | #!/usr/bin/env python |
| 2 | |
| 3 | import time |
| ashu | ef3490b | 2015-02-17 11:01:04 -0600 | [diff] [blame] | 4 | |
| 5 | class Nfd: |
| 6 | def __init__(self, node): |
| 7 | self.node = node |
| 8 | self.isRunning = False |
| 9 | |
| 10 | # Create home directory for a node |
| 11 | node.cmd("cd /tmp && mkdir %s" % node.name) |
| 12 | node.cmd("cd %s" % node.name) |
| 13 | |
| 14 | self.homeFolder = "/tmp/%s" % node.name |
| 15 | self.confFile = "%s/%s.conf" % (self.homeFolder, node.name) |
| 16 | self.logFile = "%s/%s.log" % (self.homeFolder, node.name) |
| 17 | self.sockFile = "/var/run/%s.sock" % node.name |
| 18 | self.ndnFolder = "%s/.ndn" % self.homeFolder |
| 19 | self.clientConf = "%s/client.conf" % self.ndnFolder |
| 20 | |
| ashu | ef3490b | 2015-02-17 11:01:04 -0600 | [diff] [blame] | 21 | # Copy nfd.conf file from mn-ndn/ndn_utils to the node's home |
| 22 | node.cmd("sudo cp ~/mn-ndn/ndn_utils/nfd.conf %s" % self.confFile) |
| 23 | |
| 24 | # Open the conf file and change socket file name |
| 25 | node.cmd("sudo sed -i 's|nfd.sock|%s.sock|g' %s" % (node.name, self.confFile)) |
| 26 | |
| 27 | # Make NDN folder |
| 28 | node.cmd("sudo mkdir %s" % self.ndnFolder) |
| 29 | |
| 30 | # Copy the client.conf file and change the unix socket |
| 31 | node.cmd("sudo cp ~/mn-ndn/ndn_utils/client.conf.sample %s" % self.clientConf) |
| 32 | node.cmd("sudo sed -i 's|nfd.sock|%s.sock|g' %s" % (node.name, self.clientConf)) |
| 33 | |
| 34 | # Change home folder |
| 35 | node.cmd("export HOME=%s" % self.homeFolder) |
| 36 | |
| 37 | def start(self): |
| 38 | if self.isRunning is False: |
| 39 | self.node.cmd("sudo nfd --config %s 2>> %s &" % (self.confFile, self.logFile)) |
| 40 | self.processId = self.node.cmd("echo $!")[:-1] |
| 41 | |
| 42 | time.sleep(2) |
| 43 | |
| 44 | self.isRunning = True |
| 45 | |
| 46 | def stop(self): |
| 47 | if self.isRunning is True: |
| 48 | self.node.cmd("sudo kill %s" % self.processId) |
| 49 | |
| 50 | self.isRunning = False |
| 51 | |
| 52 | def setStrategy(self, name, strategy): |
| 53 | node.cmd("nfdc set-strategy %s ndn:/localhost/nfd/strategy/%s" % (name, strategy)) |
| 54 | time.sleep(0.5) |