feat(neighbor): support announce all processes

etc/exabgp/api-announce-all.ci

@@ -0,0 +1 @@
+api-announce-all.conf

etc/exabgp/api-announce-all.conf

@@ -0,0 +1,25 @@
+process add-remove {
+	run ./run/api-announce.run;
+	encoder json;
+}
+
+process add-remove-2 {
+	run ./run/api-announce-2.run;
+	encoder json;
+}
+
+neighbor 127.0.0.1 {
+	router-id 1.2.3.4;
+	local-address 127.0.0.1;
+	local-as 1;
+	peer-as 1;
+	group-updates false;
+
+	capability {
+		graceful-restart;
+	}
+
+	api {
+		processes [ all ];
+	}
+}

etc/exabgp/run/api-announce-2.run

@@ -0,0 +1,26 @@
+#!/usr/bin/env python3
+
+import os
+import sys
+import time
+
+messages = [
+    'announce route 1.3.0.0/24 next-hop 101.1.101.1',
+    'announce route 1.4.0.0/25 next-hop 101.1.101.1',
+]
+
+while messages:
+    message = messages.pop(0)
+    sys.stdout.write(message + '\n')
+    sys.stdout.flush()
+    time.sleep(0.1)
+
+try:
+    now = time.time()
+    while os.getppid() != 1 and time.time() < now + 5:
+        line = sys.stdin.readline().strip()
+        if not line or 'shutdown' in line:
+            break
+        time.sleep(1)
+except IOError:
+    pass

qa/encoding/api-announce-all.msg

@@ -0,0 +1,4 @@
+1:announce:1.1.0.0/24
+1:announce:1.2.0.0/25
+1:announce:1.3.0.0/25
+1:announce:1.4.0.0/25

src/exabgp/bgp/neighbor.py

@@ -48,6 +48,8 @@
 
 # The definition of a neighbor (from reading the configuration)
 class Neighbor(dict):
+    PROCESS_ALL = "all"
+
     class Capability(dict):
         defaults = {
             'asn4': True,

src/exabgp/configuration/configuration.py

@@ -447,7 +447,7 @@ def validate(self):
         for neighbor in self.neighbors.values():
             for notification in neighbor.api:
                 for api in neighbor.api[notification]:
-                    if not self.processes[api].get('run', ''):
+                    if neighbor.api[notification] != [neighbor.PROCESS_ALL] and not self.processes[api].get('run', ''):
                         return self.error.set(
                             "\n\nan api called '%s' is used by neighbor '%s' but not defined\n\n"
                             % (api, neighbor['peer-address']),

src/exabgp/reactor/loop.py

@@ -151,6 +151,10 @@ def peers(self, service=''):
             if service in peer.neighbor.api['processes']:
                 matching.append(peer_name)
                 continue
+            if peer.neighbor.api['processes'] == [peer.neighbor.PROCESS_ALL]:
+                matching.append(peer_name)
+                continue
+
         return matching
 
     def handle_connection(self, peer_name, connection):