qieyuan/yb_arm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1. New Feature#1006

Browse Source 
2. add case0 : LTE 2 ape testcase
3. add case20: NR  4 ape testcase
4. add case21: NR  8 ape testcase
5. add case22: LTE 8 ape testcase
6. add case50: PCIE EP: arm read cfg for phy
This commit is contained in:
lishuang.xie 2023-08-23 16:02:18 +08:00
parent a6cc27e188
commit d734e714d5
12 changed files with 1370 additions and 281 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main.c
View File

@ -37,6 +37,8 @@ extern int32_t UCP_API_RFIC_CellSetup(uint64_t txLo, uint64_t rxLo, uint64_t bw,
#define MAX_PARA_NUM 4
uint8_t gu8_main_flag = 1; /* main fun while(): 1 while; 0: out */
int32_t main(int32_t argc, char* argvp[])
{
//uint32_t stc_cnt = 0, stc_cnt1 = 0;
@ -73,7 +75,7 @@ int32_t main(int32_t argc, char* argvp[])
test_case(count, args);
#endif
while (1)
while (gu8_main_flag)
{
usleep(100);
}

2
app/src/ucp_handshake.c
View File

@ -29,7 +29,7 @@ void ucp_handshake(void)
UcpHandshake_t* pHandshake = pPetSmLocalMgt->pHandshake;
pHandshake->request[core_id] = request;
UCP_PRINT_DEBUG("core[0x%08x] sent handshake request message,value[0x%08x].",core_id,request);
UCP_PRINT_DEBUG("core[0x%08x] send handshake request message,value[0x%08x].",core_id,request);
while(1) {
response = pHandshake->response[core_id];

0
test/case0/2ape_case(15K).txt Normal file
View File

498
test/case0/src/testcase.c
View File

@ -1,95 +1,82 @@
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
//
//
// -FHDR------------------------------------------------------------
#include <stddef.h>
#include <string.h>
#include <sys/time.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
#include "msg_transfer_mem.h"
#include "pet_sm_mgt.h"
#include "ucp_handshake.h"
#include "ospShell.h"
#include "ospLog.h"
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
//
//
// -FHDR------------------------------------------------------------
#include <stddef.h>
#include <string.h>
#include <sys/time.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
#include "msg_transfer_mem.h"
#include "pet_sm_mgt.h"
#include "ucp_handshake.h"
#include "ospShell.h"
#include "ospLog.h"
#include "ospCfgToBin.h"
#include "drv_init.h"
uint32_t slot_ind_flag = 0;
uint32_t slot_ind_time_flag = 0;
uint32_t g_slot_time = 0;
uint32_t gu32_value = 0;
uint32_t gu32_tick_receive_ctrl = 0;
uint32_t gu32_tick_from_tx_ctrl = 0;
uint32_t rx_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t tick_from_tx_ctrl = *(uint32_t *)(buf+4);
slot_ind_flag = 1;
gu32_value = value;
gu32_tick_receive_ctrl = stc_cnt;
gu32_tick_from_tx_ctrl = tick_from_tx_ctrl;
uint32_t diff = stc_cnt - tick_from_tx_ctrl;
//UCP_PRINT_LOG("a72_rx[%d], ape_tx[%d],offset[%d]",stc_cnt,tick_from_tx_ctrl,diff);
//UCP_PRINT_LOG("qNO[%d],sfn[%d],slot[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot);
if(0 == slot_ind_time_flag)
{
slot_ind_time_flag = 1;
diff = 500000;
}
else
{
diff = stc_cnt - g_slot_time;
}
g_slot_time = stc_cnt;
if ((diff > 520000) || (diff < 480000))
{
UCP_PRINT_ERROR("qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
//EcsSmLocalMgt_t* pEcsSmLocalMgt = get_ecs_sm_local_mgt();
///MsgQueueCommonInfo_t* chCommon = pEcsSmLocalMgt->pUlQueue[0][UCP4008_TRAFFIC_NR_eMBB_DATA];
//UCP_PRINT_DEBUG("rx_callback_data chCommon info alloc[%d],in[%d],out[%d]",chCommon->alloc,chCommon->in,chCommon->out);
return payloadSize;
}
uint32_t rx1_callback_data(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
uint32_t rx_callback_ctrl(const char* buf,uint32_t payloadSize)
{
#if 0
EcsSmLocalMgt_t* pEcsSmLocalMgt = get_ecs_sm_local_mgt();
MsgQueueCommonInfo_t* chCommon = pEcsSmLocalMgt->pUlQueue[0][UCP4008_TRAFFIC_NR_eMBB_CTRL];
UCP_PRINT_DEBUG("rx_callback_ctrl chCommon info alloc[%d],in[%d],out[%d]",chCommon->alloc,chCommon->in,chCommon->out);
#endif
return payloadSize;
}
#include "drv_init.h"
uint32_t slot_ind_flag = 0;
uint32_t slot_ind_time_flag = 0;
uint32_t g_slot_time = 0;
uint32_t gu32_value = 0;
uint32_t gu32_tick_receive_ctrl = 0;
uint32_t gu32_tick_from_tx_ctrl = 0;
uint32_t rx_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t tick_from_tx_ctrl = *(uint32_t *)(buf+4);
slot_ind_flag = 1;
gu32_value = value;
gu32_tick_receive_ctrl = stc_cnt;
gu32_tick_from_tx_ctrl = tick_from_tx_ctrl;
uint32_t diff = stc_cnt - tick_from_tx_ctrl;
if(0 == slot_ind_time_flag)
{
slot_ind_time_flag = 1;
diff = 1000000;
}
else
{
diff = stc_cnt - g_slot_time;
}
g_slot_time = stc_cnt;
if ((diff > 1020000) || (diff < 980000))
{
UCP_PRINT_ERROR("qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t rx1_callback_data(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
uint32_t rx_callback_ctrl(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id, uint16_t transfer_type, transfer_type_info_s* transfer_type_info_ptr)
{
queue_info_s c_plane,u_plane;
@ -105,15 +92,15 @@ static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id,
u_plane.rx_block_size = 0x28000;
u_plane.rx_block_num = 8;
//u_plane.rx_callback = rx_callback_data;
if (0 == inst_id)
{
//u_plane.rx_callback = rx_callback_data;
if (0 == inst_id)
{
u_plane.rx_callback = rx_callback_data;
}
else
{
u_plane.rx_callback = rx1_callback_data;
}
}
else
{
u_plane.rx_callback = rx1_callback_data;
}
u_plane.tx_block_size = 0x28000;
u_plane.tx_block_num = 8;
u_plane.tx_callback = NULL;
@ -138,7 +125,7 @@ static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id,
return;
}
static inline void msg_transfer_cfg(void)
{
uint8_t port_id = 0;
@ -164,206 +151,159 @@ static inline void msg_transfer_cfg(void)
UCP_PRINT_ERROR("phy_cfg_init transfer_type:OAM, handle_id[0x%08x] error.",handle_id);
}
}
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
pPetSmLocalMgt->pSyncInfo->queueCfgFlag = ++pMsgQueueLocalMgt->localSyncInfo.queueCfgFlag;
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
pPetSmLocalMgt->pSyncInfo->queueCfgFlag = ++pMsgQueueLocalMgt->localSyncInfo.queueCfgFlag;
return;
}
static inline void msg_transfer_queue_polling(void)
{
uint8_t port_id = 0;
HandleId_t handler;
uint16_t cu_flag;
uint32_t offset = 0;
uint32_t len = 0;
uint8_t* msg_ptr;
for (uint32_t 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);
}
return;
}
static inline void msg_transfer_queue_polling(void)
{
uint8_t port_id = 0;
HandleId_t handler;
uint16_t cu_flag;
uint32_t offset = 0;
uint32_t len = 0;
uint8_t* msg_ptr;
for (uint32_t 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);
}
return;
}
#define CELL_SETUP_TYPE_SIMULATION (0x5a6b7c8d)
void cell_setup_simulation()
{
uint32_t size = 16;
char* buf;
uint32_t availableSize,offset;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
uint32_t size = 16;
char* buf;
uint32_t availableSize,offset;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
//usleep(10000);
sleep(1);
int32_t ret = msg_transfer_send_start(handler.value,cu_flag);
/************C_PLANE***************/
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
int32_t ret = msg_transfer_send_start(handler.value,cu_flag);
/************C_PLANE***************/
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("cell_setup_simulation call msg_transfer_alloc_msg err.");
return ;
//continue;
}
//continue;
}
*(uint32_t*)(buf + 0) = CELL_SETUP_TYPE_SIMULATION;
*(uint32_t*)(buf + 4) = read_stc_local_timer();
*(uint32_t*)(buf + 0) = CELL_SETUP_TYPE_SIMULATION;
*(uint32_t*)(buf + 4) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
ret = msg_transfer_send_end(handler.value,cu_flag);
return;
}
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 0.");
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 0.");
osp_read_spe_cfg_file("/ramfs/cfgDat");
msg_transfer_mem_init();
msg_transfer_cfg();
ucp_handshake();
UCP_PRINT_DEBUG("start transfering message.");
uint32_t size = 100;
char* buf;
uint32_t availableSize,offset;
uint8_t* ptr;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret;
msg_transfer_mem_init();
msg_transfer_cfg();
ucp_handshake();
cell_setup_simulation();
UCP_PRINT_DEBUG("start transfering message.");
uint32_t size = 100;
char* buf;
uint32_t availableSize,offset;
uint8_t* ptr;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret;
cell_setup_simulation();
while(1) {
msg_transfer_queue_polling();
if(1 == slot_ind_flag)
{
slot_ind_flag = 0;
handler.inst_id = 0;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
}
return 0;
}
while(1) {
msg_transfer_queue_polling();
if(1 == slot_ind_flag)
{
slot_ind_flag = 0;
handler.inst_id = 0;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
handler.inst_id = 1;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
}
return 0;
}

0
test/case20/4ape_case(30K).txt Normal file
View File

312
test/case20/src/testcase20.c Normal file
View File

@ -0,0 +1,312 @@
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
//
//
// -FHDR------------------------------------------------------------
#include <stddef.h>
#include <string.h>
#include <sys/time.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
#include "msg_transfer_mem.h"
#include "pet_sm_mgt.h"
#include "ucp_handshake.h"
#include "ospShell.h"
#include "ospLog.h"
#include "ospCfgToBin.h"
#include "drv_init.h"
uint32_t slot_ind_flag = 0;
uint32_t slot_ind_time_flag = 0;
uint32_t g_slot_time = 0;
uint32_t gu32_value = 0;
uint32_t gu32_tick_receive_ctrl = 0;
uint32_t gu32_tick_from_tx_ctrl = 0;
uint32_t rx_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t tick_from_tx_ctrl = *(uint32_t *)(buf+4);
slot_ind_flag = 1;
gu32_value = value;
gu32_tick_receive_ctrl = stc_cnt;
gu32_tick_from_tx_ctrl = tick_from_tx_ctrl;
uint32_t diff = stc_cnt - tick_from_tx_ctrl;
if(0 == slot_ind_time_flag)
{
slot_ind_time_flag = 1;
diff = 500000;
}
else
{
diff = stc_cnt - g_slot_time;
}
g_slot_time = stc_cnt;
if ((diff > 520000) || (diff < 480000))
{
UCP_PRINT_ERROR("qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t rx1_callback_data(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
uint32_t rx_callback_ctrl(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id, uint16_t transfer_type, transfer_type_info_s* transfer_type_info_ptr)
{
queue_info_s c_plane,u_plane;
switch (transfer_type) {
case CU_SPLIT:
c_plane.rx_block_size = 0x25800;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_ctrl;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
u_plane.rx_block_size = 0x28000;
u_plane.rx_block_num = 8;
//u_plane.rx_callback = rx_callback_data;
if (0 == inst_id)
{
u_plane.rx_callback = rx_callback_data;
}
else
{
u_plane.rx_callback = rx1_callback_data;
}
u_plane.tx_block_size = 0x28000;
u_plane.tx_block_num = 8;
u_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
transfer_type_info_ptr->queue_uplane_info = u_plane;
break;
case OAM:
c_plane.rx_block_size = 0x100000;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_oam;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
break;
default:
UCP_PRINT_ERROR("get_msg_queue_cfg doesn't support transfer_type[%d] .",transfer_type);
break;
}
return;
}
static inline void msg_transfer_cfg(void)
{
uint8_t port_id = 0;
uint16_t inst_id = 0;
uint16_t transfer_type = 0;
int32_t handle_id = 0;
transfer_type_info_s transfer_type_info;
for (inst_id=0; inst_id<MAX_INSTANCE_NUM; inst_id++) {
/*********************************transfer_type = CU_SPLIT**********************************/
transfer_type = CU_SPLIT;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:CU_SPLIT, handle_id[0x%08x] error.",handle_id);
}
/*********************************transfer_type = OAM**********************************/
transfer_type = OAM;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:OAM, handle_id[0x%08x] error.",handle_id);
}
}
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
pPetSmLocalMgt->pSyncInfo->queueCfgFlag = ++pMsgQueueLocalMgt->localSyncInfo.queueCfgFlag;
return;
}
static inline void msg_transfer_queue_polling(void)
{
uint8_t port_id = 0;
HandleId_t handler;
uint16_t cu_flag;
uint32_t offset = 0;
uint32_t len = 0;
uint8_t* msg_ptr;
for (uint32_t 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);
}
return;
}
#define CELL_SETUP_TYPE_SIMULATION (0x5a6b7c8d)
void cell_setup_simulation()
{
uint32_t size = 16;
char* buf;
uint32_t availableSize,offset;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
//usleep(10000);
sleep(1);
int32_t ret = msg_transfer_send_start(handler.value,cu_flag);
/************C_PLANE***************/
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("cell_setup_simulation call msg_transfer_alloc_msg err.");
return ;
//continue;
}
*(uint32_t*)(buf + 0) = CELL_SETUP_TYPE_SIMULATION;
*(uint32_t*)(buf + 4) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
ret = msg_transfer_send_end(handler.value,cu_flag);
return;
}
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 20 (4 ape 30K case).");
osp_read_spe_cfg_file("/ramfs/cfgDat");
msg_transfer_mem_init();
msg_transfer_cfg();
ucp_handshake();
UCP_PRINT_DEBUG("start transfering message.");
uint32_t size = 100;
char* buf;
uint32_t availableSize,offset;
uint8_t* ptr;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret;
cell_setup_simulation();
while(1)
{
msg_transfer_queue_polling();
if(1 == slot_ind_flag)
{
slot_ind_flag = 0;
handler.inst_id = 0;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
}
return 0;
}

