lib: Add ZAPI operations to get/release SRv6 SIDs

Add two new ZAPI operations: `ZEBRA_SRV6_MANAGER_GET_SRV6_SID` and
`ZEBRA_SRV6_MANAGER_RELEASE_SRV6_SID`. These APIs allow a daemon to get and
release an SRv6 SID, respectively.

Signed-off-by: Carmine Scarpitta <cscarpit@cisco.com>

diff --git a/lib/log.c b/lib/log.c
index 427e72703c1696bb5020989b888f4ff141fdae50..fa8a8734a4e7d77e4d2c3fd952ddf1c78374b1b2 100644 (file)
--- a/lib/log.c
+++ b/lib/log.c
@@ -437,6 +437,8 @@ static const struct zebra_desc_table command_types[] = {
        DESC_ENTRY(ZEBRA_SRV6_MANAGER_GET_LOCATOR_CHUNK),
        DESC_ENTRY(ZEBRA_SRV6_MANAGER_RELEASE_LOCATOR_CHUNK),
        DESC_ENTRY(ZEBRA_SRV6_MANAGER_GET_LOCATOR),
+       DESC_ENTRY(ZEBRA_SRV6_MANAGER_GET_SRV6_SID),
+       DESC_ENTRY(ZEBRA_SRV6_MANAGER_RELEASE_SRV6_SID),
        DESC_ENTRY(ZEBRA_ERROR),
        DESC_ENTRY(ZEBRA_CLIENT_CAPABILITIES),
        DESC_ENTRY(ZEBRA_OPAQUE_MESSAGE),

diff --git a/lib/zclient.c b/lib/zclient.c
index 90ec0241556198e8c2a926b4e959f9fa75de30e3..8308215de987e3a60e3a32136a900bcb4e0e6123 100644 (file)
--- a/lib/zclient.c
+++ b/lib/zclient.c
@@ -3309,6 +3309,109 @@ int srv6_manager_get_locator(struct zclient *zclient, const char *locator_name)
        return zclient_send_message(zclient);
 }
 
