def _write_agent_address_yaml(self, agent_dir):
    address_yaml = os.path.join(agent_dir, 'conf', 'address.yaml')
    if (not os.path.exists(address_yaml)):
        with open(address_yaml, 'w+') as f:
            (ip, port) = self.network_interfaces['thrift']
            jmx = self.jmx_port
            f.write('stomp_interface: 127.0.0.1\n')
            f.write(('local_interface: %s\n' % ip))
            f.write(('agent_rpc_interface: %s\n' % ip))
            f.write(('agent_rpc_broadcast_address: %s\n' % ip))
            f.write(('cassandra_conf: %s\n' % os.path.join(self.get_path(), 'resources', 'cassandra', 'conf', 'cassandra.yaml')))
            f.write(('cassandra_install: %s\n' % self.get_path()))
            f.write(('cassandra_logs: %s\n' % os.path.join(self.get_path(), 'logs')))
            f.write(('thrift_port: %s\n' % port))
            f.write(('jmx_port: %s\n' % jmx))
            f.close()
def _write_agent_address_yaml(self, agent_dir):
    address_yaml = os.path.join(agent_dir, 'conf', 'address.yaml')
    if (not os.path.exists(address_yaml)):
        with open(address_yaml, 'w+') as f:
            (ip, port) = self.network_interfaces['thrift']
            jmx = self.jmx_port
            f.write('stomp_interface: 127.0.0.1\n')
            f.write(('local_interface: %s\n' % ip))
            f.write(('agent_rpc_interface: %s\n' % ip))
            f.write(('agent_rpc_broadcast_address: %s\n' % ip))
            f.write(('cassandra_conf: %s\n' % os.path.join(self.get_path(), 'resources', 'cassandra', 'conf', 'cassandra.yaml')))
            f.write(('cassandra_install: %s\n' % self.get_path()))
            f.write(('cassandra_logs: %s\n' % os.path.join(self.get_path(), 'logs')))
            f.write(('thrift_port: %s\n' % port))
            f.write(('jmx_port: %s\n' % jmx))
            f.close()