diff options
Diffstat (limited to 'lib/zclient.c')
| -rw-r--r-- | lib/zclient.c | 76 |
1 files changed, 50 insertions, 26 deletions
diff --git a/lib/zclient.c b/lib/zclient.c index a82484e42d..92a495ac61 100644 --- a/lib/zclient.c +++ b/lib/zclient.c @@ -2461,6 +2461,8 @@ int zebra_send_mpls_labels(struct zclient *zclient, int cmd, int zapi_labels_encode(struct stream *s, int cmd, struct zapi_labels *zl) { + struct zapi_nexthop_label *znh; + stream_reset(s); zclient_create_header(s, cmd, VRF_DEFAULT); @@ -2475,20 +2477,34 @@ int zapi_labels_encode(struct stream *s, int cmd, struct zapi_labels *zl) stream_putw(s, zl->route.instance); } - stream_putc(s, zl->nexthop.type); - stream_putw(s, zl->nexthop.family); - switch (zl->nexthop.family) { - case AF_INET: - stream_put_in_addr(s, &zl->nexthop.address.ipv4); - break; - case AF_INET6: - stream_write(s, (uint8_t *)&zl->nexthop.address.ipv6, 16); - break; - default: - break; + if (zl->nexthop_num > MULTIPATH_NUM) { + flog_err( + EC_LIB_ZAPI_ENCODE, + "%s: label %u: can't encode %u nexthops (maximum is %u)", + __func__, zl->local_label, zl->nexthop_num, + MULTIPATH_NUM); + return -1; + } + stream_putw(s, zl->nexthop_num); + + for (int i = 0; i < zl->nexthop_num; i++) { + znh = &zl->nexthops[i]; + + stream_putc(s, znh->type); + stream_putw(s, znh->family); + switch (znh->family) { + case AF_INET: + stream_put_in_addr(s, &znh->address.ipv4); + break; + case AF_INET6: + stream_write(s, (uint8_t *)&znh->address.ipv6, 16); + break; + default: + break; + } + stream_putl(s, znh->ifindex); + stream_putl(s, znh->label); } - stream_putl(s, zl->nexthop.ifindex); - stream_putl(s, zl->nexthop.label); /* Put length at the first point of the stream. */ stream_putw_at(s, 0, stream_get_endp(s)); @@ -2498,6 +2514,8 @@ int zapi_labels_encode(struct stream *s, int cmd, struct zapi_labels *zl) int zapi_labels_decode(struct stream *s, struct zapi_labels *zl) { + struct zapi_nexthop_label *znh; + memset(zl, 0, sizeof(*zl)); /* Get data. */ @@ -2545,20 +2563,26 @@ int zapi_labels_decode(struct stream *s, struct zapi_labels *zl) STREAM_GETW(s, zl->route.instance); } - STREAM_GETC(s, zl->nexthop.type); - STREAM_GETW(s, zl->nexthop.family); - switch (zl->nexthop.family) { - case AF_INET: - STREAM_GET(&zl->nexthop.address.ipv4.s_addr, s, IPV4_MAX_BYTELEN); - break; - case AF_INET6: - STREAM_GET(&zl->nexthop.address.ipv6, s, 16); - break; - default: - break; + STREAM_GETW(s, zl->nexthop_num); + for (int i = 0; i < zl->nexthop_num; i++) { + znh = &zl->nexthops[i]; + + STREAM_GETC(s, znh->type); + STREAM_GETW(s, znh->family); + switch (znh->family) { + case AF_INET: + STREAM_GET(&znh->address.ipv4.s_addr, s, + IPV4_MAX_BYTELEN); + break; + case AF_INET6: + STREAM_GET(&znh->address.ipv6, s, 16); + break; + default: + break; + } + STREAM_GETL(s, znh->ifindex); + STREAM_GETL(s, znh->label); } - STREAM_GETL(s, zl->nexthop.ifindex); - STREAM_GETL(s, zl->nexthop.label); return 0; stream_failure: |