Skip to content

Commit

Permalink
fpm: Add func to encode SRv6 SIDs in protobuf
Browse files Browse the repository at this point in the history 
Add a bunch of helper functions to support encoding of SRv6 SIDs in
protobuf.

Specifically,
* `fpm_srv6_sid_format_create`: encode SID format information into a
protobuf `SRv6SIDFormat` structure
* `fpm_srv6_local_sid_*_behavior_create` functions: encode an SRv6 SID
behavior and associated attributes into a protobuf
`Fpm__SRv6LocalSID__*` structure

This is a preliminary commit to support sending SRv6 Local SIDs and VPN
SIDs via protobuf.

Signed-off-by: Carmine Scarpitta <[email protected]>
  • Loading branch information
@cscarpitta
cscarpitta committed Feb 18, 2024
1 parent b1f1cb9 commit 154bce3
Showing 1 changed file with 308 additions and 0 deletions.
308 changes: 308 additions & 0 deletions fpm/fpm_pb.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,9 @@
* @copyright Copyright (C) 2016 Sproute Networks, Inc.
*
* @author Avneesh Sachdev <[email protected]>
*
* Portions:
* Copyright (C) 2024 Carmine Scarpitta (for SRv6)
*/

/*
Expand Down Expand Up @@ -134,4 +137,309 @@ static inline int fpm__nexthop__get(const Fpm__Nexthop *nh,
return 0;
}

/*
* fpm__srv6_sid_format__create
*/
#define fpm_srv6_sid_format_create fpm__srv6_sid_format__create
static inline Fpm__SRv6SIDFormat *
fpm__srv6_sid_format__create(qpb_allocator_t *allocator,
uint8_t locator_block_length,
uint8_t locator_node_length,
uint8_t function_length, uint8_t argument_length)
{
Fpm__SRv6SIDFormat *sid_format;

sid_format = QPB_ALLOC(allocator, typeof(*sid_format));
if (!sid_format)
return NULL;
fpm__srv6_sidformat__init(sid_format);

sid_format->locator_block_length = locator_block_length;
sid_format->locator_node_length = locator_node_length;
sid_format->function_length = function_length;
sid_format->argument_length = argument_length;

return sid_format;
}

/*
* fpm__srv6_local_sid_end_behavior__create
*/
#define fpm_srv6_local_sid_end_behavior_create \
fpm__srv6_local_sid_end_behavior__create
static inline Fpm__SRv6LocalSID__End *
fpm__srv6_local_sid_end_behavior__create(qpb_allocator_t *allocator)
{
Fpm__SRv6LocalSID__End *end;

end = QPB_ALLOC(allocator, typeof(*end));
if (!end)
return NULL;

fpm__srv6_local_sid__end__init(end);

return end;
}

/*
* fpm__srv6_local_sid_end_x_behavior__create
*/
#define fpm_srv6_local_sid_end_x_behavior_create \
fpm__srv6_local_sid_end_x_behavior__create
static inline Fpm__SRv6LocalSID__EndX *
fpm__srv6_local_sid_end_x_behavior__create(qpb_allocator_t *allocator,
struct nexthop *nexthop)
{
Fpm__SRv6LocalSID__EndX *end_x;

end_x = QPB_ALLOC(allocator, typeof(*end_x));
if (!end_x)
return NULL;

fpm__srv6_local_sid__end_x__init(end_x);

end_x->nexthop = fpm_nexthop_create(allocator, nexthop);

return end_x;
}

/*
* fpm__srv6_local_sid_end_t_behavior__create
*/
#define fpm_srv6_local_sid_end_t_behavior_create \
fpm__srv6_local_sid_end_t_behavior__create
static inline Fpm__SRv6LocalSID__EndT *
fpm__srv6_local_sid_end_t_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__EndT *end_t;

end_t = QPB_ALLOC(allocator, typeof(*end_t));
if (!end_t)
return NULL;

fpm__srv6_local_sid__end_t__init(end_t);

end_t->vrf_id = vrf_id;

return end_t;
}

/*
* fpm__srv6_local_sid_end_dx6_behavior__create
*/
#define fpm_srv6_local_sid_end_dx6_behavior_create \
fpm__srv6_local_sid_end_dx6_behavior__create
static inline Fpm__SRv6LocalSID__EndDX6 *
fpm__srv6_local_sid_end_dx6_behavior__create(qpb_allocator_t *allocator,
struct nexthop *nexthop)
{
Fpm__SRv6LocalSID__EndDX6 *end_dx6;

end_dx6 = QPB_ALLOC(allocator, typeof(*end_dx6));
if (!end_dx6)
return NULL;

fpm__srv6_local_sid__end_dx6__init(end_dx6);

end_dx6->nexthop = fpm_nexthop_create(allocator, nexthop);

return end_dx6;
}

/*
* fpm__srv6_local_sid_end_dx4_behavior__create
*/
#define fpm_srv6_local_sid_end_dx4_behavior_create \
fpm__srv6_local_sid_end_dx4_behavior__create
static inline Fpm__SRv6LocalSID__EndDX4 *
fpm__srv6_local_sid_end_dx4_behavior__create(qpb_allocator_t *allocator,
struct nexthop *nexthop)
{
Fpm__SRv6LocalSID__EndDX4 *end_dx4;

end_dx4 = QPB_ALLOC(allocator, typeof(*end_dx4));
if (!end_dx4)
return NULL;

fpm__srv6_local_sid__end_dx4__init(end_dx4);

end_dx4->nexthop = fpm_nexthop_create(allocator, nexthop);

return end_dx4;
}

