diff options
Diffstat (limited to 'test/common_plat/validation/api/classification/odp_classification_common.c')
| -rw-r--r-- | test/common_plat/validation/api/classification/odp_classification_common.c | 427 |
1 files changed, 0 insertions, 427 deletions
diff --git a/test/common_plat/validation/api/classification/odp_classification_common.c b/test/common_plat/validation/api/classification/odp_classification_common.c deleted file mode 100644 index de8a9327f..000000000 --- a/test/common_plat/validation/api/classification/odp_classification_common.c +++ /dev/null @@ -1,427 +0,0 @@ -/* Copyright (c) 2015, Linaro Limited - * All rights reserved. - * - * SPDX-License-Identifier: BSD-3-Clause - */ - -#include "odp_classification_testsuites.h" -#include "classification.h" -#include <odp_cunit_common.h> -#include "test_debug.h" - -typedef struct cls_test_packet { - odp_u32be_t magic; - odp_u32be_t seq; -} cls_test_packet_t; - -static uint8_t IPV6_SRC_ADDR[ODPH_IPV6ADDR_LEN] = { - /* I.e. ::ffff:10.0.0.1 */ - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0xFF, 0xFF, 10, 0, 0, 1 -}; - -static uint8_t IPV6_DST_ADDR[ODPH_IPV6ADDR_LEN] = { - /* I.e. ::ffff:10.0.0.100 */ - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0xFF, 0xFF, 10, 0, 0, 100 -}; - -odp_pktio_t create_pktio(odp_queue_type_t q_type, odp_pool_t pool, - odp_bool_t cls_enable) -{ - odp_pktio_t pktio; - odp_pktio_param_t pktio_param; - odp_pktin_queue_param_t pktin_param; - int ret; - - if (pool == ODP_POOL_INVALID) - return ODP_PKTIO_INVALID; - - odp_pktio_param_init(&pktio_param); - if (q_type == ODP_QUEUE_TYPE_PLAIN) - pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; - else - pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; - - pktio = odp_pktio_open("loop", pool, &pktio_param); - if (pktio == ODP_PKTIO_INVALID) { - ret = odp_pool_destroy(pool); - if (ret) - fprintf(stderr, "unable to destroy pool.\n"); - return ODP_PKTIO_INVALID; - } - - odp_pktin_queue_param_init(&pktin_param); - pktin_param.queue_param.sched.sync = ODP_SCHED_SYNC_ATOMIC; - pktin_param.classifier_enable = cls_enable; - pktin_param.hash_enable = false; - - if (odp_pktin_queue_config(pktio, &pktin_param)) { - fprintf(stderr, "pktin queue config failed.\n"); - return ODP_PKTIO_INVALID; - } - - if (odp_pktout_queue_config(pktio, NULL)) { - fprintf(stderr, "pktout queue config failed.\n"); - return ODP_PKTIO_INVALID; - } - - return pktio; -} - -int stop_pktio(odp_pktio_t pktio) -{ - odp_event_t ev; - - if (odp_pktio_stop(pktio)) { - fprintf(stderr, "pktio stop failed.\n"); - return -1; - } - - while (1) { - ev = odp_schedule(NULL, ODP_SCHED_NO_WAIT); - - if (ev != ODP_EVENT_INVALID) - odp_event_free(ev); - else - break; - } - - return 0; -} - -int cls_pkt_set_seq(odp_packet_t pkt) -{ - static uint32_t seq; - cls_test_packet_t data; - uint32_t offset; - odph_ipv4hdr_t *ip; - odph_tcphdr_t *tcp; - int status; - - data.magic = DATA_MAGIC; - data.seq = ++seq; - - ip = (odph_ipv4hdr_t *)odp_packet_l3_ptr(pkt, NULL); - offset = odp_packet_l4_offset(pkt); - CU_ASSERT_FATAL(offset != ODP_PACKET_OFFSET_INVALID); - - if (ip->proto == ODPH_IPPROTO_UDP) - status = odp_packet_copy_from_mem(pkt, offset + ODPH_UDPHDR_LEN, - sizeof(data), &data); - else { - tcp = (odph_tcphdr_t *)odp_packet_l4_ptr(pkt, NULL); - status = odp_packet_copy_from_mem(pkt, offset + tcp->hl * 4, - sizeof(data), &data); - } - - return status; -} - -uint32_t cls_pkt_get_seq(odp_packet_t pkt) -{ - uint32_t offset; - cls_test_packet_t data; - odph_ipv4hdr_t *ip; - odph_tcphdr_t *tcp; - - ip = (odph_ipv4hdr_t *)odp_packet_l3_ptr(pkt, NULL); - offset = odp_packet_l4_offset(pkt); - - if (offset == ODP_PACKET_OFFSET_INVALID || ip == NULL) - return TEST_SEQ_INVALID; - - if (ip->proto == ODPH_IPPROTO_UDP) - odp_packet_copy_to_mem(pkt, offset + ODPH_UDPHDR_LEN, - sizeof(data), &data); - else { - tcp = (odph_tcphdr_t *)odp_packet_l4_ptr(pkt, NULL); - odp_packet_copy_to_mem(pkt, offset + tcp->hl * 4, - sizeof(data), &data); - } - - if (data.magic == DATA_MAGIC) - return data.seq; - - return TEST_SEQ_INVALID; -} - -int parse_ipv4_string(const char *ipaddress, uint32_t *addr, uint32_t *mask) -{ - int b[4]; - int qualifier = 32; - int converted; - - if (strchr(ipaddress, '/')) { - converted = sscanf(ipaddress, "%d.%d.%d.%d/%d", - &b[3], &b[2], &b[1], &b[0], - &qualifier); - if (5 != converted) - return -1; - } else { - converted = sscanf(ipaddress, "%d.%d.%d.%d", - &b[3], &b[2], &b[1], &b[0]); - if (4 != converted) - return -1; - } - - if ((b[0] > 255) || (b[1] > 255) || (b[2] > 255) || (b[3] > 255)) - return -1; - if (!qualifier || (qualifier > 32)) - return -1; - - *addr = b[0] | b[1] << 8 | b[2] << 16 | b[3] << 24; - if (mask) - *mask = ~(0xFFFFFFFF & ((1ULL << (32 - qualifier)) - 1)); - - return 0; -} - -void enqueue_pktio_interface(odp_packet_t pkt, odp_pktio_t pktio) -{ - odp_pktout_queue_t pktout; - - CU_ASSERT_FATAL(odp_pktout_queue(pktio, &pktout, 1) == 1); - CU_ASSERT(odp_pktout_send(pktout, &pkt, 1) == 1); -} - -odp_packet_t receive_packet(odp_queue_t *queue, uint64_t ns) -{ - odp_event_t ev; - - ev = odp_schedule(queue, ns); - return odp_packet_from_event(ev); -} - -odp_queue_t queue_create(const char *queuename, bool sched) -{ - odp_queue_t queue; - odp_queue_param_t qparam; - - if (sched) { - odp_queue_param_init(&qparam); - qparam.type = ODP_QUEUE_TYPE_SCHED; - qparam.sched.prio = ODP_SCHED_PRIO_HIGHEST; - qparam.sched.sync = ODP_SCHED_SYNC_PARALLEL; - qparam.sched.group = ODP_SCHED_GROUP_ALL; - - queue = odp_queue_create(queuename, &qparam); - } else { - queue = odp_queue_create(queuename, NULL); - } - - return queue; -} - -odp_pool_t pool_create(const char *poolname) -{ - odp_pool_param_t param; - - odp_pool_param_init(¶m); - param.pkt.seg_len = SHM_PKT_BUF_SIZE; - param.pkt.len = SHM_PKT_BUF_SIZE; - param.pkt.num = SHM_PKT_NUM_BUFS; - param.type = ODP_POOL_PACKET; - - return odp_pool_create(poolname, ¶m); -} - -odp_packet_t create_packet(cls_packet_info_t pkt_info) -{ - uint32_t seqno; - odph_ethhdr_t *ethhdr; - odph_udphdr_t *udp; - odph_tcphdr_t *tcp; - odph_ipv4hdr_t *ip; - odph_ipv6hdr_t *ipv6; - uint16_t payload_len; - uint64_t src_mac = CLS_DEFAULT_SMAC; - uint64_t dst_mac = CLS_DEFAULT_DMAC; - uint64_t dst_mac_be; - uint32_t addr = 0; - uint32_t mask; - odp_packet_t pkt; - int packet_len = 0; - uint32_t version, tc, flow, ver_tc_flow; - uint8_t *buf, next_hdr; - uint32_t l4_len, l3_len, l2_len, l3_offset, l4_offset; - uint16_t vlan_hdr_len = 0; - uint16_t l2_hdr_len = 0; - uint16_t l3_hdr_len = 0; - uint16_t l4_hdr_len = 0; - uint16_t eth_type; - odp_u16be_t *vlan_type; - odph_vlanhdr_t *vlan_hdr; - - /* 48 bit ethernet address needs to be left shifted for proper - value after changing to be*/ - dst_mac_be = odp_cpu_to_be_64(dst_mac); - if (dst_mac != dst_mac_be) - dst_mac_be = dst_mac_be >> (64 - 8 * ODPH_ETHADDR_LEN); - - payload_len = sizeof(cls_test_packet_t) + pkt_info.len; - seqno = odp_atomic_fetch_inc_u32(pkt_info.seq); - - vlan_hdr_len = pkt_info.vlan ? ODPH_VLANHDR_LEN : 0; - vlan_hdr_len = pkt_info.vlan_qinq ? 2 * vlan_hdr_len : vlan_hdr_len; - l3_hdr_len = pkt_info.ipv6 ? ODPH_IPV6HDR_LEN : ODPH_IPV4HDR_LEN; - l4_hdr_len = pkt_info.udp ? ODPH_UDPHDR_LEN : ODPH_TCPHDR_LEN; - eth_type = pkt_info.ipv6 ? ODPH_ETHTYPE_IPV6 : ODPH_ETHTYPE_IPV4; - next_hdr = pkt_info.udp ? ODPH_IPPROTO_UDP : ODPH_IPPROTO_TCP; - l2_hdr_len = ODPH_ETHHDR_LEN + vlan_hdr_len; - l4_len = l4_hdr_len + payload_len; - l3_len = l3_hdr_len + l4_len; - l2_len = l2_hdr_len + l3_len; - packet_len = l2_len; - - pkt = odp_packet_alloc(pkt_info.pool, packet_len); - CU_ASSERT_FATAL(pkt != ODP_PACKET_INVALID); - - /* Ethernet Header */ - buf = odp_packet_data(pkt); - odp_packet_l2_offset_set(pkt, 0); - ethhdr = (odph_ethhdr_t *)odp_packet_l2_ptr(pkt, NULL); - memcpy(ethhdr->src.addr, &src_mac, ODPH_ETHADDR_LEN); - memcpy(ethhdr->dst.addr, &dst_mac_be, ODPH_ETHADDR_LEN); - vlan_type = (odp_u16be_t *)(void *)ðhdr->type; - vlan_hdr = (odph_vlanhdr_t *)(ethhdr + 1); - - if (pkt_info.vlan_qinq) { - odp_packet_has_vlan_qinq_set(pkt, 1); - *vlan_type = odp_cpu_to_be_16(ODPH_ETHTYPE_VLAN_OUTER); - vlan_hdr->tci = odp_cpu_to_be_16(0); - vlan_type = (uint16_t *)(void *)&vlan_hdr->type; - vlan_hdr++; - } - if (pkt_info.vlan) { - /* Default vlan header */ - odp_packet_has_vlan_set(pkt, 1); - *vlan_type = odp_cpu_to_be_16(ODPH_ETHTYPE_VLAN); - vlan_hdr->tci = odp_cpu_to_be_16(0); - vlan_hdr->type = odp_cpu_to_be_16(eth_type); - } else { - ethhdr->type = odp_cpu_to_be_16(eth_type); - } - - l3_offset = l2_hdr_len; - odp_packet_l3_offset_set(pkt, l3_offset); - - if (!pkt_info.ipv6) { - /* ipv4 */ - ip = (odph_ipv4hdr_t *)(buf + l3_offset); - - parse_ipv4_string(CLS_DEFAULT_DADDR, &addr, &mask); - ip->dst_addr = odp_cpu_to_be_32(addr); - - parse_ipv4_string(CLS_DEFAULT_SADDR, &addr, &mask); - ip->src_addr = odp_cpu_to_be_32(addr); - ip->ver_ihl = ODPH_IPV4 << 4 | ODPH_IPV4HDR_IHL_MIN; - ip->id = odp_cpu_to_be_16(seqno); - ip->chksum = 0; - ip->chksum = odph_ipv4_csum_update(pkt); - ip->proto = next_hdr; - ip->tot_len = odp_cpu_to_be_16(l3_len); - ip->ttl = DEFAULT_TTL; - odp_packet_has_ipv4_set(pkt, 1); - } else { - /* ipv6 */ - odp_packet_has_ipv6_set(pkt, 1); - ipv6 = (odph_ipv6hdr_t *)odp_packet_l3_ptr(pkt, NULL); - version = ODPH_IPV6 << ODPH_IPV6HDR_VERSION_SHIFT; - tc = DEFAULT_TOS << ODPH_IPV6HDR_TC_SHIFT; - flow = seqno << ODPH_IPV6HDR_FLOW_LABEL_SHIFT; - ver_tc_flow = version | tc | flow; - - ipv6->ver_tc_flow = odp_cpu_to_be_32(ver_tc_flow); - ipv6->payload_len = odp_cpu_to_be_16(l4_len); - ipv6->next_hdr = next_hdr; - ipv6->hop_limit = DEFAULT_TTL; - memcpy(ipv6->src_addr, IPV6_SRC_ADDR, ODPH_IPV6ADDR_LEN); - memcpy(ipv6->dst_addr, IPV6_DST_ADDR, ODPH_IPV6ADDR_LEN); - } - - l4_offset = l3_offset + l3_hdr_len; - odp_packet_l4_offset_set(pkt, l4_offset); - tcp = (odph_tcphdr_t *)(buf + l4_offset); - udp = (odph_udphdr_t *)(buf + l4_offset); - - /* udp */ - if (pkt_info.udp) { - udp->src_port = odp_cpu_to_be_16(CLS_DEFAULT_SPORT); - udp->dst_port = odp_cpu_to_be_16(CLS_DEFAULT_DPORT); - udp->length = odp_cpu_to_be_16(payload_len + ODPH_UDPHDR_LEN); - udp->chksum = 0; - odp_packet_has_udp_set(pkt, 1); - if (odph_udp_tcp_chksum(pkt, ODPH_CHKSUM_GENERATE, NULL) != 0) { - LOG_ERR("odph_udp_tcp_chksum failed\n"); - return ODP_PACKET_INVALID; - } - } else { - tcp->src_port = odp_cpu_to_be_16(CLS_DEFAULT_SPORT); - tcp->dst_port = odp_cpu_to_be_16(CLS_DEFAULT_DPORT); - tcp->hl = ODPH_TCPHDR_LEN / 4; - tcp->cksm = 0; - odp_packet_has_tcp_set(pkt, 1); - if (odph_udp_tcp_chksum(pkt, ODPH_CHKSUM_GENERATE, NULL) != 0) { - LOG_ERR("odph_udp_tcp_chksum failed\n"); - return ODP_PACKET_INVALID; - } - - } - - /* set pkt sequence number */ - cls_pkt_set_seq(pkt); - - return pkt; -} - -odp_cls_pmr_term_t find_first_supported_l3_pmr(void) -{ - odp_cls_pmr_term_t term = ODP_PMR_TCP_DPORT; - odp_cls_capability_t capability; - - odp_cls_capability(&capability); - - /* choose supported PMR */ - if (capability.supported_terms.bit.udp_sport) - term = ODP_PMR_UDP_SPORT; - else if (capability.supported_terms.bit.udp_dport) - term = ODP_PMR_UDP_DPORT; - else if (capability.supported_terms.bit.tcp_sport) - term = ODP_PMR_TCP_SPORT; - else if (capability.supported_terms.bit.tcp_dport) - term = ODP_PMR_TCP_DPORT; - else - CU_FAIL("Implementations doesn't support any TCP/UDP PMR"); - - return term; -} - -int set_first_supported_pmr_port(odp_packet_t pkt, uint16_t port) -{ - odph_udphdr_t *udp; - odph_tcphdr_t *tcp; - odp_cls_pmr_term_t term; - - udp = (odph_udphdr_t *)odp_packet_l4_ptr(pkt, NULL); - tcp = (odph_tcphdr_t *)odp_packet_l4_ptr(pkt, NULL); - port = odp_cpu_to_be_16(port); - term = find_first_supported_l3_pmr(); - switch (term) { - case ODP_PMR_UDP_SPORT: - udp->src_port = port; - break; - case ODP_PMR_UDP_DPORT: - udp->dst_port = port; - break; - case ODP_PMR_TCP_DPORT: - tcp->dst_port = port; - break; - case ODP_PMR_TCP_SPORT: - tcp->src_port = port; - break; - default: - CU_FAIL("Unsupported L3 term"); - return -1; - } - - return 0; -} |