> For the complete documentation index, see [llms.txt](https://yeasy.gitbook.io/openstack_code_neutron/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://yeasy.gitbook.io/openstack_code_neutron/neutron/plugins/openvswitch/agent.md).

# agent

主要包括xenapi目录（xen相关）、ovs\_neutron\_agent.py和ovs\_dvr\_neutron\_agent.py文件（运行在各个节点上的对网桥进行操作的代理）。 ovs\_neutron\_agent.py文件main函数主要过程如下：

```python
def main():
    cfg.CONF.register_opts(ip_lib.OPTS)
    common_config.init(sys.argv[1:])
    common_config.setup_logging(cfg.CONF)
    logging_config.setup_logging(cfg.CONF)
    q_utils.log_opt_values(LOG)

    try:
        agent_config = create_agent_config_map(cfg.CONF)
    except ValueError as e:
        LOG.error(_('%s Agent terminated!'), e)
        sys.exit(1)

    is_xen_compute_host = 'rootwrap-xen-dom0' in agent_config['root_helper']
    if is_xen_compute_host:
        # Force ip_lib to always use the root helper to ensure that ip
        # commands target xen dom0 rather than domU.
        cfg.CONF.set_default('ip_lib_force_root', True)

    agent = OVSNeutronAgent(**agent_config)
    signal.signal(signal.SIGTERM, handle_sigterm)

    # Start everything.
    LOG.info(_("Agent initialized successfully, now running... "))
    agent.daemon_loop()
    sys.exit(0)
```

首先是读取各种配置信息，然后提取agent相关的属性。

然后生成一个agent实例（OVSNeutronAgent类），并调用其daemon\_loop()函数，该函数进一步执行rpc\_loop()。

OVSNeutronAgent类初始化的时候，会依次调用setup\_rpc()、setup\_integration\_br()和setup\_physical\_bridges()。

ovs\_dvr\_neutron\_agent.py文件是neutron实现分布式路由器设计时的agent。

## setup\_rpc()

setup\_rpc()首先创建了两个rpc句柄，分别是

```python
self.plugin_rpc = OVSPluginApi(topics.PLUGIN)
self.state_rpc = agent_rpc.PluginReportStateAPI(topics.PLUGIN)
```

其中，前者是与neutron-server（准确的说是ovs plugin）进行通信，通过rpc消息调用plugin的方法。这些消息在neutron.agent.rpc.PluginApi类中定义，包括get\_device\_details、get\_devices\_details\_list、update\_device\_down、update\_device\_up、tunnel\_sync、security\_group\_rules\_for\_devices等。

后者是agent定期将自身的状态上报给neutron-server。

之后，创建dispatcher和所关注的消息主题：

```python
self.dispatcher = self.create_rpc_dispatcher()
        # Define the listening consumers for the agent
        consumers = [[topics.PORT, topics.UPDATE],
                     [topics.NETWORK, topics.DELETE],
                     [constants.TUNNEL, topics.UPDATE],
                     [topics.SECURITY_GROUP, topics.UPDATE]]
```

这样，neutron-server发到这四个主题的消息，会被agent接收到。agent会检查端口是否在本地，如果在本地则进行对应动作。 创建消费者rpc连接来接收rpc消息：

```python
self.connection = agent_rpc.create_consumers(self.dispatcher,
                                                     self.topic,
                                                     consumers)
```

最后，创建heartbeat，定期的调用self.\_report\_state()，通过state\_rpc来汇报本地状态。 图表 3展示了这一过程，是一个很好的理解agent端的rpc实现的例子。

![Openvswitch中agent端rpc的实现](https://github.com/yeasy/openstack_code_Neutron/tree/f46dcf5e6238c1e730845060ea2d3e4103007e88/neutron/_images/neutron.plugin.openvswitch.agent.ovs_neutron_agent.OVSNeutronAgent.png)

## setup\_integration\_br()

清除integration网桥上的int\_peer\_patch\_port端口和流表，添加一条normal流。

## setup\_physical\_bridges()

创建准备挂载物理网卡的网桥，添加一条normal流，然后创建veth对，连接到integration网桥，添加drop流规则，禁止未经转换的流量经过veth对。