TMS320F28388D: 关于CPU1和CM之间IPC消息队列通信以及IPC通信问题

// .map
20080000  IPC_CM_To_CPU1_GetBuffer                  
20082000  cmSend2CPUBuffer                          
20082400  cmDatSendBuffer                           
20082414  cmObjSendBuffer                           
20082514  IPC_CM_To_CPU1_PutBuffer                  
20084000  IPC_CM_To_CPU2_GetBuffer                  
20086000  IPC_CM_To_CPU2_PutBuffer 

// .c文件
#pragma DATA_SECTION(cmDatSendBuffer,"MSGRAM_CM_TO_CPU1")
#pragma DATA_SECTION(cmObjSendBuffer,"MSGRAM_CM_TO_CPU1")
#pragma DATA_SECTION(cmSend2CPUBuffer,"MSGRAM_CM_TO_CPU1")

uint16_t cmDatSendBuffer[10];
uint32_t cmObjSendBuffer[64];
uint16_t  cmSend2CPUBuffer[512];

// .map
0     00038000  IPC_CPU_To_CM_GetBuffer              
0     00039000  ipcTxBuffer                          
0     00039180  ipcSampleTxBuffer                    
0     00039300  cpu1DatSendBuffer                    
0     0003930a  cpu1MonitSendBuffer                  
0     00039440  IPC_CPU_To_CM_PutBuffer              
0     0003a000  IPC_CPU1_To_CPU2_PutBuffer           
0     0003b000  IPC_CPU1_To_CPU2_GetBuffer  


// .c文件
#pragma DATA_SECTION(cpu1DatSendBuffer,"MSGRAM_CPU_TO_CM")
#pragma DATA_SECTION(ipcTxBuffer,"MSGRAM_CPU_TO_CM")
#pragma DATA_SECTION(cpu1MonitSendBuffer,"MSGRAM_CPU_TO_CM")
#pragma DATA_SECTION(ipcSampleTxBuffer,"MSGRAM_CPU_TO_CM")

uint16_t  ipcTxBuffer[384] = {0};		
uint16_t  ipcSampleTxBuffer[384];	
int32_t  cpu1MonitSendBuffer[128];		

void CMTOCPU1_ipc0SendData(uint32_t dataAddr, uint32_t dataSize, uint32_t command)
{

    //
    // Send a message without message queue
    // Since C28x and CM does not share the same address space for shared RAM,
    // ADDRESS_CORRECTION is enabled
    // Length of the data to be read is passed as data.
    //
    IPC_sendCommand(IPC_CM_L_CPU1_R, IPC_FLAG0, IPC_ADDR_CORRECTION_ENABLE,
					command, (uint32_t)dataAddr, dataSize);

//    GPIO_togglePin(mGPIO_PIN_LED5);

    //
    // Wait for acknowledgment
    //
    IPC_waitForAck(IPC_CM_L_CPU1_R, IPC_FLAG0);

}

    while(1)
    {
//    	testcount++;
//    	if(testcount >= 64)
    	if(EcatRev_Flag == 1)
    	{
    		SYNC0_Update_Send();
    		EcatRev_Flag = 0;
//    		testcount = 0;
    	}
    }

void udp_rx_callback(void *arg, struct udp_pcb *upcb, struct pbuf *p,
               struct ip_addr *addr, u16_t port)

{
	int i;
	enet_actualCnt = p->len;
	enet_totalCnt  = p->tot_len;
	struct pbuf *ptmp = p;

	if (p != NULL)
	{
		{
			for (i = 0; i < enet_actualCnt; i++)
			{
				cmSend2CPUBuffer[i]=(*((uint8_t *)p->payload + i));
			}

			ptmp = p->next;

			CMTOCPU1_ipc1SendData(cmSend2CPUBuffer, enet_totalCnt, IPC1_CMD_CPU1_READ_MEM);
//			memset(&cmDatSendBuffer[0], 0, enet_totalCnt);
		}
		enet_remotePort = port;

		udp_connect(upcb, addr, port); /* connect to the remote host */

	}

	// 释放缓冲区数据
	pbuf_free(p);
}

void CMTOCPU1_ipc1SendData(uint32_t dataAddr, uint32_t dataSize, uint32_t command)
{

    //
    // Send a message without message queue
    // Since C28x and CM does not share the same address space for shared RAM,
    // ADDRESS_CORRECTION is enabled
    // Length of the data to be read is passed as data.
    //
    IPC_sendCommand(IPC_CM_L_CPU1_R, IPC_FLAG1, IPC_ADDR_CORRECTION_ENABLE,
					command, (uint32_t)dataAddr, dataSize);

    //
    // Wait for acknowledgment
    //
    IPC_waitForAck(IPC_CM_L_CPU1_R, IPC_FLAG1);
}

__interrupt void CMTOCPU1IPC1_ISR(void)
{
	uint32_t enet_totalRvCnt;
    uint32_t command;
	uint32_t Addr;
    int i = 0;

    IPC_readCommand(IPC_CPU1_L_CM_R, IPC_FLAG1, IPC_ADDR_CORRECTION_ENABLE,
                    &command, &Addr, &enet_totalRvCnt);

    if(command == IPC1_CMD_CPU1_READ_MEM || command == IPC1_CMD_CM_READ_ARRAY ||
    		command == IPC1_CMD_CM_READ_MONITOR)
    {
        for(i=0; i<enet_totalRvCnt; i++)
        {
            *(RevBuffer + i) = *((uint16_t *)Addr + i);
        }
    }

    IPC_ackFlagRtoL(IPC_CPU1_L_CM_R, IPC_FLAG1);

    Interrupt_clearACKGroup(INTERRUPT_ACK_GROUP11);
}

__interrupt void CMTOCPU1IPC0_ISR(void)
{

	uint32_t command;

	// sig0_updata_send
	command 	= CMTOCPU1_ipc0ReadData(cpu1ObjReadBuffer);

    Interrupt_clearACKGroup(INTERRUPT_ACK_GROUP11);
}

uint32_t CMTOCPU1_ipc0ReadData(uint32_t *dataAddr)
{
    uint32_t command, Addr;
    uint32_t dataSize;
    //
    // Read the command
    //
    IPC_readCommand(IPC_CPU1_L_CM_R, IPC_FLAG0, IPC_ADDR_CORRECTION_ENABLE,
                    &command, &Addr, &dataSize);

    if(command == IPC0_CMD_CPU1_ECAT_UPDATE)
    {
        int i;
        for(i=0; i<dataSize; i++)
        {
            *(dataAddr + i) = *((uint32_t *)Addr + i);
        }
    }

    IPC_ackFlagRtoL(IPC_CPU1_L_CM_R, IPC_FLAG0);

    return command;
}