dhcp_agent.py

dhcp 服务的 agent 端，负责实现 dhcp 的分配等。

主要包括 DhcpAgent()类、继承自它的 DhcpAgentWithStateReport 类和继承自 RpcProxy 的 DhcpPluginApi 类。

主函数为

  1. def main():
  2.     register_options()
  3.     common_config.init(sys.argv[1:])
  4.     config.setup_logging(cfg.CONF)
  5.     server = neutron_service.Service.create(
  6.         binary='neutron-dhcp-agent',
  7.         topic=topics.DHCP_AGENT,
  8.         report_interval=cfg.CONF.AGENT.report_interval,
  9.         manager='neutron.agent.dhcp_agent.DhcpAgentWithStateReport')
  10.     service.launch(server).wait()

读取和注册相关配置（包括dhcpagent、interface_driver、use_namespace等）。
然后创建一个neutron_service。绑定的主题是DHCP_AGENT，默认驱动是Dnsmasq，默认的管理器是DhcpAgentWithStateReport类
然后启动这个service。

dhcp agent的任务包括：汇报状态、处理来自plugin的RPC调用 API、管理dhcp信息。

plugin端的rpc调用方法（一般由neutron.api.v2.base.py发出通知）在neutron.api.rpc.agentnoftifiers.DhcpAgentNotifyAPI()类中实现，其中发出notification消息，会调用agent中对应的方法，包括（其中点符号替换为下划线符号）

  1. VALID_RESOURCES = ['network', 'subnet', 'port']
  2.     VALID_METHOD_NAMES = ['network.create.end',
  3.                           'network.update.end',
  4.                           'network.delete.end',
  5.                           'subnet.create.end',
  6.                           'subnet.update.end',
  7.                           'subnet.delete.end',
  8.                           'port.create.end',
  9.                           'port.update.end',
  10.                           'port.delete.end']

DhcpAgent类

继承自manager.Manager类。

manager.Manager类继承自n_rpc.RpcCallback类和periodic_task.PeriodicTasks类，提供周期性运行任务的方法。

初始化方法会首先从配置中导入driver类信息，然后获取admin的上下文。之后创建一个DhcpPluginApi类作为向plugin发出rpc消息的handler。

after_start()方法会调用run()方法，执行将neutron中状态同步到本地和孵化一个新的协程来周期性同步状态。

  1. def after_start(self):
  2.         self.run()
  3.         LOG.info(_("DHCP agent started"))
  5. def run(self):
  6.         """Activate the DHCP agent."""
  7.         self.sync_state()
  8.         self.periodic_resync()

其中sync_state()会发出rpc消息给plugin，获取最新的网络状态，然后更新本地信息，调用dnsmasq进程使之生效。该方法在启动后运行一次。
periodic_resync()方法则孵化一个协程来运行_periodic_resync_helper()方法，该函数是一个无限循环，它周期性的调用sync_state()。

DhcpPluginApi类

提供从agent往plugin一侧进行rpc调用的api。

DhcpAgentWithStateReport类

该类继承自DhcpAgent，主要添加了状态汇报。
汇报状态主要是DhcpAgentWithStateReport初始化中指定了一个agent_rpc.PluginReportStateAPI(topics.PLUGIN)类作为状态汇报rpc消息的处理handler。

  1. if report_interval:
  2.             self.heartbeat = loopingcall.FixedIntervalLoopingCall(self._report_state)
  3.             self.heartbeat.start(interval=report_interval)

这些代码会让_report_state()定期执行来汇报自身状态。
其中_report_state()方法主要代码为：

  1. self.agent_state.get('configurations').update(
  2.                 self.cache.get_state())
  3.             ctx = context.get_admin_context_without_session()
  4.             self.state_rpc.report_state(ctx, self.agent_state, self.use_call)