frrouting/frr
1
0
Fork 0
Code Activity
frr/pceplib/test/pcep_msg_objects_test.c
Daniel Baumann 3124f89aed
Adding upstream version 10.1.1. 
Signed-off-by: Daniel Baumann <daniel@debian.org>
2025-02-05 10:03:58 +01:00

1301 lines
48 KiB
C
Raw Blame History

// SPDX-License-Identifier: LGPL-2.1-or-later
/*
* This file is part of the PCEPlib, a PCEP protocol library.
*
* Copyright (C) 2020 Volta Networks https://voltanet.io/
*
* Author : Brady Johnson <brady@voltanet.io>
*
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <assert.h>
#include <stdlib.h>
#include <CUnit/CUnit.h>
#include "pcep_msg_encoding.h"
#include "pcep_msg_objects.h"
#include "pcep_msg_tools.h"
#include "pcep_utils_memory.h"
#include "pcep_msg_objects_test.h"
/*
* Notice:
* All of these object Unit Tests encode the created objects by explicitly
* calling pcep_encode_object() thus testing the object creation and the object
* encoding. All APIs expect IPs to be in network byte order.
*/
static struct pcep_versioning *versioning = NULL;
static uint8_t object_buf[2000];
void reset_objects_buffer(void);
int pcep_objects_test_suite_setup(void)
{
pceplib_memory_reset();
return 0;
}
int pcep_objects_test_suite_teardown(void)
{
printf("\n");
pceplib_memory_dump();
return 0;
}
void reset_objects_buffer(void)
{
memset(object_buf, 0, 2000);
}
void pcep_objects_test_setup(void)
{
versioning = create_default_pcep_versioning();
reset_objects_buffer();
}
void pcep_objects_test_teardown(void)
{
destroy_pcep_versioning(versioning);
}
/* Internal util verification function */
static void verify_pcep_obj_header2(uint8_t obj_class, uint8_t obj_type,
uint16_t obj_length, const uint8_t *obj_buf)
{
/* Object Header
*
* 0 1 2 3
* 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
* +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
* | Object-Class | OT |Res|P|I| Object Length (bytes) |
* +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
*/
/* Not using CU_ASSERT_EQUAL here, so that in case of failure,
* we can provide more info in the error message. */
if (obj_buf[0] != obj_class) {
fprintf(stderr,
"Test failure obj_class expected [%d] found [%d]\n",
obj_class, obj_buf[0]);
CU_FAIL("Object Header Class");
}
uint8_t found8 = (obj_buf[1] >> 4) & 0x0f;
if (obj_type != found8) {
fprintf(stderr,
"Test failure obj_class [%d] obj_type expected [%d] found [%d]\n",
obj_class, obj_type, found8);
CU_FAIL("Object Header Type");
}
uint8_t exp8 = 0;
found8 = obj_buf[1] & 0x0f;
if (exp8 != found8) {
fprintf(stderr,
"Test failure obj_class [%d] flags expected [%d] found [%d]\n",
obj_class, exp8, found8);
CU_FAIL("Object Header Flags");
}
uint16_t found16 = ntohs(*((uint16_t *)(obj_buf + 2)));
if (obj_length != found16) {
fprintf(stderr,
"Test failure obj_class [%d] obj_length expected [%d] found [%d]\n",
obj_class, obj_length, found16);
CU_FAIL("Object Header Length");
}
}
/* Internal util verification function */
static void verify_pcep_obj_header(uint8_t obj_class, uint8_t obj_type,
struct pcep_object_header *obj_hdr)
{
assert(obj_hdr != NULL);
verify_pcep_obj_header2(obj_class, obj_type,
pcep_object_get_length_by_hdr(obj_hdr),
obj_hdr->encoded_object);
}
void test_pcep_obj_create_open(void)
{
uint8_t deadtimer = 60;
uint8_t keepalive = 30;
uint8_t sid = 1;
struct pcep_object_open *open =
pcep_obj_create_open(keepalive, deadtimer, sid, NULL);
CU_ASSERT_PTR_NOT_NULL(open);
pcep_encode_object(&open->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_OPEN, PCEP_OBJ_TYPE_OPEN,
&open->header);
CU_ASSERT_EQUAL(open->header.encoded_object[4],
(PCEP_OBJECT_OPEN_VERSION << 5) & 0xe0);
CU_ASSERT_EQUAL(open->header.encoded_object[4] & 0x1f, 0);
CU_ASSERT_EQUAL(open->header.encoded_object[5], keepalive);
CU_ASSERT_EQUAL(open->header.encoded_object[6], deadtimer);
CU_ASSERT_EQUAL(open->header.encoded_object[7], sid);
pcep_obj_free_object((struct pcep_object_header *)open);
}
void test_pcep_obj_create_open_with_tlvs(void)
{
uint8_t deadtimer = 60;
uint8_t keepalive = 30;
uint8_t sid = 1;
double_linked_list *tlv_list = dll_initialize();
struct pcep_object_tlv_stateful_pce_capability *tlv =
pcep_tlv_create_stateful_pce_capability(true, true, true, true,
true, true);
dll_append(tlv_list, tlv);
struct pcep_object_open *open =
pcep_obj_create_open(keepalive, deadtimer, sid, tlv_list);
CU_ASSERT_PTR_NOT_NULL(open);
assert(open != NULL);
pcep_encode_object(&open->header, versioning, object_buf);
verify_pcep_obj_header2(PCEP_OBJ_CLASS_OPEN, PCEP_OBJ_TYPE_OPEN,
pcep_object_get_length_by_hdr(&open->header)
+ sizeof(uint32_t) * 2,
open->header.encoded_object);
CU_ASSERT_PTR_NOT_NULL(open->header.tlv_list);
assert(open->header.tlv_list != NULL);
CU_ASSERT_EQUAL(open->header.tlv_list->num_entries, 1);
CU_ASSERT_EQUAL(open->header.encoded_object[4],
(PCEP_OBJECT_OPEN_VERSION << 5) & 0xe0);
CU_ASSERT_EQUAL(open->header.encoded_object[4] & 0x1f, 0);
CU_ASSERT_EQUAL(open->header.encoded_object[5], keepalive);
CU_ASSERT_EQUAL(open->header.encoded_object[6], deadtimer);
CU_ASSERT_EQUAL(open->header.encoded_object[7], sid);
pcep_obj_free_object((struct pcep_object_header *)open);
}
void test_pcep_obj_create_rp(void)
{
uint32_t reqid = 15;
uint8_t invalid_priority = 100;
uint8_t priority = 7;
struct pcep_object_rp *rp = pcep_obj_create_rp(
invalid_priority, true, false, false, true, reqid, NULL);
CU_ASSERT_PTR_NULL(rp);
rp = pcep_obj_create_rp(priority, true, false, false, true, reqid,
NULL);
CU_ASSERT_PTR_NOT_NULL(rp);
pcep_encode_object(&rp->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_RP, PCEP_OBJ_TYPE_RP,
&rp->header);
CU_ASSERT_EQUAL(rp->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(rp->header.encoded_object[5], 0);
CU_ASSERT_EQUAL(rp->header.encoded_object[6], 0);
CU_ASSERT_EQUAL((rp->header.encoded_object[7] & 0x07), priority);
CU_ASSERT_TRUE(rp->header.encoded_object[7] & OBJECT_RP_FLAG_R);
CU_ASSERT_TRUE(rp->header.encoded_object[7] & OBJECT_RP_FLAG_OF);
CU_ASSERT_TRUE(rp->header.encoded_object[7] & ~OBJECT_RP_FLAG_B);
CU_ASSERT_TRUE(rp->header.encoded_object[7] & ~OBJECT_RP_FLAG_O);
CU_ASSERT_EQUAL(*((uint32_t *)(rp->header.encoded_object + 8)),
htonl(reqid));
pcep_obj_free_object((struct pcep_object_header *)rp);
}
void test_pcep_obj_create_nopath(void)
{
uint8_t ni = 8;
uint32_t errorcode = 42;
struct pcep_object_nopath *nopath =
pcep_obj_create_nopath(ni, true, errorcode);
CU_ASSERT_PTR_NOT_NULL(nopath);
pcep_encode_object(&nopath->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_NOPATH, PCEP_OBJ_TYPE_NOPATH,
&nopath->header);
CU_ASSERT_EQUAL(nopath->header.encoded_object[4], ni);
CU_ASSERT_TRUE(nopath->header.encoded_object[5] & OBJECT_NOPATH_FLAG_C);
CU_ASSERT_EQUAL(nopath->header.encoded_object[6], 0);
CU_ASSERT_EQUAL(nopath->header.encoded_object[7], 0);
/* Verify the TLV */
assert(nopath != NULL);
assert(nopath->header.tlv_list != NULL);
CU_ASSERT_PTR_NOT_NULL(nopath->header.tlv_list);
struct pcep_object_tlv_nopath_vector *tlv =
(struct pcep_object_tlv_nopath_vector *)
nopath->header.tlv_list->head->data;
CU_ASSERT_EQUAL(tlv->header.encoded_tlv_length, 4);
CU_ASSERT_EQUAL(tlv->header.type, 1);
CU_ASSERT_EQUAL(tlv->error_code, errorcode);
CU_ASSERT_EQUAL(*((uint16_t *)(nopath->header.encoded_object + 8)),
htons(PCEP_OBJ_TLV_TYPE_NO_PATH_VECTOR));
CU_ASSERT_EQUAL(*((uint16_t *)(nopath->header.encoded_object + 10)),
htons(4));
CU_ASSERT_EQUAL(*((uint32_t *)(nopath->header.encoded_object + 12)),
htonl(errorcode));
pcep_obj_free_object((struct pcep_object_header *)nopath);
}
void test_pcep_obj_create_association_ipv4(void)
{
uint16_t all_assoc_groups = 0xffff;
struct in_addr src;
inet_pton(AF_INET, "192.168.1.2", &src);
struct pcep_object_association_ipv4 *assoc =
pcep_obj_create_association_ipv4(
false, PCEP_ASSOCIATION_TYPE_SR_POLICY_ASSOCIATION_TYPE,
all_assoc_groups, src);
CU_ASSERT_PTR_NOT_NULL(assoc);
assert(assoc != NULL);
CU_ASSERT_EQUAL(assoc->association_type,
PCEP_ASSOCIATION_TYPE_SR_POLICY_ASSOCIATION_TYPE);
CU_ASSERT_EQUAL(assoc->association_id, all_assoc_groups);
CU_ASSERT_EQUAL(assoc->header.object_class, PCEP_OBJ_CLASS_ASSOCIATION);
CU_ASSERT_EQUAL(assoc->header.object_type,
PCEP_OBJ_TYPE_ASSOCIATION_IPV4);
CU_ASSERT_EQUAL(assoc->src.s_addr, src.s_addr);
pcep_obj_free_object((struct pcep_object_header *)assoc);
}
void test_pcep_obj_create_association_ipv6(void)
{
uint32_t all_assoc_groups = 0xffff;
struct in6_addr src;
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &src);
struct pcep_object_association_ipv6 *assoc =
pcep_obj_create_association_ipv6(
false, PCEP_ASSOCIATION_TYPE_SR_POLICY_ASSOCIATION_TYPE,
all_assoc_groups, src);
CU_ASSERT_PTR_NOT_NULL(assoc);
assert(assoc != NULL);
CU_ASSERT_EQUAL(assoc->association_type,
PCEP_ASSOCIATION_TYPE_SR_POLICY_ASSOCIATION_TYPE);
CU_ASSERT_EQUAL(assoc->association_id, all_assoc_groups);
CU_ASSERT_EQUAL(assoc->header.object_class, PCEP_OBJ_CLASS_ASSOCIATION);
CU_ASSERT_EQUAL(assoc->header.object_type,
PCEP_OBJ_TYPE_ASSOCIATION_IPV6);
CU_ASSERT_EQUAL(assoc->src.__in6_u.__u6_addr32[0],
(src.__in6_u.__u6_addr32[0]));
CU_ASSERT_EQUAL(assoc->src.__in6_u.__u6_addr32[1],
(src.__in6_u.__u6_addr32[1]));
CU_ASSERT_EQUAL(assoc->src.__in6_u.__u6_addr32[2],
(src.__in6_u.__u6_addr32[2]));
CU_ASSERT_EQUAL(assoc->src.__in6_u.__u6_addr32[3],
(src.__in6_u.__u6_addr32[3]));
pcep_obj_free_object((struct pcep_object_header *)assoc);
}
void test_pcep_obj_create_endpoint_ipv4(void)
{
struct in_addr src_ipv4, dst_ipv4;
inet_pton(AF_INET, "192.168.1.2", &src_ipv4);
inet_pton(AF_INET, "172.168.1.2", &dst_ipv4);
struct pcep_object_endpoints_ipv4 *ipv4 =
pcep_obj_create_endpoint_ipv4(NULL, NULL);
CU_ASSERT_PTR_NULL(ipv4);
ipv4 = pcep_obj_create_endpoint_ipv4(&src_ipv4, NULL);
CU_ASSERT_PTR_NULL(ipv4);
ipv4 = pcep_obj_create_endpoint_ipv4(NULL, &dst_ipv4);
CU_ASSERT_PTR_NULL(ipv4);
ipv4 = pcep_obj_create_endpoint_ipv4(&src_ipv4, &dst_ipv4);
CU_ASSERT_PTR_NOT_NULL(ipv4);
pcep_encode_object(&ipv4->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_ENDPOINTS,
PCEP_OBJ_TYPE_ENDPOINT_IPV4, &ipv4->header);
CU_ASSERT_EQUAL(*((uint32_t *)(ipv4->header.encoded_object + 4)),
src_ipv4.s_addr);
CU_ASSERT_EQUAL(*((uint32_t *)(ipv4->header.encoded_object + 8)),
dst_ipv4.s_addr);
pcep_obj_free_object((struct pcep_object_header *)ipv4);
}
void test_pcep_obj_create_endpoint_ipv6(void)
{
struct in6_addr src_ipv6, dst_ipv6;
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &src_ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:8446", &dst_ipv6);
struct pcep_object_endpoints_ipv6 *ipv6 =
pcep_obj_create_endpoint_ipv6(NULL, NULL);
CU_ASSERT_PTR_NULL(ipv6);
ipv6 = pcep_obj_create_endpoint_ipv6(&src_ipv6, NULL);
CU_ASSERT_PTR_NULL(ipv6);
ipv6 = pcep_obj_create_endpoint_ipv6(NULL, &dst_ipv6);
CU_ASSERT_PTR_NULL(ipv6);
ipv6 = pcep_obj_create_endpoint_ipv6(&src_ipv6, &dst_ipv6);
CU_ASSERT_PTR_NOT_NULL(ipv6);
pcep_encode_object(&ipv6->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_ENDPOINTS,
PCEP_OBJ_TYPE_ENDPOINT_IPV6, &ipv6->header);
uint32_t *uint32_ptr = (uint32_t *)(ipv6->header.encoded_object + 4);
CU_ASSERT_EQUAL(uint32_ptr[0], src_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], src_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], src_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], src_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[4], dst_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[5], dst_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[6], dst_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[7], dst_ipv6.__in6_u.__u6_addr32[3]);
pcep_obj_free_object((struct pcep_object_header *)ipv6);
}
void test_pcep_obj_create_bandwidth(void)
{
/* 1.8 => binary 1.11001101
* exponent = 127 => 0111 1111
* fraction = 1100 1101 0000 0000 0000 000 */
float bandwidth = 1.8;
struct pcep_object_bandwidth *bw = pcep_obj_create_bandwidth(bandwidth);
CU_ASSERT_PTR_NOT_NULL(bw);
pcep_encode_object(&bw->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_BANDWIDTH,
PCEP_OBJ_TYPE_BANDWIDTH_REQ, &bw->header);
CU_ASSERT_EQUAL(bw->header.encoded_object[4], 0x3f);
CU_ASSERT_EQUAL(bw->header.encoded_object[5], 0xe6);
CU_ASSERT_EQUAL(bw->header.encoded_object[6], 0x66);
CU_ASSERT_EQUAL(bw->header.encoded_object[7], 0x66);
pcep_obj_free_object((struct pcep_object_header *)bw);
}
void test_pcep_obj_create_metric(void)
{
uint8_t type = PCEP_METRIC_BORDER_NODE_COUNT;
/* https://en.wikipedia.org/wiki/IEEE_754-1985
* 0.15625 = 1/8 + 1/32 = binary 0.00101 = 1.01 x 10^-3
* Exponent bias = 127, so exponent = (127-3) = 124 = 0111 1100
* Sign Exponent Fraction
* (8 bits) (23 bits)
* 0.15625 => 0 0111 1100 010 0000 ... 0000 */
float value = 0.15625;
struct pcep_object_metric *metric =
pcep_obj_create_metric(type, true, true, value);
CU_ASSERT_PTR_NOT_NULL(metric);
pcep_encode_object(&metric->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_METRIC, PCEP_OBJ_TYPE_METRIC,
&metric->header);
CU_ASSERT_EQUAL(metric->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(metric->header.encoded_object[5], 0);
CU_ASSERT_TRUE(metric->header.encoded_object[6] & OBJECT_METRIC_FLAC_B);
CU_ASSERT_TRUE(metric->header.encoded_object[6] & OBJECT_METRIC_FLAC_C);
CU_ASSERT_EQUAL(metric->header.encoded_object[7], type);
/* See comments above for explanation of these values */
CU_ASSERT_EQUAL(metric->header.encoded_object[8], 0x3e);
CU_ASSERT_EQUAL(metric->header.encoded_object[9], 0x20);
CU_ASSERT_EQUAL(metric->header.encoded_object[10], 0x00);
CU_ASSERT_EQUAL(metric->header.encoded_object[11], 0x00);
pcep_obj_free_object((struct pcep_object_header *)metric);
}
void test_pcep_obj_create_lspa(void)
{
uint32_t exclude_any = 10;
uint32_t include_any = 20;
uint32_t include_all = 30;
uint8_t prio = 0;
uint8_t hold_prio = 10;
struct pcep_object_lspa *lspa = pcep_obj_create_lspa(
exclude_any, include_any, include_all, prio, hold_prio, true);
CU_ASSERT_PTR_NOT_NULL(lspa);
pcep_encode_object(&lspa->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_LSPA, PCEP_OBJ_TYPE_LSPA,
&lspa->header);
uint32_t *uint32_ptr = (uint32_t *)(lspa->header.encoded_object + 4);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(exclude_any));
CU_ASSERT_EQUAL(uint32_ptr[1], htonl(include_any));
CU_ASSERT_EQUAL(uint32_ptr[2], htonl(include_all));
CU_ASSERT_EQUAL(lspa->header.encoded_object[16], prio);
CU_ASSERT_EQUAL(lspa->header.encoded_object[17], hold_prio);
CU_ASSERT_TRUE(lspa->header.encoded_object[18] & OBJECT_LSPA_FLAG_L);
CU_ASSERT_EQUAL(lspa->header.encoded_object[19], 0);
pcep_obj_free_object((struct pcep_object_header *)lspa);
}
void test_pcep_obj_create_svec(void)
{
struct pcep_object_svec *svec =
pcep_obj_create_svec(true, true, true, NULL);
CU_ASSERT_PTR_NULL(svec);
double_linked_list *id_list = dll_initialize();
uint32_t *uint32_ptr =
pceplib_malloc(PCEPLIB_MESSAGES, sizeof(uint32_t));
*uint32_ptr = 10;
dll_append(id_list, uint32_ptr);
svec = pcep_obj_create_svec(true, true, true, id_list);
CU_ASSERT_PTR_NOT_NULL(svec);
assert(svec != NULL);
pcep_encode_object(&svec->header, versioning, object_buf);
verify_pcep_obj_header2(PCEP_OBJ_CLASS_SVEC, PCEP_OBJ_TYPE_SVEC,
(OBJECT_HEADER_LENGTH + sizeof(uint32_t) * 2),
svec->header.encoded_object);
CU_ASSERT_EQUAL(svec->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(svec->header.encoded_object[5], 0);
CU_ASSERT_EQUAL(svec->header.encoded_object[6], 0);
CU_ASSERT_TRUE(svec->header.encoded_object[7] & OBJECT_SVEC_FLAG_S);
CU_ASSERT_TRUE(svec->header.encoded_object[7] & OBJECT_SVEC_FLAG_N);
CU_ASSERT_TRUE(svec->header.encoded_object[7] & OBJECT_SVEC_FLAG_L);
CU_ASSERT_EQUAL(*((uint32_t *)(svec->header.encoded_object + 8)),
htonl(*uint32_ptr));
pcep_obj_free_object((struct pcep_object_header *)svec);
}
void test_pcep_obj_create_error(void)
{
uint8_t error_type = PCEP_ERRT_SESSION_FAILURE;
uint8_t error_value = PCEP_ERRV_RECVD_INVALID_OPEN_MSG;
struct pcep_object_error *error =
pcep_obj_create_error(error_type, error_value);
CU_ASSERT_PTR_NOT_NULL(error);
pcep_encode_object(&error->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_ERROR, PCEP_OBJ_TYPE_ERROR,
&error->header);
CU_ASSERT_EQUAL(error->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(error->header.encoded_object[5], 0);
CU_ASSERT_EQUAL(error->header.encoded_object[6], error_type);
CU_ASSERT_EQUAL(error->header.encoded_object[7], error_value);
pcep_obj_free_object((struct pcep_object_header *)error);
}
void test_pcep_obj_create_close(void)
{
uint8_t reason = PCEP_CLOSE_REASON_DEADTIMER;
struct pcep_object_close *close = pcep_obj_create_close(reason);
CU_ASSERT_PTR_NOT_NULL(close);
pcep_encode_object(&close->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_CLOSE, PCEP_OBJ_TYPE_CLOSE,
&close->header);
CU_ASSERT_EQUAL(close->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(close->header.encoded_object[5], 0);
CU_ASSERT_EQUAL(close->header.encoded_object[6], 0);
CU_ASSERT_EQUAL(close->header.encoded_object[7], reason);
pcep_obj_free_object((struct pcep_object_header *)close);
}
void test_pcep_obj_create_srp(void)
{
bool lsp_remove = true;
uint32_t srp_id_number = 0x89674523;
struct pcep_object_srp *srp =
pcep_obj_create_srp(lsp_remove, srp_id_number, NULL);
CU_ASSERT_PTR_NOT_NULL(srp);
pcep_encode_object(&srp->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_SRP, PCEP_OBJ_TYPE_SRP,
&srp->header);
CU_ASSERT_EQUAL(srp->header.encoded_object[4], 0);
CU_ASSERT_EQUAL(srp->header.encoded_object[5], 0);
CU_ASSERT_EQUAL(srp->header.encoded_object[6], 0);
CU_ASSERT_TRUE(srp->header.encoded_object[7] & OBJECT_SRP_FLAG_R);
CU_ASSERT_EQUAL(*((uint32_t *)(srp->header.encoded_object + 8)),
htonl(srp_id_number));
pcep_obj_free_object((struct pcep_object_header *)srp);
}
void test_pcep_obj_create_lsp(void)
{
uint32_t plsp_id = 0x000fffff;
enum pcep_lsp_operational_status status = PCEP_LSP_OPERATIONAL_ACTIVE;
bool c_flag = true;
bool a_flag = true;
bool r_flag = true;
bool s_flag = true;
bool d_flag = true;
/* Should return for invalid plsp_id */
struct pcep_object_lsp *lsp =
pcep_obj_create_lsp(0x001fffff, status, c_flag, a_flag, r_flag,
s_flag, d_flag, NULL);
CU_ASSERT_PTR_NULL(lsp);
/* Should return for invalid status */
lsp = pcep_obj_create_lsp(plsp_id, 8, c_flag, a_flag, r_flag, s_flag,
d_flag, NULL);
CU_ASSERT_PTR_NULL(lsp);
lsp = pcep_obj_create_lsp(plsp_id, status, c_flag, a_flag, r_flag,
s_flag, d_flag, NULL);
CU_ASSERT_PTR_NOT_NULL(lsp);
pcep_encode_object(&lsp->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_LSP, PCEP_OBJ_TYPE_LSP,
&lsp->header);
CU_ASSERT_EQUAL((ntohl(*((uint32_t *)(lsp->header.encoded_object + 4)))
>> 12) & 0x000fffff,
plsp_id);
CU_ASSERT_EQUAL((lsp->header.encoded_object[7] >> 4) & 0x07, status);
CU_ASSERT_TRUE(lsp->header.encoded_object[7] & OBJECT_LSP_FLAG_A);
CU_ASSERT_TRUE(lsp->header.encoded_object[7] & OBJECT_LSP_FLAG_C);
CU_ASSERT_TRUE(lsp->header.encoded_object[7] & OBJECT_LSP_FLAG_D);
CU_ASSERT_TRUE(lsp->header.encoded_object[7] & OBJECT_LSP_FLAG_R);
CU_ASSERT_TRUE(lsp->header.encoded_object[7] & OBJECT_LSP_FLAG_S);
pcep_obj_free_object((struct pcep_object_header *)lsp);
}
void test_pcep_obj_create_vendor_info(void)
{
uint32_t enterprise_number = 0x01020304;
uint32_t enterprise_specific_info = 0x05060708;
struct pcep_object_vendor_info *obj = pcep_obj_create_vendor_info(
enterprise_number, enterprise_specific_info);
CU_ASSERT_PTR_NOT_NULL(obj);
pcep_encode_object(&obj->header, versioning, object_buf);
verify_pcep_obj_header(PCEP_OBJ_CLASS_VENDOR_INFO,
PCEP_OBJ_TYPE_VENDOR_INFO, &obj->header);
uint32_t *uint32_ptr = (uint32_t *)(obj->header.encoded_object + 4);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(enterprise_number));
CU_ASSERT_EQUAL(uint32_ptr[1], htonl(enterprise_specific_info));
pcep_obj_free_object((struct pcep_object_header *)obj);
}
/* Internal test function. The only difference between pcep_obj_create_ero(),
* pcep_obj_create_iro(), and pcep_obj_create_rro() is the object_class
* and the object_type.
*/
typedef struct pcep_object_ro *(*ro_func)(double_linked_list *);
static void test_pcep_obj_create_object_common(ro_func func_to_test,
uint8_t object_class,
uint8_t object_type)
{
double_linked_list *ero_list = dll_initialize();
struct pcep_object_ro *ero = func_to_test(NULL);
CU_ASSERT_PTR_NOT_NULL(ero);
assert(ero != NULL);
pcep_encode_object(&ero->header, versioning, object_buf);
verify_pcep_obj_header2(object_class, object_type, OBJECT_HEADER_LENGTH,
ero->header.encoded_object);
pcep_obj_free_object((struct pcep_object_header *)ero);
reset_objects_buffer();
ero = func_to_test(ero_list);
CU_ASSERT_PTR_NOT_NULL(ero);
assert(ero != NULL);
pcep_encode_object(&ero->header, versioning, object_buf);
verify_pcep_obj_header2(object_class, object_type, OBJECT_HEADER_LENGTH,
ero->header.encoded_object);
pcep_obj_free_object((struct pcep_object_header *)ero);
reset_objects_buffer();
struct pcep_ro_subobj_32label *ro_subobj =
pcep_obj_create_ro_subobj_32label(false, 0, 101);
ero_list = dll_initialize();
dll_append(ero_list, ro_subobj);
ero = func_to_test(ero_list);
CU_ASSERT_PTR_NOT_NULL(ero);
assert(ero != NULL);
pcep_encode_object(&ero->header, versioning, object_buf);
/* 4 bytes for obj header +
* 2 bytes for ro_subobj header +
* 2 bytes for lable c-type and flags +
* 4 bytes for label */
verify_pcep_obj_header2(object_class, object_type,
OBJECT_HEADER_LENGTH + sizeof(uint32_t) * 2,
ero->header.encoded_object);
pcep_obj_free_object((struct pcep_object_header *)ero);
}
void test_pcep_obj_create_ero(void)
{
test_pcep_obj_create_object_common(
pcep_obj_create_ero, PCEP_OBJ_CLASS_ERO, PCEP_OBJ_TYPE_ERO);
}
void test_pcep_obj_create_rro(void)
{
test_pcep_obj_create_object_common(
pcep_obj_create_rro, PCEP_OBJ_CLASS_RRO, PCEP_OBJ_TYPE_RRO);
}
void test_pcep_obj_create_iro(void)
{
test_pcep_obj_create_object_common(
pcep_obj_create_iro, PCEP_OBJ_CLASS_IRO, PCEP_OBJ_TYPE_IRO);
}
/* Internal util function to wrap an RO Subobj in a RO and encode it */
static struct pcep_object_ro *encode_ro_subobj(struct pcep_object_ro_subobj *sr)
{
double_linked_list *sr_subobj_list = dll_initialize();
dll_append(sr_subobj_list, sr);
struct pcep_object_ro *ro = pcep_obj_create_ero(sr_subobj_list);
pcep_encode_object(&ro->header, versioning, object_buf);
return ro;
}
static void verify_pcep_obj_ro_header(struct pcep_object_ro *ro,
struct pcep_object_ro_subobj *ro_subobj,
uint8_t ro_subobj_type, bool loose_hop,
uint16_t length)
{
(void)ro_subobj;
verify_pcep_obj_header2(PCEP_OBJ_CLASS_ERO, PCEP_OBJ_TYPE_ERO, length,
ro->header.encoded_object);
/* TODO consider printing the stack trace:
* https://stackoverflow.com/questions/105659/how-can-one-grab-a-stack-trace-in-c
*/
/* Not using CU_ASSERT_EQUAL here, so that in case of failure,
* we can provide more info in the error message. */
uint8_t found_type = (ro->header.encoded_object[4]
& 0x7f); /* remove the Loose hop bit */
if (found_type != ro_subobj_type) {
fprintf(stderr,
"Test failure ro_sub_obj_type expected [%d] found [%d]\n",
ro_subobj_type, found_type);
CU_FAIL("Sub Object Header Type");
}
bool loose_hop_found = (ro->header.encoded_object[4] & 0x80);
if (loose_hop != loose_hop_found) {
fprintf(stderr,
"Test failure ro_sub_obj Loose Hop bit expected [%d] found [%d]\n",
loose_hop, loose_hop_found);
CU_FAIL("Sub Object Header Loose Hop bit");
}
if (length - 4 != ro->header.encoded_object[5]) {
fprintf(stderr,
"Test failure ro_sub_obj length expected [%d] found [%d]\n",
length - 4, ro->header.encoded_object[5]);
CU_FAIL("Sub Object Length");
}
}
static void
verify_pcep_obj_ro_sr_header(struct pcep_object_ro *ro,
struct pcep_object_ro_subobj *ro_subobj,
uint8_t nai_type, bool loose_hop, uint16_t length)
{
verify_pcep_obj_ro_header(ro, ro_subobj, RO_SUBOBJ_TYPE_SR, loose_hop,
length);
uint8_t found_nai_type = ((ro->header.encoded_object[6] >> 4) & 0x0f);
if (nai_type != found_nai_type) {
fprintf(stderr,
"Test failure ro_sr_sub_obj nai_type expected [%d] found [%d]\n",
nai_type, found_nai_type);
CU_FAIL("Sub Object SR NAI Type");
}
}
void test_pcep_obj_create_ro_subobj_ipv4(void)
{
struct in_addr ro_ipv4;
inet_pton(AF_INET, "192.168.1.2", &ro_ipv4);
uint8_t prefix_len = 8;
struct pcep_ro_subobj_ipv4 *ipv4 =
pcep_obj_create_ro_subobj_ipv4(true, NULL, prefix_len, false);
CU_ASSERT_PTR_NULL(ipv4);
ipv4 = pcep_obj_create_ro_subobj_ipv4(false, &ro_ipv4, prefix_len,
true);
CU_ASSERT_PTR_NOT_NULL(ipv4);
struct pcep_object_ro *ro = encode_ro_subobj(&ipv4->ro_subobj);
verify_pcep_obj_ro_header(ro, &ipv4->ro_subobj, RO_SUBOBJ_TYPE_IPV4,
false, sizeof(uint32_t) * 3);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 6)),
ro_ipv4.s_addr);
CU_ASSERT_EQUAL(ro->header.encoded_object[10], prefix_len);
CU_ASSERT_TRUE(ro->header.encoded_object[11]
& OBJECT_SUBOBJ_IP_FLAG_LOCAL_PROT);
pcep_obj_free_object((struct pcep_object_header *)ro);
reset_objects_buffer();
ipv4 = pcep_obj_create_ro_subobj_ipv4(true, &ro_ipv4, prefix_len,
false);
CU_ASSERT_PTR_NOT_NULL(ipv4);
ro = encode_ro_subobj(&ipv4->ro_subobj);
verify_pcep_obj_ro_header(ro, &ipv4->ro_subobj, RO_SUBOBJ_TYPE_IPV4,
true, sizeof(uint32_t) * 3);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 6)),
ro_ipv4.s_addr);
CU_ASSERT_EQUAL(ro->header.encoded_object[10], prefix_len);
CU_ASSERT_EQUAL(ro->header.encoded_object[11], 0);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_ipv6(void)
{
struct in6_addr ro_ipv6;
uint8_t prefix_len = 16;
struct pcep_ro_subobj_ipv6 *ipv6 =
pcep_obj_create_ro_subobj_ipv6(true, NULL, prefix_len, true);
CU_ASSERT_PTR_NULL(ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &ro_ipv6);
ipv6 = pcep_obj_create_ro_subobj_ipv6(false, &ro_ipv6, prefix_len,
true);
CU_ASSERT_PTR_NOT_NULL(ipv6);
struct pcep_object_ro *ro = encode_ro_subobj(&ipv6->ro_subobj);
verify_pcep_obj_ro_header(ro, &ipv6->ro_subobj, RO_SUBOBJ_TYPE_IPV6,
false, sizeof(uint32_t) * 6);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 6);
CU_ASSERT_EQUAL(uint32_ptr[0], ro_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], ro_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], ro_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], ro_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(ro->header.encoded_object[22], prefix_len);
CU_ASSERT_TRUE(ro->header.encoded_object[23]
& OBJECT_SUBOBJ_IP_FLAG_LOCAL_PROT);
pcep_obj_free_object((struct pcep_object_header *)ro);
reset_objects_buffer();
ipv6 = pcep_obj_create_ro_subobj_ipv6(true, &ro_ipv6, prefix_len,
false);
CU_ASSERT_PTR_NOT_NULL(ipv6);
ro = encode_ro_subobj(&ipv6->ro_subobj);
verify_pcep_obj_ro_header(ro, &ipv6->ro_subobj, RO_SUBOBJ_TYPE_IPV6,
true, sizeof(uint32_t) * 6);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 6);
CU_ASSERT_EQUAL(uint32_ptr[0], ro_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], ro_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], ro_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], ro_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(ro->header.encoded_object[22], prefix_len);
CU_ASSERT_EQUAL(ro->header.encoded_object[23], 0);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_unnum(void)
{
struct in_addr router_id;
uint32_t if_id = 123;
struct pcep_ro_subobj_unnum *unnum =
pcep_obj_create_ro_subobj_unnum(NULL, if_id);
CU_ASSERT_PTR_NULL(unnum);
inet_pton(AF_INET, "192.168.1.2", &router_id);
unnum = pcep_obj_create_ro_subobj_unnum(&router_id, if_id);
CU_ASSERT_PTR_NOT_NULL(unnum);
struct pcep_object_ro *ro = encode_ro_subobj(&unnum->ro_subobj);
verify_pcep_obj_ro_header(ro, &unnum->ro_subobj, RO_SUBOBJ_TYPE_UNNUM,
false, sizeof(uint32_t) * 4);
CU_ASSERT_EQUAL(ro->header.encoded_object[6], 0);
CU_ASSERT_EQUAL(ro->header.encoded_object[7], 0);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 8)),
router_id.s_addr);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 12)),
htonl(if_id));
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_32label(void)
{
uint8_t class_type = 1;
uint32_t label = 0xeeffaabb;
struct pcep_ro_subobj_32label *label32 =
pcep_obj_create_ro_subobj_32label(true, class_type, label);
CU_ASSERT_PTR_NOT_NULL(label32);
struct pcep_object_ro *ro = encode_ro_subobj(&label32->ro_subobj);
verify_pcep_obj_ro_header(ro, &label32->ro_subobj, RO_SUBOBJ_TYPE_LABEL,
false, sizeof(uint32_t) * 3);
CU_ASSERT_TRUE(ro->header.encoded_object[6]
& OBJECT_SUBOBJ_LABEL_FLAG_GLOGAL);
CU_ASSERT_EQUAL(ro->header.encoded_object[7], class_type);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 8)),
htonl(label));
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_asn(void)
{
uint16_t asn = 0x0102;
struct pcep_ro_subobj_asn *asn_obj = pcep_obj_create_ro_subobj_asn(asn);
CU_ASSERT_PTR_NOT_NULL(asn_obj);
struct pcep_object_ro *ro = encode_ro_subobj(&asn_obj->ro_subobj);
verify_pcep_obj_ro_header(ro, &asn_obj->ro_subobj, RO_SUBOBJ_TYPE_ASN,
false, sizeof(uint32_t) * 2);
CU_ASSERT_EQUAL(*((uint16_t *)(ro->header.encoded_object + 6)),
htons(asn));
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_nonai(void)
{
uint32_t sid = 0x01020304;
struct pcep_ro_subobj_sr *sr =
pcep_obj_create_ro_subobj_sr_nonai(false, sid, false, false);
CU_ASSERT_PTR_NOT_NULL(sr);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_ABSENT, false,
sizeof(uint32_t) * 3);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
pcep_obj_free_object((struct pcep_object_header *)ro);
reset_objects_buffer();
sr = pcep_obj_create_ro_subobj_sr_nonai(true, sid, true, true);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_ABSENT, true,
sizeof(uint32_t) * 3);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_ipv4_node(void)
{
uint32_t sid = 0x01020304;
struct in_addr ipv4_node_id;
inet_pton(AF_INET, "192.168.1.2", &ipv4_node_id);
/* (loose_hop, sid_absent, c_flag, m_flag, sid, ipv4_node_id) */
struct pcep_ro_subobj_sr *sr = pcep_obj_create_ro_subobj_sr_ipv4_node(
true, false, true, true, sid, NULL);
CU_ASSERT_PTR_NULL(sr);
/* Test the sid is absent */
sr = pcep_obj_create_ro_subobj_sr_ipv4_node(true, true, false, false,
sid, &ipv4_node_id);
CU_ASSERT_PTR_NOT_NULL(sr);
assert(sr != NULL);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV4_NODE, true,
sizeof(uint32_t) * 3);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_EQUAL(sr->sid, 0);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 8)),
ipv4_node_id.s_addr);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
reset_objects_buffer();
inet_pton(AF_INET, "192.168.1.2", &ipv4_node_id);
sr = pcep_obj_create_ro_subobj_sr_ipv4_node(false, false, true, true,
sid, &ipv4_node_id);
CU_ASSERT_PTR_NOT_NULL(sr);
assert(sr != NULL);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV4_NODE, false,
sizeof(uint32_t) * 4);
assert(ro != NULL);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 8)),
htonl(sid));
CU_ASSERT_EQUAL(*((uint32_t *)(ro->header.encoded_object + 12)),
ipv4_node_id.s_addr);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_ipv6_node(void)
{
uint32_t sid = 0x01020304;
struct in6_addr ipv6_node_id;
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &ipv6_node_id);
/* (loose_hop, sid_absent, c_flag, m_flag, sid, ipv6_node_id) */
struct pcep_ro_subobj_sr *sr = pcep_obj_create_ro_subobj_sr_ipv6_node(
false, true, true, true, sid, NULL);
CU_ASSERT_PTR_NULL(sr);
/* Test the sid is absent */
sr = pcep_obj_create_ro_subobj_sr_ipv6_node(true, true, true, true, sid,
&ipv6_node_id);
CU_ASSERT_PTR_NOT_NULL(sr);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV6_NODE, true,
sizeof(uint32_t) * 6);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], ipv6_node_id.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], ipv6_node_id.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], ipv6_node_id.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], ipv6_node_id.__in6_u.__u6_addr32[3]);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
reset_objects_buffer();
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &ipv6_node_id);
sr = pcep_obj_create_ro_subobj_sr_ipv6_node(false, false, true, true,
sid, &ipv6_node_id);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV6_NODE, false,
sizeof(uint32_t) * 7);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(sid));
CU_ASSERT_EQUAL(uint32_ptr[1], ipv6_node_id.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[2], ipv6_node_id.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[3], ipv6_node_id.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[4], ipv6_node_id.__in6_u.__u6_addr32[3]);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_ipv4_adj(void)
{
struct in_addr local_ipv4;
struct in_addr remote_ipv4;
inet_pton(AF_INET, "192.168.1.2", &local_ipv4);
inet_pton(AF_INET, "172.168.1.2", &remote_ipv4);
uint32_t sid = ENCODE_SR_ERO_SID(3, 7, 0, 188);
CU_ASSERT_EQUAL(sid, 16060);
/* (loose_hop, sid_absent, c_flag, m_flag, sid, local_ipv4, remote_ipv4)
*/
struct pcep_ro_subobj_sr *sr = pcep_obj_create_ro_subobj_sr_ipv4_adj(
false, true, true, true, sid, NULL, NULL);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_ipv4_adj(false, true, true, true, sid,
&local_ipv4, NULL);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_ipv4_adj(false, true, true, true, sid,
NULL, &remote_ipv4);
CU_ASSERT_PTR_NULL(sr);
/* Test the sid is absent */
sr = pcep_obj_create_ro_subobj_sr_ipv4_adj(true, true, true, true, sid,
&local_ipv4, &remote_ipv4);
CU_ASSERT_PTR_NOT_NULL(sr);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV4_ADJACENCY, true,
sizeof(uint32_t) * 4);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
assert(sr != NULL);
CU_ASSERT_EQUAL(sr->sid, 0);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], local_ipv4.s_addr);
CU_ASSERT_EQUAL(uint32_ptr[1], remote_ipv4.s_addr);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
inet_pton(AF_INET, "192.168.1.2", &local_ipv4);
inet_pton(AF_INET, "172.168.1.2", &remote_ipv4);
reset_objects_buffer();
sr = pcep_obj_create_ro_subobj_sr_ipv4_adj(
false, false, true, true, sid, &local_ipv4, &remote_ipv4);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV4_ADJACENCY, false,
sizeof(uint32_t) * 5);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(sid));
CU_ASSERT_EQUAL(uint32_ptr[1], local_ipv4.s_addr);
CU_ASSERT_EQUAL(uint32_ptr[2], remote_ipv4.s_addr);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_ipv6_adj(void)
{
uint32_t sid = 0x01020304;
struct in6_addr local_ipv6;
struct in6_addr remote_ipv6;
inet_pton(AF_INET6, "2001:db8::8a2e:370:8221", &local_ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &remote_ipv6);
/* (loose_hop, sid_absent, c_flag, m_flag, sid, local_ipv6, remote_ipv6)
*/
struct pcep_ro_subobj_sr *sr = pcep_obj_create_ro_subobj_sr_ipv6_adj(
false, true, true, true, sid, NULL, NULL);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_ipv6_adj(false, true, true, true, sid,
&local_ipv6, NULL);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_ipv6_adj(false, true, true, true, sid,
NULL, &remote_ipv6);
CU_ASSERT_PTR_NULL(sr);
/* Test the sid is absent */
sr = pcep_obj_create_ro_subobj_sr_ipv6_adj(true, true, true, true, sid,
&local_ipv6, &remote_ipv6);
CU_ASSERT_PTR_NOT_NULL(sr);
assert(sr != NULL);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV6_ADJACENCY, true,
sizeof(uint32_t) * 10);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_EQUAL(sr->sid, 0);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], local_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], local_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], local_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], local_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[4], remote_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[5], remote_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[6], remote_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[7], remote_ipv6.__in6_u.__u6_addr32[3]);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
reset_objects_buffer();
inet_pton(AF_INET6, "2001:db8::8a2e:370:8221", &local_ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &remote_ipv6);
sr = pcep_obj_create_ro_subobj_sr_ipv6_adj(
false, false, true, false, sid, &local_ipv6, &remote_ipv6);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_IPV6_ADJACENCY, false,
sizeof(uint32_t) * 11);
/* All flags are false */
CU_ASSERT_EQUAL(ro->header.encoded_object[7], 0);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(sid));
CU_ASSERT_EQUAL(uint32_ptr[1], local_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[2], local_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[3], local_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[4], local_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[5], remote_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[6], remote_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[7], remote_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[8], remote_ipv6.__in6_u.__u6_addr32[3]);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
void test_pcep_obj_create_ro_subobj_sr_unnumbered_ipv4_adj(void)
{
uint32_t sid = 0x01020304;
uint32_t local_node_id = 0x11223344;
uint32_t local_if_id = 0x55667788;
uint32_t remote_node_id = 0x99aabbcc;
uint32_t remote_if_id = 0xddeeff11;
/* (loose_hop, sid_absent, c_flag, m_flag,
sid, local_node_id, local_if_id, remote_node_id, remote_if_id) */
/* Test the sid is absent */
struct pcep_ro_subobj_sr *sr =
pcep_obj_create_ro_subobj_sr_unnumbered_ipv4_adj(
true, true, true, true, sid, local_node_id, local_if_id,
remote_node_id, remote_if_id);
CU_ASSERT_PTR_NOT_NULL(sr);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(
ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_UNNUMBERED_IPV4_ADJACENCY, true,
sizeof(uint32_t) * 6);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
assert(sr != NULL);
CU_ASSERT_EQUAL(sr->sid, 0);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], local_node_id);
CU_ASSERT_EQUAL(uint32_ptr[1], local_if_id);
CU_ASSERT_EQUAL(uint32_ptr[2], remote_node_id);
CU_ASSERT_EQUAL(uint32_ptr[3], remote_if_id);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
reset_objects_buffer();
sr = pcep_obj_create_ro_subobj_sr_unnumbered_ipv4_adj(
false, false, true, true, sid, local_node_id, local_if_id,
remote_node_id, remote_if_id);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(
ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_UNNUMBERED_IPV4_ADJACENCY, false,
sizeof(uint32_t) * 7);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(sid));
CU_ASSERT_EQUAL(uint32_ptr[1], local_node_id);
CU_ASSERT_EQUAL(uint32_ptr[2], local_if_id);
CU_ASSERT_EQUAL(uint32_ptr[3], remote_node_id);
CU_ASSERT_EQUAL(uint32_ptr[4], remote_if_id);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* TODO Test draft07 types */
}
void test_pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(void)
{
uint32_t sid = 0x01020304;
uint32_t local_if_id = 0x11002200;
uint32_t remote_if_id = 0x00110022;
struct in6_addr local_ipv6;
struct in6_addr remote_ipv6;
inet_pton(AF_INET6, "2001:db8::8a2e:370:8221", &local_ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &remote_ipv6);
/* (loose_hop, sid_absent, c_flag, m_flag, sid, local_ipv6, local_if_id,
* remote_ipv6, remote_if_id */
struct pcep_ro_subobj_sr *sr =
pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(
false, true, true, true, sid, NULL, local_if_id, NULL,
remote_if_id);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(
false, true, true, true, sid, &local_ipv6, local_if_id, NULL,
remote_if_id);
CU_ASSERT_PTR_NULL(sr);
sr = pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(
false, true, true, true, sid, NULL, local_if_id, &remote_ipv6,
remote_if_id);
CU_ASSERT_PTR_NULL(sr);
/* Test the sid is absent */
sr = pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(
true, true, true, true, sid, &local_ipv6, local_if_id,
&remote_ipv6, remote_if_id);
CU_ASSERT_PTR_NOT_NULL(sr);
struct pcep_object_ro *ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(
ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_LINK_LOCAL_IPV6_ADJACENCY, true,
sizeof(uint32_t) * 12);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_M);
assert(sr != NULL);
CU_ASSERT_EQUAL(sr->sid, 0);
uint32_t *uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], local_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[1], local_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[2], local_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[3], local_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[4], local_if_id);
CU_ASSERT_EQUAL(uint32_ptr[5], remote_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[6], remote_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[7], remote_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[8], remote_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[9], remote_if_id);
pcep_obj_free_object((struct pcep_object_header *)ro);
/* Test the sid is present */
inet_pton(AF_INET6, "2001:db8::8a2e:370:8221", &local_ipv6);
inet_pton(AF_INET6, "2001:db8::8a2e:370:7334", &remote_ipv6);
reset_objects_buffer();
sr = pcep_obj_create_ro_subobj_sr_linklocal_ipv6_adj(
false, false, true, true, sid, &local_ipv6, local_if_id,
&remote_ipv6, remote_if_id);
CU_ASSERT_PTR_NOT_NULL(sr);
ro = encode_ro_subobj(&sr->ro_subobj);
verify_pcep_obj_ro_sr_header(
ro, &sr->ro_subobj,
PCEP_SR_SUBOBJ_NAI_LINK_LOCAL_IPV6_ADJACENCY, false,
sizeof(uint32_t) * 13);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_C);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & OBJECT_SUBOBJ_SR_FLAG_M);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_S);
CU_ASSERT_TRUE(ro->header.encoded_object[7] & ~OBJECT_SUBOBJ_SR_FLAG_F);
uint32_ptr = (uint32_t *)(ro->header.encoded_object + 8);
CU_ASSERT_EQUAL(uint32_ptr[0], htonl(sid));
CU_ASSERT_EQUAL(uint32_ptr[1], local_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[2], local_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[3], local_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[4], local_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[5], local_if_id);
CU_ASSERT_EQUAL(uint32_ptr[6], remote_ipv6.__in6_u.__u6_addr32[0]);
CU_ASSERT_EQUAL(uint32_ptr[7], remote_ipv6.__in6_u.__u6_addr32[1]);
CU_ASSERT_EQUAL(uint32_ptr[8], remote_ipv6.__in6_u.__u6_addr32[2]);
CU_ASSERT_EQUAL(uint32_ptr[9], remote_ipv6.__in6_u.__u6_addr32[3]);
CU_ASSERT_EQUAL(uint32_ptr[10], remote_if_id);
pcep_obj_free_object((struct pcep_object_header *)ro);
}
View git blame Copy permalink