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

fixed the msg_transfer issue

Browse Source
This commit is contained in:
xianfeng.du 2023-08-01 19:08:29 +08:00
parent 50e11a1be7
commit a9d77a5d60
4 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
app/src/msg_transfer_layer.c
View File

@ -130,9 +130,9 @@ int32_t msg_transfer_send_start(int32_t handle_id, uint16_t cu_flag)
UCP_PRINT_ERROR("msg_transfer_send_start,UNINITIALIZED_QUEUE"); UCP_PRINT_ERROR("msg_transfer_send_start,UNINITIALIZED_QUEUE");
return UNINITIALIZED_QUEUE; return UNINITIALIZED_QUEUE;
} }
msg_queue_dl_block_init(inst_id,que_id);
int32_t ret = msg_queue_dl_block_init(inst_id,que_id);
return SUCCESS; return ret;
} }
@ -156,11 +156,17 @@ int32_t msg_transfer_alloc_msg(int32_t handle_id, uint16_t cu_flag, uint32_t buf
MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt(); MsgQueueLocalMgt_t* pMsgQueueLocalMgt = get_msg_queue_local_mgt();
MsgQueueLocalInfo_t* ch = (MsgQueueLocalInfo_t*)&pMsgQueueLocalMgt->localDlQueue[inst_id][que_id]; MsgQueueLocalInfo_t* ch = (MsgQueueLocalInfo_t*)&pMsgQueueLocalMgt->localDlQueue[inst_id][que_id];
if (bufSize > ch->availableSize) {
UCP_PRINT_ERROR("msg_transfer_alloc_msg,OUT_OF_BLOCK_MEMORY");
return OUT_OF_BLOCK_MEMORY;
}
if (0 == ch->msgCnt) if (0 == ch->msgCnt)
{ {
msg_queue_dl_alloc_buf(inst_id,que_id); msg_queue_dl_alloc_buf(inst_id,que_id);
} }
*(uint64_t *)buf = ch->bufAddr + ch->offset; *(uint64_t *)buf = ch->bufAddr + ch->offset;
*availableSize = ch->availableSize; *availableSize = ch->availableSize;
*offset = ch->offset; *offset = ch->offset;
@ -198,10 +204,10 @@ int32_t msg_transfer_send_end(int32_t handle_id, uint16_t cu_flag)
{ {
HandleId_t handler; HandleId_t handler;
handler.value= (uint32_t)handle_id; handler.value= (uint32_t)handle_id;
//uint8_t port_id = handler.port_id; //uint8_t port_id = handler.port_id;
uint8_t inst_id = handler.inst_id; uint8_t inst_id = handler.inst_id;
uint8_t type_id = handler.type_id; uint8_t type_id = handler.type_id;
int8_t que_id = get_queue_id(type_id, cu_flag); int8_t que_id = get_queue_id(type_id, cu_flag);
if (que_id < 0) if (que_id < 0)
{ {

5
app/src/msg_transfer_queue.c
View File

@ -73,6 +73,11 @@ int32_t msg_queue_dl_block_init(uint8_t inst_id, uint8_t que_id)
PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt(); PetSmLocalMgt_t* pPetSmLocalMgt = get_pet_sm_local_mgt();
MsgQueueCommonInfo_t* chCommon = pPetSmLocalMgt->pDlQueue[inst_id][que_id]; MsgQueueCommonInfo_t* chCommon = pPetSmLocalMgt->pDlQueue[inst_id][que_id];
if((MSG_MBUF_HEAD_SIZE >= chCommon->bufSize) || (0 == ch->bufBase))
{
return UNINITIALIZED_QUEUE;
}
ch->availableSize = chCommon->bufSize - MSG_MBUF_HEAD_SIZE; ch->availableSize = chCommon->bufSize - MSG_MBUF_HEAD_SIZE;
ch->offset = 0; ch->offset = 0;
ch->msgCnt = 0; ch->msgCnt = 0;

2
driver/rfic

@ -1 +1 @@
Subproject commit 99d6653cd9acb4b2797ec3c36252f0c80dcf0895 Subproject commit 8ea437815106d50f2230e0b3989f7f7174ac0fed

2
driver/tfu

@ -1 +1 @@
Subproject commit 7908793098da2a3fcc5da3f3f2831c84fe4947f7 Subproject commit 7bd0c4a6b87b70cf28b0c47eea74b731c9e90e38