/* * This file is part of the PCEPlib, a PCEP protocol library. * * Copyright (C) 2020 Volta Networks https://voltanet.io/ * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public License * along with this program. If not, see . * * Author : Brady Johnson * */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include #include #include #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() { memset(object_buf, 0, 2000); } void pcep_objects_test_setup() { versioning = create_default_pcep_versioning(); reset_objects_buffer(); } void pcep_objects_test_teardown() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { /* 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { test_pcep_obj_create_object_common( pcep_obj_create_ero, PCEP_OBJ_CLASS_ERO, PCEP_OBJ_TYPE_ERO); } void test_pcep_obj_create_rro() { test_pcep_obj_create_object_common( pcep_obj_create_rro, PCEP_OBJ_CLASS_RRO, PCEP_OBJ_TYPE_RRO); } void test_pcep_obj_create_iro() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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() { 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); }