'Process added and removed port events coming from OVSDB monitor.'

@registry.receives(ovs_agent_constants.OVSDB_RESOURCE, [events.AFTER_READ])
def process_trunk_port_events(self, resource, event, trigger, ovsdb_events):

    for port_event in ovsdb_events['added']:
        port_name = port_event['name']
        if is_trunk_bridge(port_name):
            LOG.debug('Processing    trunk    bridge    %s', port_name)
            eventlet.spawn_n(self.handle_trunk_add, port_name)
    for port_event in ovsdb_events['removed']:
        bridge_name = port_event['external_ids'].get('bridge_name')
        if (bridge_name and is_trunk_bridge(bridge_name)):
            eventlet.spawn_n(self.handle_trunk_remove, bridge_name, port_event)