+/**
+ * Function to request an SRv6 SID in an asynchronous way
+ *
+ * @param zclient The zclient used to connect to SRv6 manager (zebra)
+ * @param ctx Context associated with the SRv6 SID
+ * @param sid_value SRv6 SID value for explicit SID allocation
+ * @param locator_name Name of the parent locator for dynamic SID allocation
+ * @param sid_func SID function assigned by the SRv6 Manager
+ * @result 0 on success, -1 otherwise
+ */
+int srv6_manager_get_sid(struct zclient *zclient, const struct srv6_sid_ctx *ctx,
+                        struct in6_addr *sid_value, const char *locator_name,
+                        uint32_t *sid_func)
+{
+       struct stream *s;
+       uint8_t flags = 0;
+       size_t len;
+       char buf[256];
+
+       if (zclient->sock < 0) {
+               flog_err(EC_LIB_ZAPI_SOCKET, "%s: invalid zclient socket",
+                        __func__);
+               return ZCLIENT_SEND_FAILURE;
+       }
+
+       if (zclient_debug)
+               zlog_debug("Getting SRv6 SID: %s",
+                          srv6_sid_ctx2str(buf, sizeof(buf), ctx));
+
+       /* send request */
+       s = zclient->obuf;
+       stream_reset(s);
+
+       zclient_create_header(s, ZEBRA_SRV6_MANAGER_GET_SRV6_SID, VRF_DEFAULT);
+
+       /* Context associated with the SRv6 SID */
+       stream_put(s, ctx, sizeof(struct srv6_sid_ctx));
+
+       /* Flags */
+       if (!sid_zero_ipv6(sid_value))
+               SET_FLAG(flags, ZAPI_SRV6_MANAGER_SID_FLAG_HAS_SID_VALUE);
+       if (locator_name)
+               SET_FLAG(flags, ZAPI_SRV6_MANAGER_SID_FLAG_HAS_LOCATOR);
+       stream_putc(s, flags);
+
+       /* SRv6 SID value */
+       if (CHECK_FLAG(flags, ZAPI_SRV6_MANAGER_SID_FLAG_HAS_SID_VALUE))
+               stream_put(s, sid_value, sizeof(struct in6_addr));
+
+       /* SRv6 locator */
+       if (CHECK_FLAG(flags, ZAPI_SRV6_MANAGER_SID_FLAG_HAS_LOCATOR)) {
+               len = strlen(locator_name);
+               stream_putw(s, len);
+               stream_put(s, locator_name, len);
+       }
+
+       /* Put length at the first point of the stream. */
+       stream_putw_at(s, 0, stream_get_endp(s));
+
+       /* Send the request to SRv6 Manager */
+       return zclient_send_message(zclient);
+}
+
+/**
+ * Function to release an SRv6 SID
+ *
+ * @param zclient Zclient used to connect to SRv6 manager (zebra)
+ * @param ctx Context associated with the SRv6 SID to be removed
+ * @result 0 on success, -1 otherwise
+ */
+int srv6_manager_release_sid(struct zclient *zclient,
+                            const struct srv6_sid_ctx *ctx)
+{
+       struct stream *s;
+       char buf[256];
+
+       if (zclient->sock < 0) {
+               flog_err(EC_LIB_ZAPI_SOCKET, "%s: invalid zclient socket",
+                        __func__);
+               return -1;
+       }
+
+       if (zclient_debug)
+               zlog_debug("Releasing SRv6 SID: %s",
+                          srv6_sid_ctx2str(buf, sizeof(buf), ctx));
+
+       /* send request */
+       s = zclient->obuf;
+       stream_reset(s);
+
+       zclient_create_header(s, ZEBRA_SRV6_MANAGER_RELEASE_SRV6_SID,
+                             VRF_DEFAULT);
+
+       /* Context associated with the SRv6 SID */
+       stream_put(s, ctx, sizeof(struct srv6_sid_ctx));
+
+       /* Put length at the first point of the stream. */
+       stream_putw_at(s, 0, stream_get_endp(s));
+
+       /* Send the SID release message */
+       return zclient_send_message(zclient);
+}
+
 /*
  * Asynchronous label chunk request
  *

diff --git a/lib/zclient.h b/lib/zclient.h
index 87617003d8f26d31ea2ba2bdf0b956887c575019..bb527f0b41b61ad5282405f0a92aebd2ecbe35d4 100644 (file)
--- a/lib/zclient.h
+++ b/lib/zclient.h
@@ -210,6 +210,8 @@ typedef enum {
        ZEBRA_SRV6_MANAGER_GET_LOCATOR_CHUNK,
        ZEBRA_SRV6_MANAGER_RELEASE_LOCATOR_CHUNK,
        ZEBRA_SRV6_MANAGER_GET_LOCATOR,
+       ZEBRA_SRV6_MANAGER_GET_SRV6_SID,
+       ZEBRA_SRV6_MANAGER_RELEASE_SRV6_SID,
        ZEBRA_ERROR,
        ZEBRA_CLIENT_CAPABILITIES,
        ZEBRA_OPAQUE_MESSAGE,
@@ -1071,12 +1073,23 @@ extern int tm_get_table_chunk(struct zclient *zclient, uint32_t chunk_size,
                              uint32_t *start, uint32_t *end);
 extern int tm_release_table_chunk(struct zclient *zclient, uint32_t start,
                                  uint32_t end);
+
+/* Zebra SRv6 Manager flags */
+#define ZAPI_SRV6_MANAGER_SID_FLAG_HAS_SID_VALUE 0x01
+#define ZAPI_SRV6_MANAGER_SID_FLAG_HAS_LOCATOR  0x02
+
 extern int srv6_manager_get_locator_chunk(struct zclient *zclient,
                                          const char *locator_name);
 extern int srv6_manager_release_locator_chunk(struct zclient *zclient,
                                              const char *locator_name);
 extern int srv6_manager_get_locator(struct zclient *zclient,
                                    const char *locator_name);
+extern int srv6_manager_get_sid(struct zclient *zclient,
+                               const struct srv6_sid_ctx *ctx,
+                               struct in6_addr *sid_value,
+                               const char *locator_name, uint32_t *sid_func);
+extern int srv6_manager_release_sid(struct zclient *zclient,
+                                   const struct srv6_sid_ctx *ctx);
 
 extern enum zclient_send_status zebra_send_sr_policy(struct zclient *zclient,
                                                     int cmd,