lib: Replace shim IPCPs with points of attachment

Removes the UDP and Ethernet shim IPCPs. The unicast and broadcast
IPCPs can now directly attach to a "legacy" socket. We adopt Saltzer's
Point-of-Attachment terminology, also advocated in Day's "Patterns in
Network Architecture". The "poa" component manages these
PoA's with one management thread, one link monitoring thread and one
thread per attached point.

For Ethernet PoA's the irm connect and enroll can resolve the
destination IPCP or Layer name with a broadcast name query over the
attached PoAs (first reply wins). UDP PoA's require a destination IP
address or FQDN.

attach to a local endpoint (required both server and client side):

 irm ipcp poa attach name a udp 10.0.0.1
 irm ipcp poa attach name a udp 10.0.0.1:3435
 irm ipcp poa attach name a udp [::1]:3435
 irm ipcp poa attach name a eth dev eth0
 irm ipcp poa attach name a eth dev eth0 ethertype 0xA000

release a PoA (refused while it carries a flow):

 irm ipcp poa detach name a udp 10.0.0.1:3435
 irm ipcp poa detach name a eth eth0

list an IPCP's PoAs:

 irm ipcp poa list name a

connect to a peer, by name or at an address:

 irm ipcp connect name b dst a
 irm ipcp connect name b dst a eth
 irm ipcp connect name b dst a eth dev eth0
 irm ipcp connect name b dst a udp 10.0.0.1:3435
 irm ipcp connect name b dst a udp peer.example.com:3435

disconnect by peer name, no address:

 irm ipcp disconnect name b dst a
 irm ipcp disconnect name b dst a component mgmt

enroll has the same shape as connect:

 irm ipcp enroll name b layer lr autobind
 irm ipcp enroll name b layer lr autobind eth dev eth0
 irm ipcp enroll name b layer lr autobind udp 10.0.0.1:3435

the IRMd config file attaches PoAs and names peers the same way:

 udp = [ "10.0.0.1", "10.0.0.1:3436" ]
 eth = [ "eth0", {dev="eth1", ethertype=0xA007} ]

 enrol={dst="LAN", eth={dev="eth0"}}
 conn=[{dst="lan3", eth={}}, {dst="lan4", udp="10.0.0.1:3435"}]

Signed-off-by: Dimitri Staessens <dimitri@ouroboros.rocks>
Signed-off-by: Sander Vrijders <sander@ouroboros.rocks>

1 files changed, 40 insertions, 31 deletions

diff --git a/src/irmd/ipcp.h b/src/irmd/ipcp.h
index 8d06623c..1f257e7d 100644
--- a/src/irmd/ipcp.h
+++ b/src/irmd/ipcp.h
@@ -27,48 +27,57 @@
 #ifndef OUROBOROS_IRMD_IPCP_H
 #define OUROBOROS_IRMD_IPCP_H
 
-int   ipcp_enroll(pid_t               pid,
-                  const char *        dst,
-                  struct layer_info * info);
+int     ipcp_enroll(pid_t                   pid,
+                    const char *            dst,
+                    const struct poa_addr * addr,
+                    struct layer_info *     info);
 
-int   ipcp_bootstrap(pid_t                pid,
-                     struct ipcp_config * conf,
-                     struct layer_info *  info);
+int     ipcp_attach(pid_t                   pid,
+                    const struct poa_spec * poa,
+                    bool                    attach);
 
-int   ipcp_connect(pid_t        pid,
-                   const char * dst,
-                   const char * component,
-                   qosspec_t    qs);
+ssize_t ipcp_list_poas(pid_t              pid,
+                       struct poa_spec ** eps);
 
-int   ipcp_disconnect(pid_t        pid,
-                      const char * dst,
-                      const char * component);
+int     ipcp_bootstrap(pid_t                pid,
+                       struct ipcp_config * conf,
+                       struct layer_info *  info);
 
-int   ipcp_reg(pid_t          pid,
-               const buffer_t hash);
+int     ipcp_connect(pid_t                   pid,
+                     const char *            dst,
+                     const char *            component,
+                     qosspec_t               qs,
+                     const struct poa_addr * addr);
 
-int   ipcp_unreg(pid_t          pid,
+int     ipcp_disconnect(pid_t        pid,
+                        const char * dst,
+                        const char * component);
+
+int     ipcp_reg(pid_t          pid,
                  const buffer_t hash);
 
-int   ipcp_query(pid_t          pid,
-                 const buffer_t dst);
+int     ipcp_unreg(pid_t          pid,
+                   const buffer_t hash);
+
+int     ipcp_query(pid_t          pid,
+                   const buffer_t dst);
 
-int   ipcp_flow_alloc(const struct flow_info * flow,
-                      const buffer_t           hash,
-                      const buffer_t           data);
+int     ipcp_flow_alloc(const struct flow_info * flow,
+                        const buffer_t           hash,
+                        const buffer_t           data);
 
-int   ipcp_flow_join(const struct flow_info * flow,
-                     const buffer_t           dst);
+int     ipcp_flow_join(const struct flow_info * flow,
+                       const buffer_t           dst);
 
-int   ipcp_flow_alloc_resp(const struct flow_info * flow,
-                           int                      response,
-                           const buffer_t           data);
+int     ipcp_flow_alloc_resp(const struct flow_info * flow,
+                             int                      response,
+                             const buffer_t           data);
 
-int   ipcp_flow_dealloc(pid_t  pid,
-                        int    flow_id,
-                        time_t timeo);
+int     ipcp_flow_dealloc(pid_t  pid,
+                          int    flow_id,
+                          time_t timeo);
 
-int   ipcp_flow_update(const struct flow_info * flow,
-                       const buffer_t           data);
+int     ipcp_flow_update(const struct flow_info * flow,
+                         const buffer_t           data);
 
 #endif /* OUROBOROS_IRMD_IPCP_H */