/*
* fpm__srv6_local_sid_end_dt6_behavior__create
*/
#define fpm_srv6_local_sid_end_dt6_behavior_create \
fpm__srv6_local_sid_end_dt6_behavior__create
static inline Fpm__SRv6LocalSID__EndDT6 *
fpm__srv6_local_sid_end_dt6_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__EndDT6 *end_dt6;

end_dt6 = QPB_ALLOC(allocator, typeof(*end_dt6));
if (!end_dt6)
return NULL;

fpm__srv6_local_sid__end_dt6__init(end_dt6);

end_dt6->vrf_id = vrf_id;

return end_dt6;
}

/*
* fpm__srv6_local_sid_end_dt4_behavior__create
*/
#define fpm_srv6_local_sid_end_dt4_behavior_create \
fpm__srv6_local_sid_end_dt4_behavior__create
static inline Fpm__SRv6LocalSID__EndDT4 *
fpm__srv6_local_sid_end_dt4_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__EndDT4 *end_dt4;

end_dt4 = QPB_ALLOC(allocator, typeof(*end_dt4));
if (!end_dt4)
return NULL;

fpm__srv6_local_sid__end_dt4__init(end_dt4);

end_dt4->vrf_id = vrf_id;

return end_dt4;
}

/*
* fpm__srv6_local_sid_end_dt46_behavior__create
*/
#define fpm_srv6_local_sid_end_dt46_behavior_create \
fpm__srv6_local_sid_end_dt46_behavior__create
static inline Fpm__SRv6LocalSID__EndDT46 *
fpm__srv6_local_sid_end_dt46_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__EndDT46 *end_dt46;

end_dt46 = QPB_ALLOC(allocator, typeof(*end_dt46));
if (!end_dt46)
return NULL;

fpm__srv6_local_sid__end_dt46__init(end_dt46);

end_dt46->vrf_id = vrf_id;

return end_dt46;
}

/*
* fpm__srv6_local_sid_un_behavior__create
*/
#define fpm_srv6_local_sid_un_behavior_create \
fpm__srv6_local_sid_un_behavior__create
static inline Fpm__SRv6LocalSID__UN *
fpm__srv6_local_sid_un_behavior__create(qpb_allocator_t *allocator)
{
Fpm__SRv6LocalSID__UN *un;

un = QPB_ALLOC(allocator, typeof(*un));
if (!un)
return NULL;

fpm__srv6_local_sid__un__init(un);

return un;
}

/*
* fpm__srv6_local_sid_ua_behavior__create
*/
#define fpm_srv6_local_sid_ua_behavior_create \
fpm__srv6_local_sid_ua_behavior__create
static inline Fpm__SRv6LocalSID__UA *
fpm__srv6_local_sid_ua_behavior__create(qpb_allocator_t *allocator,
struct nexthop *nexthop)
{
Fpm__SRv6LocalSID__UA *ua;

ua = QPB_ALLOC(allocator, typeof(*ua));
if (!ua)
return NULL;

fpm__srv6_local_sid__ua__init(ua);

ua->nexthop = fpm_nexthop_create(allocator, nexthop);

return ua;
}

/*
* fpm__srv6_local_sid_udt6_behavior__create
*/
#define fpm_srv6_local_sid_udt6_behavior_create \
fpm__srv6_local_sid_udt6_behavior__create
static inline Fpm__SRv6LocalSID__UDT6 *
fpm__srv6_local_sid_udt6_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__UDT6 *udt6;

udt6 = QPB_ALLOC(allocator, typeof(*udt6));
if (!udt6)
return NULL;

fpm__srv6_local_sid__udt6__init(udt6);

udt6->vrf_id = vrf_id;

return udt6;
}

/*
* fpm__srv6_local_sid_udt4_behavior__create
*/
#define fpm_srv6_local_sid_udt4_behavior_create \
fpm__srv6_local_sid_udt4_behavior__create
static inline Fpm__SRv6LocalSID__UDT4 *
fpm__srv6_local_sid_udt4_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__UDT4 *udt4;

udt4 = QPB_ALLOC(allocator, typeof(*udt4));
if (!udt4)
return NULL;

fpm__srv6_local_sid__udt4__init(udt4);

udt4->vrf_id = vrf_id;

return udt4;
}

/*
* fpm__srv6_local_sid_udt46_behavior__create
*/
#define fpm_srv6_local_sid_udt46_behavior_create \
fpm__srv6_local_sid_udt46_behavior__create
static inline Fpm__SRv6LocalSID__UDT46 *
fpm__srv6_local_sid_udt46_behavior__create(qpb_allocator_t *allocator,
vrf_id_t vrf_id)
{
Fpm__SRv6LocalSID__UDT46 *udt46;

udt46 = QPB_ALLOC(allocator, typeof(*udt46));
if (!udt46)
return NULL;

fpm__srv6_local_sid__udt46__init(udt46);

udt46->vrf_id = vrf_id;

return udt46;
}

#endif

0 comments on commit 154bce3

Please sign in to comment.