0
test/case21/8ape_case(30K).txt Normal file
View File

401
test/case21/src/testcase21.c Normal file
View File

@ -0,0 +1,401 @@
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test5.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
// 8 ape case
//
// -FHDR------------------------------------------------------------
#include <stdint.h>
#include <stddef.h>
#include <string.h>
#include <sys/time.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
#include "msg_transfer_mem.h"
#include "pet_sm_mgt.h"
#include "ucp_handshake.h"
#include "ospShell.h"
#include "ospLog.h"
#include "ospCfgToBin.h"
#include "drv_init.h"
uint32_t slot_ind_flag = 0;
uint32_t slot_ind_time_flag = 0;
uint32_t g_slot_time = 0;
uint32_t gu32_value = 0;
uint32_t gu32_tick_receive_ctrl = 0;
uint32_t gu32_tick_from_tx_ctrl = 0;
uint32_t gu32_rx_callback_data_cnt = 0;
uint32_t rx_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t tick_from_tx_ctrl = *(uint32_t *)(buf+4);
++gu32_rx_callback_data_cnt;
slot_ind_flag = 1;
gu32_value = value;
gu32_tick_receive_ctrl = stc_cnt;
gu32_tick_from_tx_ctrl = tick_from_tx_ctrl;
uint32_t diff = stc_cnt - tick_from_tx_ctrl;
if(0 == slot_ind_time_flag)
{
slot_ind_time_flag = 1;
diff = 500000;
}
else
{
diff = stc_cnt - g_slot_time;
}
g_slot_time = stc_cnt;
if ((diff > 520000) || (diff < 480000))
{
UCP_PRINT_ERROR("[0],qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t gu32_rx1_slot_ind_flag = 0;
uint32_t gu32_rx1_slot_ind_time_flag = 0;
uint32_t gu32_rx1_slot_time = 0;
uint32_t rx1_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t diff = 0;
gu32_rx1_slot_ind_flag = 1;
if(0 == gu32_rx1_slot_ind_time_flag)
{
gu32_rx1_slot_ind_time_flag = 1;
diff = 500000;
}
else
{
diff = stc_cnt - gu32_rx1_slot_time;
}
gu32_rx1_slot_time = stc_cnt;
if ((diff > 520000) || (diff < 480000))
{
UCP_PRINT_ERROR("[1],qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t rx_callback_ctrl(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id, uint16_t transfer_type, transfer_type_info_s* transfer_type_info_ptr)
{
queue_info_s c_plane,u_plane;
switch (transfer_type) {
case CU_SPLIT:
c_plane.rx_block_size = 0x25800;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_ctrl;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
u_plane.rx_block_size = 0x28000;
u_plane.rx_block_num = 8;
//u_plane.rx_callback = rx_callback_data;
if (0 == inst_id)
{
u_plane.rx_callback = rx_callback_data;
}
else
{
u_plane.rx_callback = rx1_callback_data;
}
u_plane.tx_block_size = 0x28000;
u_plane.tx_block_num = 8;
u_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
transfer_type_info_ptr->queue_uplane_info = u_plane;
break;
case OAM:
c_plane.rx_block_size = 0x100000;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_oam;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
break;
default:
UCP_PRINT_ERROR("get_msg_queue_cfg doesn't support transfer_type[%d] .",transfer_type);
break;
}
return;
}
static inline void msg_transfer_cfg(void)
{
uint8_t port_id = 0;
uint16_t inst_id = 0;
uint16_t transfer_type = 0;
int32_t handle_id = 0;
transfer_type_info_s transfer_type_info;
for (inst_id=0; inst_id<MAX_INSTANCE_NUM; inst_id++) {
/*********************************transfer_type = CU_SPLIT**********************************/
transfer_type = CU_SPLIT;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:CU_SPLIT, handle_id[0x%08x] error.",handle_id);
}
/*********************************transfer_type = OAM**********************************/
transfer_type = OAM;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:OAM, handle_id[0x%08x] error.",handle_id);
}
}
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
pPetSmLocalMgt->pSyncInfo->queueCfgFlag = ++pMsgQueueLocalMgt->localSyncInfo.queueCfgFlag;
return;
}
static inline void msg_transfer_queue_polling(void)
{
uint8_t port_id = 0;
HandleId_t handler;
uint16_t cu_flag;
uint32_t offset = 0;
uint32_t len = 0;
uint8_t* msg_ptr;
for (uint32_t 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);
}
return;
}
#define CELL_SETUP_TYPE_SIMULATION (0x5a6b7c8d)
void cell_setup_simulation()
{
uint32_t size = 16;
char* buf;
uint32_t availableSize,offset;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret = msg_transfer_send_start(handler.value,cu_flag);
/************C_PLANE***************/
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("cell_setup_simulation call msg_transfer_alloc_msg err.");
return ;
//continue;
}
*(uint32_t*)(buf + 0) = CELL_SETUP_TYPE_SIMULATION;
*(uint32_t*)(buf + 4) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
ret = msg_transfer_send_end(handler.value,cu_flag);
return;
}
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 21 (8 ape 30K case).");
osp_read_spe_cfg_file("/ramfs/cfgDat");
msg_transfer_mem_init();
msg_transfer_cfg();
ucp_handshake();
UCP_PRINT_DEBUG("start transfering message.");
uint32_t size = 100;
char* buf;
uint32_t availableSize,offset;
uint8_t* ptr;
uint8_t u8_cell_flag = 0;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret;
sleep(1);
cell_setup_simulation(); /* the first cell */
UCP_PRINT_DEBUG("call cell setup(1)");
while(1)
{
if ((20000 == gu32_rx_callback_data_cnt) && (0 == u8_cell_flag))
{
/* 1st cell build ok after 10s */
cell_setup_simulation(); /* the second cell */
u8_cell_flag = 1;
UCP_PRINT_DEBUG("call cell setup(2)");
}
msg_transfer_queue_polling();
if(1 == slot_ind_flag)
{
slot_ind_flag = 0;
handler.inst_id = 0;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
if (1 == gu32_rx1_slot_ind_flag)
{
gu32_rx1_slot_ind_flag = 0;
handler.inst_id = 1;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
}
return 0;
}

0
test/case22/8ape_case(15K).txt Normal file
View File

402
test/case22/src/testcase22.c Normal file
View File

@ -0,0 +1,402 @@
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
//
//
// -FHDR------------------------------------------------------------
#include <stddef.h>
#include <string.h>
#include <sys/time.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
#include "msg_transfer_mem.h"
#include "pet_sm_mgt.h"
#include "ucp_handshake.h"
#include "ospShell.h"
#include "ospLog.h"
#include "ospCfgToBin.h"
#include "drv_init.h"
uint32_t slot_ind_flag = 0;
uint32_t slot_ind_time_flag = 0;
uint32_t g_slot_time = 0;
uint32_t gu32_value = 0;
uint32_t gu32_tick_receive_ctrl = 0;
uint32_t gu32_tick_from_tx_ctrl = 0;
uint32_t gu32_rx_callback_data_cnt = 0;
uint32_t rx_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t tick_from_tx_ctrl = *(uint32_t *)(buf+4);
++gu32_rx_callback_data_cnt;
slot_ind_flag = 1;
gu32_value = value;
gu32_tick_receive_ctrl = stc_cnt;
gu32_tick_from_tx_ctrl = tick_from_tx_ctrl;
uint32_t diff = stc_cnt - tick_from_tx_ctrl;
if(0 == slot_ind_time_flag)
{
slot_ind_time_flag = 1;
diff = 1000000;
}
else
{
diff = stc_cnt - g_slot_time;
}
g_slot_time = stc_cnt;
if ((diff > 1020000) || (diff < 980000))
{
UCP_PRINT_ERROR("[0],qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t gu32_rx1_slot_ind_flag = 0;
uint32_t gu32_rx1_slot_ind_time_flag = 0;
uint32_t gu32_rx1_slot_time = 0;
uint32_t rx1_callback_data(const char* buf,uint32_t payloadSize)
{
uint32_t stc_cnt = read_stc_local_timer();
uint32_t value = *(uint32_t *)buf;
uint16_t sfn = value >> 16;
uint16_t slot = value & 0xffff;
uint32_t diff = 0;
gu32_rx1_slot_ind_flag = 1;
if(0 == gu32_rx1_slot_ind_time_flag)
{
gu32_rx1_slot_ind_time_flag = 1;
diff = 1000000;
}
else
{
diff = stc_cnt - gu32_rx1_slot_time;
}
gu32_rx1_slot_time = stc_cnt;
if ((diff > 1020000) || (diff < 980000))
{
UCP_PRINT_ERROR("[1],qNO[%d],sfn[%d],slot[%d],diff[%d]",UCP4008_TRAFFIC_NR_eMBB_DATA,sfn,slot,diff);
}
return payloadSize;
}
uint32_t rx_callback_ctrl(const char* buf,uint32_t payloadSize)
{
return payloadSize;
}
static inline void get_msg_transfer_info(uint16_t port_index, uint16_t inst_id, uint16_t transfer_type, transfer_type_info_s* transfer_type_info_ptr)
{
queue_info_s c_plane,u_plane;
switch (transfer_type) {
case CU_SPLIT:
c_plane.rx_block_size = 0x25800;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_ctrl;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
u_plane.rx_block_size = 0x28000;
u_plane.rx_block_num = 8;
//u_plane.rx_callback = rx_callback_data;
if (0 == inst_id)
{
u_plane.rx_callback = rx_callback_data;
}
else
{
u_plane.rx_callback = rx1_callback_data;
}
u_plane.tx_block_size = 0x28000;
u_plane.tx_block_num = 8;
u_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
transfer_type_info_ptr->queue_uplane_info = u_plane;
break;
case OAM:
c_plane.rx_block_size = 0x100000;
c_plane.rx_block_num = 32;
c_plane.rx_callback = rx_callback_oam;
c_plane.tx_block_size = 0x8000;
c_plane.tx_block_num = 8;
c_plane.tx_callback = NULL;
transfer_type_info_ptr->queue_cplane_info = c_plane;
break;
default:
UCP_PRINT_ERROR("get_msg_queue_cfg doesn't support transfer_type[%d] .",transfer_type);
break;
}
return;
}
static inline void msg_transfer_cfg(void)
{
uint8_t port_id = 0;
uint16_t inst_id = 0;
uint16_t transfer_type = 0;
int32_t handle_id = 0;
transfer_type_info_s transfer_type_info;
for (inst_id=0; inst_id<MAX_INSTANCE_NUM; inst_id++) {
/*********************************transfer_type = CU_SPLIT**********************************/
transfer_type = CU_SPLIT;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:CU_SPLIT, handle_id[0x%08x] error.",handle_id);
}
/*********************************transfer_type = OAM**********************************/
transfer_type = OAM;
get_msg_transfer_info(port_id,inst_id,transfer_type, &transfer_type_info);
handle_id = msg_transfer_init(port_id, transfer_type, inst_id, &transfer_type_info);
if (handle_id < 0) {
UCP_PRINT_ERROR("phy_cfg_init transfer_type:OAM, handle_id[0x%08x] error.",handle_id);
}
}
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
pPetSmLocalMgt->pSyncInfo->queueCfgFlag = ++pMsgQueueLocalMgt->localSyncInfo.queueCfgFlag;
return;
}
static inline void msg_transfer_queue_polling(void)
{
uint8_t port_id = 0;
HandleId_t handler;
uint16_t cu_flag;
uint32_t offset = 0;
uint32_t len = 0;
uint8_t* msg_ptr;
for (uint32_t 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);
}
return;
}
#define CELL_SETUP_TYPE_SIMULATION (0x5a6b7c8d)
void cell_setup_simulation()
{
uint32_t size = 16;
char* buf;
uint32_t availableSize,offset;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret = msg_transfer_send_start(handler.value,cu_flag);
/************C_PLANE***************/
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("cell_setup_simulation call msg_transfer_alloc_msg err.");
return ;
//continue;
}
*(uint32_t*)(buf + 0) = CELL_SETUP_TYPE_SIMULATION;
*(uint32_t*)(buf + 4) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
ret = msg_transfer_send_end(handler.value,cu_flag);
return;
}
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 22 (8 ape 15K case).");
osp_read_spe_cfg_file("/ramfs/cfgDat");
msg_transfer_mem_init();
msg_transfer_cfg();
ucp_handshake();
UCP_PRINT_DEBUG("start transfering message.");
uint32_t size = 100;
char* buf;
uint32_t availableSize,offset;
uint8_t* ptr;
uint8_t u8_cell_flag = 0;
uint16_t cu_flag = C_PLANE;
HandleId_t handler;
handler.port_id = 0;
handler.inst_id = 0;
handler.type_id = CU_SPLIT;
int32_t ret;
sleep(1);
cell_setup_simulation(); /* the first cell */
UCP_PRINT_DEBUG("call cell setup(1)");
while(1)
{
#if 1
if ((10000 == gu32_rx_callback_data_cnt) && (0 == u8_cell_flag))
{
/* 1st cell build ok after 10s */
cell_setup_simulation(); /* the second cell */
u8_cell_flag = 1;
UCP_PRINT_DEBUG("call cell setup(2)");
}
#endif
msg_transfer_queue_polling();
if(1 == slot_ind_flag)
{
slot_ind_flag = 0;
handler.inst_id = 0;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("0,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
if (1 == gu32_rx1_slot_ind_flag)
{
gu32_rx1_slot_ind_flag = 0;
handler.inst_id = 1;
/************C_PLANE***************/
cu_flag = C_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,c_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
/************U_PLANE***************/
cu_flag = U_PLANE;
ret = msg_transfer_send_start(handler.value,cu_flag);
ret = msg_transfer_alloc_msg(handler.value, cu_flag, size, &buf, &availableSize, &offset);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane alloc error\r\n");
continue;
}
ptr = (uint8_t *)buf;
*(uint32_t*)(ptr + 0) = gu32_value;
*(uint32_t*)(ptr + 4) = gu32_tick_from_tx_ctrl;
*(uint32_t*)(ptr + 8) = gu32_tick_receive_ctrl;
*(uint32_t*)(ptr + 12) = read_stc_local_timer();
ret = msg_transfer_send_msg(handler.value, cu_flag, (uint8_t *)buf, offset, size);
if ( SUCCESS != ret) {
UCP_PRINT_ERROR("1,u_plane send error\r\n");
}
ret = msg_transfer_send_end(handler.value,cu_flag);
}
}
return 0;
}

0
test/case50/PCIE_EP_arm_read_cfg.txt Normal file
View File

32
test/case50/src/testcase50.c Normal file
View File

@ -0,0 +1,32 @@
// +FHDR------------------------------------------------------------
// Copyright (c) 2022 SmartLogic.
// ALL RIGHTS RESERVED
// -----------------------------------------------------------------
// Filename : test.c
// Author : xianfeng.du
// Created On : 2022-11-25
// Last Modified :
// -----------------------------------------------------------------
// Description:
//
//
// -FHDR------------------------------------------------------------
#include <stddef.h>
#include <string.h>
#include <unistd.h>
#include "typedef.h"
#include "ucp_printf.h"
extern uint8_t gu8_main_flag;
int32_t test_case(uint32_t argc, int32_t* argvp)
{
UCP_PRINT_DEBUG("start running testcase 50.");
gu8_main_flag = 0;
return 0;
}