/*
|
* messageproc.c
|
*
|
* Created on: 2021Äê11ÔÂ1ÈÕ
|
* Author: graydon
|
*/
|
#include <string.h>
|
#include <stdlib.h>
|
#include <sru.h>
|
#include <def1802.h>
|
#include <cdef1802.h>
|
#include <heapnew>
|
#include "messageproc.h"
|
#include "../drv/spi.h"
|
#include "../drv/memory.h"
|
#include "queue.h"
|
#include "tob.h"
|
#include "F2F.h"
|
//#include "../drv/sru_dai.h"
|
#include "../drv/fir_acc.h"
|
#include <time.h>
|
//#include "convert.h"
|
#include "protocol.h"
|
#include "scene.h"
|
#include "ParamCtrl.h"
|
|
|
s32 Message::Send(MsgType msg_type, uvoidptr buffer, u32 len)
|
{
|
MSG msg;
|
|
msg.Enc(msg_type, buffer, len);
|
return txQueue->Push(msg);
|
}
|
|
s32 Message::Send(MSG* pmsg )
|
{
|
return txQueue->Push(*pmsg);
|
}
|
|
|
s32 Message::LevelProcess(MSG* pmsg)
|
{
|
ToB* tob = ToB::GetInstance();
|
if(tob ) {
|
s16 buffer[1600];
|
u32 n = tob->GetLevels(buffer);
|
u32 data_len ;
|
u32 total_pkts = (n + SPI_DATA_LEN-1)/SPI_DATA_LEN;
|
|
//for(u32 i =0 ;i < n;i++) buffer[i] = i;
|
pmsg->totalPkts = total_pkts;
|
pmsg->msgIDLSB = n;
|
pmsg->msgIDMSB = 0;
|
|
for(u32 i=0; i< total_pkts; i++){
|
if(i == total_pkts-1){
|
data_len = n - i*SPI_DATA_LEN;
|
}
|
else{
|
data_len = SPI_DATA_LEN;
|
}
|
|
pmsg->pktNo = i;
|
pmsg->Enc(MsgType::MSG_LEVEL_GET_REQ, buffer+i*SPI_DATA_LEN, data_len<<1);
|
Send(pmsg) ;
|
}
|
}
|
return 0;
|
}
|
|
s32 Message::PresetProcess(MSG* pmsg)
|
{
|
// static u8* bin = NULL;
|
// extern ubool TopoLoading;
|
//
|
// if(pmsg->pktNo == 0 && bin != NULL ) {
|
// DDRFree(bin);
|
// bin = NULL;
|
// printf("PresetProcess pmsg->pktNo\n");
|
// }
|
// if(pmsg->pktNo == 0 && bin == NULL) {
|
// bin = (u8*)DDRMalloc(pmsg->totalPkts*MSG_DATA_LEN);
|
// dbg_printf("preset address %p.\n", bin);
|
// }
|
// if(bin == NULL) {
|
// printf("PresetProcess\n");
|
// return -1;
|
// }
|
// memcpy(bin+pmsg->pktNo*MSG_DATA_LEN, pmsg->data , pmsg->dataLen);
|
// if(pmsg->pktNo == pmsg->totalPkts -1) {
|
// ToB* tob = ToB::GetInstance();
|
// u32 size = (pmsg->totalPkts -1)*MSG_DATA_LEN+pmsg->dataLen;
|
//
|
// if(tob) tob->toCtrl(bin, size);
|
//
|
// DDRFree( bin);
|
// bin = NULL;
|
// TopoLoading = ufalse;
|
// Send(MsgType::MSG_PRESET_RES, 0 ,0) ;
|
// }
|
|
return 0;
|
}
|
|
s32 Message::PresetProcess(MSG* pmsg, int pad)
|
{
|
extern ubool TopoLoading;
|
s32 ret = 0;
|
|
ToB* tob = ToB::GetInstance();
|
tob->SetMute(utrue);
|
TopoLoading = utrue;
|
|
scene_cpy(pmsg->pktNo,(void*)pmsg->data,pmsg->dataLen);
|
|
if(pmsg->pktNo == pmsg->totalPkts -1) {
|
ret = TopoProcess();
|
|
TopoLoading = ufalse;
|
|
|
Send(MsgType::MSG_PRESET_RES, (u8*)&ret ,1) ;
|
}
|
|
return 0;
|
}
|
|
s32 Message::TopoProcess(MSG* pmsg)
|
{
|
// extern ubool TopoLoading;
|
// extern uvoid SetNumOfChannels(u16 rxNum, u16 txNum);
|
// static u8* bin = NULL;
|
// ToB* tob = ToB::GetInstance();
|
// u32 size =0;
|
//
|
// tob->SetMute(utrue);
|
// TopoLoading = utrue;
|
//
|
// if(pmsg->pktNo == 0 && bin != NULL ) {
|
// DDRFree(bin);
|
// bin = NULL;
|
// }
|
// if(pmsg->pktNo == 0 && bin == NULL) {
|
// bin = (u8*)DDRMalloc(pmsg->totalPkts*MSG_DATA_LEN);
|
// size =0 ;
|
// }
|
// if(bin == NULL) return -1;
|
//
|
// memcpy(bin+pmsg->pktNo*MSG_DATA_LEN, pmsg->data , pmsg->dataLen);
|
// if(pmsg->pktNo == pmsg->totalPkts -1) {
|
// size = (pmsg->totalPkts -1)*MSG_DATA_LEN+pmsg->dataLen;
|
// SetNumOfChannels(0, 0);
|
// if(tob) {
|
// fir_acc_delete();
|
// tob->toClear();
|
// tob->CreateModule(bin, size);
|
// fir_acc_startup();
|
// }
|
// DDRFree( bin);
|
// bin = NULL;
|
//
|
// Send(MsgType::MSG_TOPO_RES, 0 ,0) ;
|
// }
|
|
return 0;
|
}
|
|
s32 Message::TopoProcess()
|
{
|
extern ubool TopoLoading;
|
extern uvoid SetNumOfChannels(u16 rxNum, u16 txNum);
|
char *bin = (char*)DDRMalloc(8*1024);//new char[8*1024];//
|
int size = 0;
|
int scene_size = 0;
|
|
ToB* tob = ToB::GetInstance();
|
|
//tob->SetMute(utrue);
|
//TopoLoading = utrue;
|
|
if(bin == NULL) return -1;
|
|
scene_type_update();
|
|
SetNumOfChannels(0, 0);
|
if(tob) {
|
fir_acc_delete();
|
tob->toClear();
|
SceneToDSPFlowchart(bin, &size);
|
tob->CreateModule((u8*)bin, size,NULL);
|
fir_acc_startup();
|
}
|
|
DDRFree(bin);
|
//delete[] bin;
|
bin = NULL;
|
|
return scene_size;
|
}
|
|
s32 Message::ParamCtrl(MSG* pmsg)
|
{
|
ToB* tob = ToB::GetInstance();
|
|
if(!ConfiGurable){
|
ptag_cmd pcmd = (ptag_cmd)pmsg->data;
|
if(tob != NULL){
|
tob->toCtrl(pcmd->proc_id, pcmd->cmd, pcmd->val);
|
dbg_printf("proc_id %d .\n", pcmd->proc_id);
|
}
|
|
return 0;
|
}
|
|
|
// if(pmsg->totalPkts > 1) {
|
// static s16* bin = NULL;
|
//
|
// if(pmsg->pktNo == 0 && bin != NULL) {
|
// delete[] bin; bin = NULL;
|
// }
|
// if(bin == NULL) {
|
// bin = new s16[pmsg->totalPkts*MSG_DATA_LEN];
|
// }
|
// memcpy(bin+ pmsg->pktNo*MSG_DATA_LEN, pmsg->data , pmsg->dataLen);
|
// dbg_printf("ParamCtrl %d(%d).\n", pmsg->totalPkts,pmsg->pktNo);
|
// if(pmsg->pktNo == pmsg->totalPkts-1) {
|
// Param * ptr = (Param *)bin;
|
// s16 * data = (s16*)(bin+sizeof(Param));
|
//
|
// if(tob != NULL){
|
// tob->toCtrl(ptr->mID, ptr->pID, data, ptr->num);
|
// dbg_printf("PID %d num %d.\n", ptr->pID,ptr->num);
|
// }
|
// delete[] bin; bin = NULL;
|
// }
|
// }
|
// else {
|
// Param * ptr = (Param *)pmsg->data;
|
// s16 * data = (s16*)(pmsg->data+sizeof(Param));
|
//
|
// if(tob != NULL){
|
// tob->toCtrl(ptr->mID, ptr->pID, data, ptr->num);
|
// dbg_printf("PID %d num %u.\n", ptr->pID, ptr->num);
|
// }
|
// }
|
|
return 0;
|
}
|
|
#if 0
|
s32 Message::SystemConfigSetProcess(MSG* pmsg)
|
{
|
extern ubool HandShakeSuccesful;
|
extern u16 mDspIndex;
|
DSPConfig* conf = (DSPConfig*)pmsg->data;
|
|
if(HandShakeSuccesful == ufalse) {
|
SAMPLE_NUM = conf->mSampleNum;
|
SAMPLE_RATE = (conf->mSampleRateH<<16)|conf->mSampleRateL;
|
|
mDspIndex = conf->mDspIndex;
|
new ToB(conf->mDualDsp , conf->mDspIndex);
|
|
RouteConfig(conf->routes,conf->mRouteNum);
|
SportsConfig(conf->sports);
|
SRCsConfig(conf->srcs);
|
PCGsConfig(conf->pcgs);
|
|
SetCh(conf->mLocalRxNum, conf->mLocalTxNum, conf->mDanteRxNum, conf->mDanteTxNum);
|
HandShakeSuccesful = utrue;
|
}
|
|
Send(MsgType::MSG_HANDSHAKE_RES, 0 , 0);
|
|
return 0;
|
}
|
#else
|
s32 Message::SystemConfigSetProcess(MSG* pmsg)
|
{
|
extern ubool HandShakeSuccesful;
|
extern u16 mDspIndex;
|
|
extern int input_num_channels;
|
extern int output_num_channels;
|
|
extern int local_input_channels_num;
|
extern int local_output_channels_num;
|
extern int dante_input_channels_num;
|
extern int dante_output_channels_num;
|
|
if(HandShakeSuccesful == ufalse) {
|
ptag_hwconf p = (ptag_hwconf)pmsg->data;
|
|
local_input_channels_num = p->local_rx_num;
|
local_output_channels_num = p->local_tx_num;
|
dante_input_channels_num = p->dante_rx_num;
|
dante_output_channels_num = p->dante_tx_num;
|
|
input_num_channels = p->local_rx_num + p->dante_rx_num;
|
output_num_channels = p->local_tx_num + p->dante_tx_num;
|
|
p->scene_size = sizeof(tag_parameters);
|
|
mDspIndex = p->dsp_index;
|
new ToB(p->dual_dsp, p->dsp_index);
|
|
Audio_Config();
|
|
HandShakeSuccesful = utrue;
|
}
|
|
Send(MsgType::MSG_HANDSHAKE_RES, 0 , 0);
|
|
return 0;
|
}
|
#endif
|
|
s32 Message::PushDSPStatus(u16 ID, s16 value)
|
{
|
if(mDevStatusNum < 32) {
|
mDevStatus[mDevStatusNum].ID = ID;
|
mDevStatus[mDevStatusNum].value[0] = value;
|
mDevStatusNum++ ;
|
}
|
|
return 0;
|
}
|
s32 Message::DSPStatusProcess(MSG* pmsg)
|
{
|
s16* data = (s16*)pmsg->data;
|
u32 n = mDevStatusNum*sizeof(DeviceStatus);
|
|
if( n > 0) {
|
memcpy(data , mDevStatus , n);
|
pmsg->Enc(MsgType::MSG_DSP_STATUS_RES, 0 , n*2);
|
mDevStatusNum = 0;
|
Send(pmsg);
|
}
|
return n;
|
}
|
|
s32 Message::RxMessageHandler(MSG* pmsg)
|
{
|
if(pmsg->magic != 0x5aa5) {
|
return -1;
|
}
|
|
pmsg->dataLen = (pmsg->dataLen>>1);
|
switch(pmsg->msgType&0xff){
|
case MsgType::MSG_LEVEL_GET_REQ:
|
LevelProcess(pmsg);
|
break;
|
case MsgType::MSG_PRESET_REQ:
|
dbg_printf("preset %d(%d).\n", pmsg->totalPkts ,pmsg->pktNo);
|
//if(ConfiGurable) PresetProcess(pmsg);
|
break;
|
case MsgType::MSG_TOPO_REQ:
|
dbg_printf("topo %d(%d).\n", pmsg->totalPkts ,pmsg->pktNo);
|
if(ConfiGurable) TopoProcess(pmsg);
|
else PresetProcess(pmsg,0);
|
break;
|
case MsgType::MSG_PARMA_CTRL_REQ:
|
ParamCtrl(pmsg);
|
break;
|
case MsgType::MSG_HANDSHAKE_REQ:
|
SystemConfigSetProcess(pmsg);
|
break;
|
case MsgType::MSG_CHANNEL_COPY_REQ:
|
scene_channel_copy((ptag_channel_copy)pmsg->data);
|
break;
|
case MsgType::MSG_DSP_STATUS_REQ:
|
DSPStatusProcess(pmsg);
|
break;
|
default:
|
break;
|
}
|
|
return 0;
|
}
|
|
uvoid Message::Proc()
|
{
|
spi_status_e spi_status = spi_get_status();
|
|
if(spi_status == spi_completed){
|
//ÅжÏÊǽÓÊÕ»¹ÊÇ·¢ËÍÍê³É
|
spi_direction_e spi_dir = spi_get_direction();
|
MSG* spi_buffer = (MSG*)spi_get_buffer();
|
|
if(spi_dir == spi_rx){
|
//memcpy(&msg, spi_buffer, 512);
|
RxMessageHandler(spi_buffer);
|
}
|
|
//¸ù¾Ý·¢ËͶÓÁÐÅжÏÏÂÒ»°üÅäÖ÷¢ËÍ»¹ÊǽÓÊÕ
|
if(txQueue->Count() > 0){
|
txQueue->Pop(*spi_buffer);
|
spi_config_dma(spi_tx);
|
SRU(LOW,DPI_PB12_I);
|
}
|
else{
|
spi_config_dma(spi_rx);
|
SRU(HIGH,DPI_PB12_I);
|
}
|
SRU(HIGH,DPI_PB11_I);//֪ͨMCU SPI¿ÉÓÃ
|
}
|
}
|
