Merge branch 'dev_ck_v2.1_feature_enhancement##1110' into 'dev_ck_v2.1'
pcie场景增加case51,修改case14 feature enhancement#1110 See merge request ucp/driver/ucp4008_platform_spu!43
This commit is contained in:
Xianfeng Du
commit
fe841573fd
@ -1,50 +1,50 @@
|
|||||||
// +FHDR------------------------------------------------------------
|
// +FHDR------------------------------------------------------------
|
||||||
// Copyright (c) 2022 SmartLogic.
|
// Copyright (c) 2022 SmartLogic.
|
||||||
// ALL RIGHTS RESERVED
|
// ALL RIGHTS RESERVED
|
||||||
// -----------------------------------------------------------------
|
// -----------------------------------------------------------------
|
||||||
// Filename : ape0_recv_task.s.c
|
// Filename : ape0_recv_task.s.c
|
||||||
// Author :
|
// Author :
|
||||||
// Created On : 2022-10-24
|
// Created On : 2022-10-24
|
||||||
// Last Modified :
|
// Last Modified :
|
||||||
// -----------------------------------------------------------------
|
// -----------------------------------------------------------------
|
||||||
// Description:
|
// Description:
|
||||||
//
|
//
|
||||||
//
|
//
|
||||||
// -FHDR------------------------------------------------------------
|
// -FHDR------------------------------------------------------------
|
||||||
#include "ucp_utility.h"
|
#include "ucp_utility.h"
|
||||||
#include "msg_transfer_layer.h"
|
#include "msg_transfer_layer.h"
|
||||||
#include "phy_para.h"
|
#include "phy_para.h"
|
||||||
#include "ucp_tick.h"
|
#include "ucp_tick.h"
|
||||||
#include "ucp_testcase.h"
|
#include "ucp_testcase.h"
|
||||||
#include "spu_log.h"
|
#include "spu_log.h"
|
||||||
#include "osp_msg.h"
|
#include "osp_msg.h"
|
||||||
#include "ucp_printf.h"
|
#include "ucp_printf.h"
|
||||||
|
|
||||||
#define TEST_PORT_ID (0)
|
#define TEST_PORT_ID (0)
|
||||||
typedef struct SPU_SW_MSG_INFO
|
typedef struct SPU_SW_MSG_INFO1
|
||||||
{
|
{
|
||||||
uint32_t u32DataLen;
|
uint32_t u32DataLen;
|
||||||
uint32_t u32PktType;
|
uint32_t u32PktType;
|
||||||
uint32_t u32CoreId;
|
uint32_t u32CoreId;
|
||||||
uint32_t u32MsgType;
|
uint32_t u32MsgType;
|
||||||
}spu0_info_t;
|
}spu0_info_t;
|
||||||
|
|
||||||
void ape0_log_send_task()
|
void ape0_log_send_task()
|
||||||
{
|
{
|
||||||
char abuf2[256] = "ape0:ape0_log_send_task test12test67\n";
|
char abuf2[256] = "ape0:ape0_log_send_task test12test67\n";
|
||||||
spu0_info_t sttest;
|
spu0_info_t sttest;
|
||||||
|
|
||||||
sttest.u32DataLen = 0xaabbccdd;
|
sttest.u32DataLen = 0xaabbccdd;
|
||||||
sttest.u32PktType = 0x01020304;
|
sttest.u32PktType = 0x01020304;
|
||||||
sttest.u32CoreId = 0x05060708;
|
sttest.u32CoreId = 0x05060708;
|
||||||
sttest.u32MsgType = 0x090a0b0c;
|
sttest.u32MsgType = 0x090a0b0c;
|
||||||
|
|
||||||
delay_us(50);
|
delay_us(50);
|
||||||
|
|
||||||
spu_log_output(0, abuf2);
|
spu_log_output(0, abuf2);
|
||||||
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
||||||
osp_sendLog_print(0, (char *)&sttest, sizeof(spu0_info_t), 0);
|
osp_sendLog_print(0, (char *)&sttest, sizeof(spu0_info_t), 0);
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,50 +1,50 @@
|
|||||||
// +FHDR------------------------------------------------------------
|
// +FHDR------------------------------------------------------------
|
||||||
// Copyright (c) 2022 SmartLogic.
|
// Copyright (c) 2022 SmartLogic.
|
||||||
// ALL RIGHTS RESERVED
|
// ALL RIGHTS RESERVED
|
||||||
// -----------------------------------------------------------------
|
// -----------------------------------------------------------------
|
||||||
// Filename : ape0_recv_task.s.c
|
// Filename : ape0_recv_task.s.c
|
||||||
// Author :
|
// Author :
|
||||||
// Created On : 2022-10-24
|
// Created On : 2022-10-24
|
||||||
// Last Modified :
|
// Last Modified :
|
||||||
// -----------------------------------------------------------------
|
// -----------------------------------------------------------------
|
||||||
// Description:
|
// Description:
|
||||||
//
|
//
|
||||||
//
|
//
|
||||||
// -FHDR------------------------------------------------------------
|
// -FHDR------------------------------------------------------------
|
||||||
#include "ucp_utility.h"
|
#include "ucp_utility.h"
|
||||||
#include "msg_transfer_layer.h"
|
#include "msg_transfer_layer.h"
|
||||||
#include "phy_para.h"
|
#include "phy_para.h"
|
||||||
#include "ucp_tick.h"
|
#include "ucp_tick.h"
|
||||||
#include "ucp_testcase.h"
|
#include "ucp_testcase.h"
|
||||||
#include "spu_log.h"
|
#include "spu_log.h"
|
||||||
#include "osp_msg.h"
|
#include "osp_msg.h"
|
||||||
#include "ucp_printf.h"
|
#include "ucp_printf.h"
|
||||||
|
|
||||||
#define TEST_PORT_ID (0)
|
#define TEST_PORT_ID (0)
|
||||||
typedef struct SPU_SW_MSG_INFO
|
typedef struct SPU_SW_MSG_INFO1
|
||||||
{
|
{
|
||||||
uint32_t u32DataLen;
|
uint32_t u32DataLen;
|
||||||
uint32_t u32PktType;
|
uint32_t u32PktType;
|
||||||
uint32_t u32CoreId;
|
uint32_t u32CoreId;
|
||||||
uint32_t u32MsgType;
|
uint32_t u32MsgType;
|
||||||
}spu1_info_t;
|
}spu1_info_t;
|
||||||
|
|
||||||
|
|
||||||
void ape1_log_send_task()
|
void ape1_log_send_task()
|
||||||
{
|
{
|
||||||
char abuf2[256] = "ape1:ape1_log_send_task test12test67\n";
|
char abuf2[256] = "ape1:ape1_log_send_task test12test67\n";
|
||||||
spu1_info_t sttest;
|
spu1_info_t sttest;
|
||||||
|
|
||||||
sttest.u32DataLen = 0xaabbccdd;
|
sttest.u32DataLen = 0xaabbccdd;
|
||||||
sttest.u32PktType = 0x01020304;
|
sttest.u32PktType = 0x01020304;
|
||||||
sttest.u32CoreId = 0x05060708;
|
sttest.u32CoreId = 0x05060708;
|
||||||
sttest.u32MsgType = 0x090a0b0c;
|
sttest.u32MsgType = 0x090a0b0c;
|
||||||
|
|
||||||
delay_us(50);
|
delay_us(50);
|
||||||
|
|
||||||
spu_log_output(0, abuf2);
|
spu_log_output(0, abuf2);
|
||||||
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
||||||
osp_sendLog_print(0, (char *)&sttest, sizeof(spu1_info_t), 0);
|
osp_sendLog_print(0, (char *)&sttest, sizeof(spu1_info_t), 0);
|
||||||
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
@ -0,0 +1,61 @@
|
|||||||
|
// +FHDR------------------------------------------------------------
|
||||||
|
// Copyright (c) 2022 SmartLogic.
|
||||||
|
// ALL RIGHTS RESERVED
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Filename : ape_test_case1.s.c
|
||||||
|
// Author :
|
||||||
|
// Created On : 2022-10-26
|
||||||
|
// Last Modified :
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Description:
|
||||||
|
//
|
||||||
|
//
|
||||||
|
// -FHDR------------------------------------------------------------
|
||||||
|
|
||||||
|
#include "typedef.h"
|
||||||
|
#include "ucp_printf.h"
|
||||||
|
#include "phy_para.h"
|
||||||
|
|
||||||
|
|
||||||
|
/************************************************************************/
|
||||||
|
extern void cpri_init(uint32_t option,uint32_t MappingMode);
|
||||||
|
extern void jesd_init();
|
||||||
|
extern void ecpri_init(uint8_t nOption);
|
||||||
|
|
||||||
|
int32_t fh_data_init(void)
|
||||||
|
{
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
int32_t fh_drv_init()
|
||||||
|
{
|
||||||
|
#ifdef DISTRIBUTED_BS
|
||||||
|
cpri_init(CPRI_OPTION_8, OTIC_MAP_FIGURE12);
|
||||||
|
#endif
|
||||||
|
#ifdef ECPRI_DISTRIBUTED_BS
|
||||||
|
ecpri_init(ECPRI_OPTION_10G);
|
||||||
|
#endif
|
||||||
|
#ifdef INTEGRATED_BS
|
||||||
|
jesd_init();
|
||||||
|
#endif
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
int32_t fh_csu_test_init(void)
|
||||||
|
{
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
void fh_test_case()
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
void fh_data_check(uint32_t times)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
33
public/test/testcases/case51/osp/inc/pcie_testcase.h
Normal file
33
public/test/testcases/case51/osp/inc/pcie_testcase.h
Normal file
@ -0,0 +1,33 @@
|
|||||||
|
// +FHDR------------------------------------------------------------
|
||||||
|
// Copyright (c) 2022 SmartLogic.
|
||||||
|
// ALL RIGHTS RESERVED
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Filename : ucp_pcie_traffic.h
|
||||||
|
// Author : xianfeng.du
|
||||||
|
// Created On : 2022-06-25
|
||||||
|
// Last Modified :
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Description:
|
||||||
|
//
|
||||||
|
//
|
||||||
|
// -FHDR------------------------------------------------------------
|
||||||
|
#ifndef __PCIE_TESTCASE_H__
|
||||||
|
#define __PCIE_TESTCASE_H__
|
||||||
|
|
||||||
|
|
||||||
|
uint32_t pcie_rx_callback_data(const char* buf,uint32_t payloadSize);
|
||||||
|
uint32_t pcie_rx_callback_ctrl(const char* buf,uint32_t payloadSize);
|
||||||
|
uint32_t pcie_rx_callback_oam(const char* buf,uint32_t payloadSize);
|
||||||
|
void test_case_cfgpar_pcie();
|
||||||
|
void test_case_sendmsg_pcie();
|
||||||
|
void test_case_recv_msg_pcie();
|
||||||
|
void test_speed_sendmsg_pcie();
|
||||||
|
void test_speed_recv_msg_pcie();
|
||||||
|
void ape0_test_task_reg(void);
|
||||||
|
void pcie_test_task_func(void);
|
||||||
|
void ape1_test_task_reg(void);
|
||||||
|
void ape2_test_task_reg(void);
|
||||||
|
void ape3_test_task_reg(void);
|
||||||
|
#endif
|
||||||
|
|
||||||
|
|
||||||
618
public/test/testcases/case51/osp/src/pcie_testcase.c
Normal file
618
public/test/testcases/case51/osp/src/pcie_testcase.c
Normal file
@ -0,0 +1,618 @@
|
|||||||
|
// +FHDR------------------------------------------------------------
|
||||||
|
// Copyright (c) 2022 SmartLogic.
|
||||||
|
// ALL RIGHTS RESERVED
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Filename : main.c
|
||||||
|
// Author : xianfeng.du
|
||||||
|
// Created On : 2022-06-25
|
||||||
|
// Last Modified :
|
||||||
|
// -----------------------------------------------------------------
|
||||||
|
// Description:
|
||||||
|
//
|
||||||
|
//
|
||||||
|
// -FHDR------------------------------------------------------------
|
||||||
|
#include "typedef.h"
|
||||||
|
#include "osp_task.h"
|
||||||
|
#include "osp_timer.h"
|
||||||
|
#include "ucp_printf.h"
|
||||||
|
#include "spu_log.h"
|
||||||
|
|
||||||
|
#include "ucp_drv_common.h"
|
||||||
|
//#include "pet_rfm_spu0_top.h"
|
||||||
|
//#include "msg_transfer_host.h"
|
||||||
|
#include "msg_transfer_layer.h"
|
||||||
|
//#include "ucp_pcie_traffic.h"
|
||||||
|
#include "ucp_printf.h"
|
||||||
|
#include "msg_transfer_mem.h"
|
||||||
|
#include "msg_transfer_mbuffer.h"
|
||||||
|
#include "ucp_drv_common.h"
|
||||||
|
|
||||||
|
#define RC_OAM_MSG 0
|
||||||
|
|
||||||
|
typedef struct SPU_SW_MSG_INFO1
|
||||||
|
{
|
||||||
|
uint32_t u32DataLen;
|
||||||
|
uint32_t u32PktType;
|
||||||
|
uint32_t u32CoreId;
|
||||||
|
uint32_t u32MsgType;
|
||||||
|
}spu1_info_t;
|
||||||
|
|
||||||
|
typedef struct tOamMsgTransferHeader {
|
||||||
|
uint8_t numMsg;
|
||||||
|
uint8_t cellIndex;
|
||||||
|
uint16_t rsv;
|
||||||
|
uint32_t msgType;
|
||||||
|
uint32_t msgLen;
|
||||||
|
uint32_t msgData[0];
|
||||||
|
} OamMsgTransferHeader_t;
|
||||||
|
|
||||||
|
typedef struct tSpuOamBaseDelayQryRsp {
|
||||||
|
uint8_t u8fiber_port;
|
||||||
|
uint8_t u8result;
|
||||||
|
uint8_t u8rsv[2];
|
||||||
|
uint32_t u32dl_frame_offset;
|
||||||
|
uint32_t u32ul_frame_offset;
|
||||||
|
} SpuOamBaseDelayQryRsp_t;
|
||||||
|
|
||||||
|
|
||||||
|
static uint32_t g_ape0 = 0;
|
||||||
|
static uint32_t g_ape1 = 0;
|
||||||
|
static OamMsgTransferHeader_t *g_oam_msg_ptr = NULL;
|
||||||
|
|
||||||
|
uint32_t pcie_rx_callback_data(const char* buf,uint32_t payloadSize)
|
||||||
|
{
|
||||||
|
char tmplogbuf[1024] = {0};
|
||||||
|
if(payloadSize < 1024)
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, payloadSize);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, 1024);
|
||||||
|
}
|
||||||
|
UCP_PRINT_LOG("received buf : %s\n", tmplogbuf);
|
||||||
|
|
||||||
|
return payloadSize;
|
||||||
|
}
|
||||||
|
|
||||||
|
uint32_t pcie_rx_callback_ctrl(const char* buf,uint32_t payloadSize)
|
||||||
|
{
|
||||||
|
char tmplogbuf[1024] = {0};
|
||||||
|
if(payloadSize < 1024)
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, payloadSize);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, 1024);
|
||||||
|
}
|
||||||
|
UCP_PRINT_LOG("received buf : %s\n", tmplogbuf);
|
||||||
|
|
||||||
|
return payloadSize;
|
||||||
|
}
|
||||||
|
|
||||||
|
uint32_t pcie_rx_callback_oam(const char* buf,uint32_t payloadSize)
|
||||||
|
{
|
||||||
|
char tmplogbuf[1024] = {0};
|
||||||
|
if(payloadSize < 1024)
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, payloadSize);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
memcpy_ucp(tmplogbuf, buf, 1024);
|
||||||
|
}
|
||||||
|
UCP_PRINT_LOG("received buf : %s\n", tmplogbuf);
|
||||||
|
|
||||||
|
return payloadSize;
|
||||||
|
}
|
||||||
|
|
||||||
|
void test_case_cfgpar_pcie()
|
||||||
|
{
|
||||||
|
int i = 0;
|
||||||
|
|
||||||
|
for(i = 0; i < MAX_INSTANCE_NUM; i++)
|
||||||
|
{
|
||||||
|
msg_transfer_callback_register(CU_SPLIT, i, C_PLANE, pcie_rx_callback_ctrl);
|
||||||
|
msg_transfer_callback_register(CU_SPLIT, i, U_PLANE, pcie_rx_callback_data);
|
||||||
|
msg_transfer_callback_register(OAM, i, C_PLANE, pcie_rx_callback_oam);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
int8_t get_id(uint16_t type_id, uint16_t cu_flag)
|
||||||
|
{
|
||||||
|
int8_t que_id = -1;
|
||||||
|
|
||||||
|
switch (type_id) {
|
||||||
|
case CU_SPLIT:
|
||||||
|
if (cu_flag == U_PLANE) {
|
||||||
|
que_id = UCP4008_TRAFFIC_NR_eMBB_DATA;
|
||||||
|
} else {
|
||||||
|
que_id = UCP4008_TRAFFIC_NR_eMBB_CTRL;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case OAM:
|
||||||
|
que_id = UCP4008_TRAFFIC_OAM;
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
UCP_PRINT_ERROR("get_queue_id doesn't support transfer_type[%d] .",type_id);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
return que_id;
|
||||||
|
}
|
||||||
|
|
||||||
|
//static uint32_t count = 0;
|
||||||
|
|
||||||
|
void test_case_sendmsg_pcie()
|
||||||
|
{
|
||||||
|
uint32_t size = 512-16;
|
||||||
|
char* buf = NULL;
|
||||||
|
uint32_t availableSize;
|
||||||
|
|
||||||
|
uint16_t cu_flag = C_PLANE;
|
||||||
|
HandleId_t handler;
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = 0;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
uint32_t slot_ind_flag = 1;
|
||||||
|
int ret = 0;
|
||||||
|
|
||||||
|
uint32_t offset = 0;
|
||||||
|
uint32_t i = 0;
|
||||||
|
char templogbuf[256] = {0};
|
||||||
|
|
||||||
|
int8_t que_id = 0;
|
||||||
|
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
|
||||||
|
MsgQueueLocalInfo_t* ch = (MsgQueueLocalInfo_t *)&pMsgQueueLocalMgt->localDlQueue[0][1];
|
||||||
|
//uint32_t core_id = get_core_id();
|
||||||
|
//uint32_t bufsize = ch->bufSize - MSG_MBUF_HEAD_SIZE;
|
||||||
|
/****************************test code************************************************/
|
||||||
|
for(i = 0; i < MAX_INSTANCE_NUM; i++)
|
||||||
|
{
|
||||||
|
//debug_write(DBG_DDR_COMMON_IDX(core_id, 2), ++count);
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = i;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
if(1 == slot_ind_flag)
|
||||||
|
{
|
||||||
|
// slot_ind_flag = 0;
|
||||||
|
ret = msg_transfer_send_start(handler.value);
|
||||||
|
/************C_PLANE***************/
|
||||||
|
cu_flag = C_PLANE;
|
||||||
|
que_id = get_id(handler.type_id, cu_flag);
|
||||||
|
ch = (MsgQueueLocalInfo_t *)&pMsgQueueLocalMgt->localDlQueue[i][que_id];
|
||||||
|
size = ch->bufSize-MSG_MBUF_HEAD_SIZE;
|
||||||
|
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
|
||||||
|
if ( SUCCESS != ret) {
|
||||||
|
UCP_PRINT_ERROR("alloc msg failed!\n");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
//size = availableSize;
|
||||||
|
//buf = *bufAddr;
|
||||||
|
UCP_PRINT_ERROR("msg transfer alloced ul msg C_PLANE buf = 0x%x!\n", buf);
|
||||||
|
memset(templogbuf, 0x00, sizeof(templogbuf));
|
||||||
|
sprintf(templogbuf, "%s", "this is test for ul CU_SPLIT ctrl transfer!\n");
|
||||||
|
memcpy_ucp(buf, templogbuf, strlen(templogbuf)+1);
|
||||||
|
/*
|
||||||
|
*(uint32_t*)(ptr + 0) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 4) = 0x5a5a5a5a;
|
||||||
|
*(uint32_t*)(ptr + 8) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 12) = 0xa5a5a5a5;
|
||||||
|
*/
|
||||||
|
//PCIE_DEBUG_LOG("start enter msg_transfer_send_msg\n");
|
||||||
|
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
|
||||||
|
if(ret != SUCCESS)
|
||||||
|
{
|
||||||
|
UCP_PRINT_ERROR("ul msg_transfer_send_msg CU_SPLIT ctrl failed! ret = %d\n", ret);
|
||||||
|
}
|
||||||
|
|
||||||
|
/************U_PLANE***************/
|
||||||
|
cu_flag = U_PLANE;
|
||||||
|
que_id = get_id(handler.type_id, cu_flag);
|
||||||
|
ch = (MsgQueueLocalInfo_t *)&pMsgQueueLocalMgt->localDlQueue[i][que_id];
|
||||||
|
size = ch->bufSize-MSG_MBUF_HEAD_SIZE;
|
||||||
|
|
||||||
|
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
|
||||||
|
if ( SUCCESS != ret) {
|
||||||
|
UCP_PRINT_ERROR("alloc msg failed!\n");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
//size = availableSize;
|
||||||
|
//buf = *bufAddr;
|
||||||
|
UCP_PRINT_ERROR("msg transfer alloced ul U_PLANE msg buf = 0x%x!\n", buf);
|
||||||
|
memset(templogbuf, 0x00, sizeof(templogbuf));
|
||||||
|
sprintf(templogbuf, "%s", "this is test for ul CU_SPLIT data transfer!\n");
|
||||||
|
memcpy_ucp(buf, templogbuf, strlen(templogbuf)+1);
|
||||||
|
|
||||||
|
/*
|
||||||
|
ptr = (uint8_t *)buf;
|
||||||
|
*(uint32_t*)(ptr + 0) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 4) = 0x5a5a5a5a;
|
||||||
|
*(uint32_t*)(ptr + 8) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 12) = 0xa5a5a5a5;
|
||||||
|
*/
|
||||||
|
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
|
||||||
|
if(ret != SUCCESS)
|
||||||
|
{
|
||||||
|
UCP_PRINT_ERROR("ul msg_transfer_send_msg CU_SPLIT data failed! ret = %d\n", ret);
|
||||||
|
}
|
||||||
|
|
||||||
|
ret = msg_transfer_send_end(handler.value);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
handler.type_id = OAM;
|
||||||
|
if(1 == slot_ind_flag)
|
||||||
|
{
|
||||||
|
// slot_ind_flag = 0;
|
||||||
|
|
||||||
|
ret = msg_transfer_send_start(handler.value);
|
||||||
|
|
||||||
|
/************C_PLANE***************/
|
||||||
|
cu_flag = C_PLANE;
|
||||||
|
que_id = get_id(handler.type_id, cu_flag);
|
||||||
|
ch = (MsgQueueLocalInfo_t *)&pMsgQueueLocalMgt->localDlQueue[i][que_id];
|
||||||
|
size = ch->bufSize-MSG_MBUF_HEAD_SIZE;
|
||||||
|
|
||||||
|
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
|
||||||
|
if ( SUCCESS != ret) {
|
||||||
|
UCP_PRINT_ERROR("alloc msg failed!\n");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
//size = availableSize;
|
||||||
|
//buf = *bufAddr;
|
||||||
|
UCP_PRINT_ERROR("msg transfer alloced msg OAM buf = 0x%x!\n", buf);
|
||||||
|
memset(templogbuf, 0x00, sizeof(templogbuf));
|
||||||
|
sprintf(templogbuf, "%s", "this is test for ul OAM ctrl transfer!\n");
|
||||||
|
memcpy_ucp(buf, templogbuf, strlen(templogbuf)+1);
|
||||||
|
|
||||||
|
/*
|
||||||
|
*(uint32_t*)(ptr + 0) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 4) = 0x5a5a5a5a;
|
||||||
|
*(uint32_t*)(ptr + 8) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 12) = 0xa5a5a5a5;
|
||||||
|
*/
|
||||||
|
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
|
||||||
|
if(ret != SUCCESS)
|
||||||
|
{
|
||||||
|
UCP_PRINT_ERROR("ul msg_transfer_send_msg failed! CU_SPLIT oam ! ret = %d\n", ret);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
UCP_PRINT_ERROR("msg_transfer_send_msg end!\n");
|
||||||
|
ret = msg_transfer_send_end(handler.value);
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/*********************************************************************************/
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
void test_case_recv_msg_pcie()
|
||||||
|
{
|
||||||
|
uint16_t cu_flag = C_PLANE;
|
||||||
|
HandleId_t handler;
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = 0;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
|
||||||
|
uint8_t port_id = 0;
|
||||||
|
uint32_t offset = 0;
|
||||||
|
uint32_t len = 0;
|
||||||
|
uint8_t* msg_ptr;
|
||||||
|
uint32_t i = 0;
|
||||||
|
|
||||||
|
/****************************test code************************************************/
|
||||||
|
for ( i = 0; i < MAX_INSTANCE_NUM; i++) {
|
||||||
|
handler.port_id = port_id;
|
||||||
|
handler.inst_id = i;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
cu_flag = C_PLANE;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
|
||||||
|
cu_flag = U_PLANE;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
|
||||||
|
handler.type_id = OAM;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
}
|
||||||
|
/*********************************************************************************/
|
||||||
|
}
|
||||||
|
|
||||||
|
#if 0
|
||||||
|
|
||||||
|
void test_speed_sendmsg_pcie()
|
||||||
|
{
|
||||||
|
uint32_t size = 0;
|
||||||
|
char* buf = NULL;
|
||||||
|
uint32_t availableSize;
|
||||||
|
|
||||||
|
uint16_t cu_flag = C_PLANE;
|
||||||
|
HandleId_t handler;
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = 0;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
uint32_t slot_ind_flag = 1;
|
||||||
|
int ret = 0;
|
||||||
|
|
||||||
|
uint32_t offset = 0;
|
||||||
|
uint32_t i = 0;
|
||||||
|
char templogbuf[1024] = {0};
|
||||||
|
|
||||||
|
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
|
||||||
|
MsgQueueLocalInfo_t* ch = (MsgQueueLocalInfo_t*)&pMsgQueueLocalMgt->localUlQueue[0][1];
|
||||||
|
size = ch->bufSize - MSG_MBUF_HEAD_SIZE;
|
||||||
|
/****************************test code************************************************/
|
||||||
|
for(i = 0; i < 2; i++)
|
||||||
|
{
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = i;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
if(1 == slot_ind_flag)
|
||||||
|
{
|
||||||
|
// slot_ind_flag = 0;
|
||||||
|
ret = msg_transfer_send_start(handler.value);
|
||||||
|
|
||||||
|
/************C_PLANE***************/
|
||||||
|
cu_flag = C_PLANE;
|
||||||
|
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
|
||||||
|
if ( SUCCESS != ret) {
|
||||||
|
UCP_PRINT_LOG("alloc msg failed!\n");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
//size = availableSize;
|
||||||
|
//buf = *bufAddr;
|
||||||
|
UCP_PRINT_LOG("msg transfer alloced ul msg C_PLANE buf = 0x%x!\n", buf);
|
||||||
|
memset(templogbuf, 0x00, sizeof(templogbuf));
|
||||||
|
sprintf(templogbuf, "%s", "this is test for ul CU_SPLIT ctrl transfer!\n");
|
||||||
|
memcpy_ucp(buf, templogbuf, strlen(templogbuf)+1);
|
||||||
|
/*
|
||||||
|
*(uint32_t*)(ptr + 0) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 4) = 0x5a5a5a5a;
|
||||||
|
*(uint32_t*)(ptr + 8) = 0x12345678;
|
||||||
|
*(uint32_t*)(ptr + 12) = 0xa5a5a5a5;
|
||||||
|
*/
|
||||||
|
//PCIE_DEBUG_LOG("start enter msg_transfer_send_msg\n");
|
||||||
|
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
|
||||||
|
if(ret != SUCCESS)
|
||||||
|
{
|
||||||
|
UCP_PRINT_LOG("ul msg_transfer_send_msg CU_SPLIT ctrl failed! ret = %d\n", ret);
|
||||||
|
}
|
||||||
|
|
||||||
|
ret = msg_transfer_send_end(handler.value);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
/*********************************************************************************/
|
||||||
|
|
||||||
|
}
|
||||||
|
#endif
|
||||||
|
|
||||||
|
void test_speed_recv_msg_pcie()
|
||||||
|
{
|
||||||
|
uint16_t cu_flag = C_PLANE;
|
||||||
|
HandleId_t handler;
|
||||||
|
handler.port_id = 0;
|
||||||
|
handler.inst_id = 0;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
|
||||||
|
uint8_t port_id = 0;
|
||||||
|
uint32_t offset = 0;
|
||||||
|
uint32_t len = 0;
|
||||||
|
uint8_t* msg_ptr;
|
||||||
|
uint32_t i = 0;
|
||||||
|
|
||||||
|
/****************************test code************************************************/
|
||||||
|
for ( i = 0; i < 2; i++) {
|
||||||
|
handler.port_id = port_id;
|
||||||
|
handler.inst_id = i;
|
||||||
|
handler.type_id = CU_SPLIT;
|
||||||
|
cu_flag = C_PLANE;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
|
||||||
|
cu_flag = U_PLANE;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
|
||||||
|
handler.type_id = OAM;
|
||||||
|
msg_transfer_receive(handler.value, cu_flag, offset, len, &msg_ptr);
|
||||||
|
}
|
||||||
|
/*********************************************************************************/
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
uint32_t oam_spu_fill_rc_msg_header(uint8_t inst_id, char* buf, uint32_t size, uint32_t msgType)
|
||||||
|
{
|
||||||
|
OamMsgTransferHeader_t header;
|
||||||
|
header.numMsg = 1;
|
||||||
|
header.cellIndex = inst_id;
|
||||||
|
header.msgType = msgType;
|
||||||
|
header.msgLen = size + sizeof(OamMsgTransferHeader_t);
|
||||||
|
uint8_t u8core_id = (uint8_t)get_core_id();
|
||||||
|
|
||||||
|
memcpy_ucp(buf, &header, sizeof(OamMsgTransferHeader_t));
|
||||||
|
__ucps2_synch(0);
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(u8core_id, 57), buf);/*0xb7e016e4*/
|
||||||
|
|
||||||
|
uint32_t dst_addr = (uint32_t)(buf + sizeof(OamMsgTransferHeader_t));
|
||||||
|
|
||||||
|
return dst_addr;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
int32_t oam_spu_send_rc_msg(uint8_t inst_id, uint32_t src_addr, uint32_t size, uint32_t msgType)
|
||||||
|
{
|
||||||
|
uint8_t u8core_id = (uint8_t)get_core_id();
|
||||||
|
|
||||||
|
if (0 == size) {
|
||||||
|
return SUCCESS;
|
||||||
|
}
|
||||||
|
uint32_t len = size+sizeof(OamMsgTransferHeader_t);
|
||||||
|
|
||||||
|
char* buf;
|
||||||
|
uint32_t availableSize,offset;
|
||||||
|
|
||||||
|
uint16_t cu_flag = C_PLANE;
|
||||||
|
HandleId_t handler;
|
||||||
|
handler.port_id = u8core_id;
|
||||||
|
handler.inst_id = inst_id;
|
||||||
|
handler.type_id = OAM;
|
||||||
|
|
||||||
|
int32_t ret = msg_transfer_send_start(handler.value);
|
||||||
|
ret = msg_transfer_alloc_msg(handler.value, cu_flag, len, &buf, &availableSize, &offset);
|
||||||
|
if (SUCCESS != ret)
|
||||||
|
{
|
||||||
|
UCP_PRINT_ERROR("oam_spu_send_msg ret[0x%08x]", ret);
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
uint32_t dst_addr = oam_spu_fill_rc_msg_header(inst_id, buf, size, msgType);
|
||||||
|
|
||||||
|
//ape_csu_dma_1D_G2L_ch2ch3_transfer((uint64_t)((uint32_t)(src_addr-0x100000)), dst_addr, size, inst_id, 1);
|
||||||
|
//ape_csu_dma_1D_L2G_ch2ch3_transfer((uint64_t)((uint32_t)(src_addr-0x100000)), dst_addr, size, inst_id, 1);
|
||||||
|
memcpy_ucp(dst_addr, src_addr, size);
|
||||||
|
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(u8core_id, 53), dst_addr);/*0xb7e002d4*/
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(u8core_id, 54), src_addr);
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(u8core_id, 55), buf);
|
||||||
|
|
||||||
|
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, len);
|
||||||
|
ret = msg_transfer_send_end(handler.value);
|
||||||
|
|
||||||
|
UCP_PRINT_LOG("oam_spu_send_msg buf:%p len:%d\n", buf, len);
|
||||||
|
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
/* 收到rc侧发来的oam消息（通过RFM转发） */
|
||||||
|
static uint32_t g_u32_case20_ape1_event1_rev_num = 0; // 30 0xB7E00278
|
||||||
|
static uint32_t g_u32_case20_ape1_event1_rev_ok = 0; // 31 0xB7E0027C
|
||||||
|
static uint32_t g_u32_case20_ape1_event1_addr_err = 0; // 32 0xB7E00280
|
||||||
|
|
||||||
|
void ape1_oam_event1_task(uint32_t addr, uint32_t size)
|
||||||
|
{
|
||||||
|
uint32_t ape_id = get_core_id();
|
||||||
|
uint32_t msg_addr = 0;
|
||||||
|
int32_t ret = 0;
|
||||||
|
SpuOamBaseDelayQryRsp_t *oam_base_delay_qry_rsp_ptr = NULL;
|
||||||
|
|
||||||
|
g_u32_case20_ape1_event1_rev_num++;
|
||||||
|
if (0 == addr)
|
||||||
|
{
|
||||||
|
g_u32_case20_ape1_event1_addr_err++;
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(ape_id, 32), g_u32_case20_ape1_event1_addr_err);
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
msg_addr = do_read(addr);
|
||||||
|
|
||||||
|
g_oam_msg_ptr = (OamMsgTransferHeader_t*)msg_addr;
|
||||||
|
g_u32_case20_ape1_event1_rev_ok++;
|
||||||
|
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(ape_id, 30), g_oam_msg_ptr->cellIndex);
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(ape_id, 31), g_oam_msg_ptr->msgType);
|
||||||
|
debug_write(DBG_DDR_COMMON_IDX(ape_id, 32), g_oam_msg_ptr->numMsg);
|
||||||
|
oam_base_delay_qry_rsp_ptr = (SpuOamBaseDelayQryRsp_t *)(msg_addr+sizeof(OamMsgTransferHeader_t));
|
||||||
|
oam_base_delay_qry_rsp_ptr->u8result = 1;
|
||||||
|
|
||||||
|
ret = oam_spu_send_rc_msg(g_oam_msg_ptr->cellIndex, (uint32_t)oam_base_delay_qry_rsp_ptr, sizeof(SpuOamBaseDelayQryRsp_t), 0x203);
|
||||||
|
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
void pcie_ape0_task_func(void)
|
||||||
|
{
|
||||||
|
uint32_t core_id = get_core_id();
|
||||||
|
|
||||||
|
char abuf2[256] = "ape0:ape0_log_send_task test12test67\n";
|
||||||
|
spu1_info_t sttest;
|
||||||
|
|
||||||
|
sttest.u32DataLen = 0xaabbccdd;
|
||||||
|
sttest.u32PktType = 0x01020304;
|
||||||
|
sttest.u32CoreId = 0x05060708;
|
||||||
|
sttest.u32MsgType = 0x090a0b0c;
|
||||||
|
|
||||||
|
spu_log_output(0, abuf2);
|
||||||
|
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
||||||
|
osp_sendLog_print(0, (char *)&sttest, sizeof(spu1_info_t), 0);
|
||||||
|
|
||||||
|
g_ape0++;
|
||||||
|
debug_write(OSP_DEBUG_POT(core_id, 38), g_ape0);//0xb7e02098
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
void pcie_ape1_task_func(void)
|
||||||
|
{
|
||||||
|
uint32_t core_id = get_core_id();
|
||||||
|
char abuf2[256] = "ape1:ape1_log_send_task test12test67\n";
|
||||||
|
spu1_info_t sttest;
|
||||||
|
|
||||||
|
sttest.u32DataLen = 0xaabbccdd;
|
||||||
|
sttest.u32PktType = 0x01020304;
|
||||||
|
sttest.u32CoreId = 0x05060708;
|
||||||
|
sttest.u32MsgType = 0x090a0b0c;
|
||||||
|
|
||||||
|
spu_log_output(0, abuf2);
|
||||||
|
osp_sendLog(0, abuf2, strlen(abuf2), 0);
|
||||||
|
osp_sendLog_print(0, (char *)&sttest, sizeof(spu1_info_t), 0);
|
||||||
|
|
||||||
|
g_ape1++;
|
||||||
|
debug_write(OSP_DEBUG_POT(core_id, 39), g_ape1);//0xb7e0245c
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape0_test_task_reg(void)
|
||||||
|
{
|
||||||
|
osp_task_info_ex pcie_timer_task_stc = {58, (int8_t*)"pcie_test_taskc", 58, 4096, OSP_NORMAL_TYPE, 3, 0, 0, NULL, (OSP_TASKENTRY_FUNC)pcie_ape0_task_func};
|
||||||
|
osp_task_create(&pcie_timer_task_stc);
|
||||||
|
//osp_timer_sync(1);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape1_test_task_reg(void)
|
||||||
|
{
|
||||||
|
osp_task_info_ex ape1_event_task_recv = {40, (int8_t*)"ape1_test_taskd", 40, 2048, OSP_EVENT_TYPE, 0, 0 , 0, NULL, (OSP_TASKENTRY_FUNC)ape1_oam_event1_task};
|
||||||
|
osp_task_info_ex pcie_timer_task_stc1 = {61, (int8_t*)"pcie_test_taskc1", 61, 4096, OSP_NORMAL_TYPE, 5, 0, 0, NULL, (OSP_TASKENTRY_FUNC)pcie_ape1_task_func};
|
||||||
|
osp_task_create(&ape1_event_task_recv);
|
||||||
|
osp_task_create(&pcie_timer_task_stc1);
|
||||||
|
//osp_timer_sync(1);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape2_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape3_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape4_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape5_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape6_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ape7_test_task_reg(void)
|
||||||
|
{
|
||||||
|
return ;
|
||||||
|
}
|
||||||
|
|
||||||
Loading…
x
Reference in New Issue
Block a user