echo.c

Using DSP/BIOS I/O in Multichannel Systems

/* ***********************************************************
* THIS PROGRAM IS PROVIDED "AS IS". TI MAKES NO WARRANTIES OR
* REPRESENTATIONS, EITHER EXPRESS, IMPLIED OR STATUTORY, 
* INCLUDING ANY IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS 
* FOR A PARTICULAR PURPOSE, LACK OF VIRUSES, ACCURACY OR 
* COMPLETENESS OF RESPONSES, RESULTS AND LACK OF NEGLIGENCE. 
* TI DISCLAIMS ANY WARRANTY OF TITLE, QUIET ENJOYMENT, QUIET 
* POSSESSION, AND NON-INFRINGEMENT OF ANY THIRD PARTY 
* INTELLECTUAL PROPERTY RIGHTS WITH REGARD TO THE PROGRAM OR 
* YOUR USE OF THE PROGRAM.
*
* IN NO EVENT SHALL TI BE LIABLE FOR ANY SPECIAL, INCIDENTAL, 
* CONSEQUENTIAL OR INDIRECT DAMAGES, HOWEVER CAUSED, ON ANY 
* THEORY OF LIABILITY AND WHETHER OR NOT TI HAS BEEN ADVISED 
* OF THE POSSIBILITY OF SUCH DAMAGES, ARISING IN ANY WAY OUT 
* OF THIS AGREEMENT, THE PROGRAM, OR YOUR USE OF THE PROGRAM. 
* EXCLUDED DAMAGES INCLUDE, BUT ARE NOT LIMITED TO, COST OF 
* REMOVAL OR REINSTALLATION, COMPUTER TIME, LABOR COSTS, LOSS 
* OF GOODWILL, LOSS OF PROFITS, LOSS OF SAVINGS, OR LOSS OF 
* USE OR INTERRUPTION OF BUSINESS. IN NO EVENT WILL TI'S 
* AGGREGATE LIABILITY UNDER THIS AGREEMENT OR ARISING OUT OF 
* YOUR USE OF THE PROGRAM EXCEED FIVE HUNDRED DOLLARS 
* (U.S.$500).
*
* Unless otherwise stated, the Program written and copyrighted 
* by Texas Instruments is distributed as "freeware".  You may, 
* only under TI's copyright in the Program, use and modify the 
* Program without any charge or restriction.  You may 
* distribute to third parties, provided that you transfer a 
* copy of this license to the third party and the third party 
* agrees to these terms by its first use of the Program. You 
* must reproduce the copyright notice and any other legend of 
* ownership on each copy or partial copy, of the Program.
*
* You acknowledge and agree that the Program contains 
* copyrighted material, trade secrets and other TI proprietary 
* information and is protected by copyright laws, 
* international copyright treaties, and trade secret laws, as 
* well as other intellectual property laws.  To protect TI's 
* rights in the Program, you agree not to decompile, reverse 
* engineer, disassemble or otherwise translate any object code 
* versions of the Program to a human-readable form.  You agree 
* that in no event will you alter, remove or destroy any 
* copyright notice included in the Program.  TI reserves all 
* rights not specifically granted under this license. Except 
* as specifically provided herein, nothing in this agreement 
* shall be construed as conferring by implication, estoppel, 
* or otherwise, upon you, any license or other right under any 
* TI patents, copyrights or trade secrets.
*
* You may not use the Program in non-TI devices.
* ********************************************************* */

#include <std.h>
#include <mem.h>
#include <log.h>
#include <sio.h>
#include <tsk.h>

#define NUM_CHANNELS	2
#define SAMPLE_BUF_LEN 	160 /* number of samples in a frame */
#define SAMPLE_BUF_SIZE (SAMPLE_BUF_LEN * sizeof(unsigned short)) 
#define CHANNEL0		0
#define CHANNEL1		1

extern far LOG_Obj trace; 	   	/* application printf() log */ 
extern far LOG_Obj trace1;
extern far SIO_Obj inStream0;
extern far SIO_Obj outStream0;
extern far SIO_Obj inStream1;
extern far SIO_Obj outStream1;
extern Int IDRAM;

extern Void doLoad(int load);

void echo(Int channelNum);

typedef struct dataChannel {
	SIO_Obj 	*inStream;
	SIO_Obj 	*outStream;
    Ptr 		buf;
    Ptr			buf1;
    Ptr			buf2;
    Int			bufSize;
	Int			load;
} dataChannel;

dataChannel		audioChannel[NUM_CHANNELS];

Void initChannelData(void)
{   
	dataChannel		*pChannel;
	
	/* initialize structure for channel 0 */
	pChannel = &audioChannel[CHANNEL0];
	pChannel->inStream = &inStream0;
	pChannel->outStream = &outStream0;
   	pChannel->bufSize = SAMPLE_BUF_SIZE;
    pChannel->load = 0;
	    
	/* initialize structure for channel  */
	pChannel = &audioChannel[CHANNEL1];
	pChannel->inStream = &inStream1;
	pChannel->outStream = &outStream1;
   	pChannel->bufSize = SAMPLE_BUF_SIZE;
    pChannel->load = 0;
}

Bool processChannel(dataChannel *channel)
{ 
	Arg		arg;
  
	LOG_printf(&trace1, "sio_issue in uses buffer 0x%x", channel->buf);
	
	if (SIO_issue(channel->inStream, 
				  channel->buf, 
				  channel->bufSize, 
				  NULL) < 0) {
		return(FALSE);
	}

	if (SIO_reclaim(channel->inStream,
					&channel->buf,
					&arg) < 0) {
		return(FALSE);
	}

	LOG_printf(&trace1, "sio_reclaim in returns buffer 0x%x", channel->buf);
	
	/* processing of received buffer is done here */
	doLoad(channel->load);
      
	LOG_printf(&trace1, "sio_issue out uses buffer 0x%x", channel->buf);

	if (SIO_issue(channel->outStream, 
				  channel->buf, 
				  channel->bufSize, 
				  NULL) < 0) {
		return(FALSE);
	}

	if (SIO_reclaim(channel->outStream,
					&channel->buf,
					&arg) < 0) {
		return(FALSE);
	}
		
	LOG_printf(&trace1, "sio_reclaim out returns buffer 0x%x", channel->buf);
	return(TRUE);	
}

void echo(Int channelNum)
{
	/* need to get the three output buffers, and prime the output SIO; this */
	/* is done with zero-length buffers, because it is output; it is necessary */
	/* to prime the SIO if we want to mirror the double-buffering done in the */
	/* standard model */
	if ((audioChannel[channelNum].buf = (Ptr)MEM_alloc(IDRAM, 
													   SAMPLE_BUF_SIZE, 
													   0)) == NULL) {
        SYS_abort("MEM_alloc failed");
	}
	/* get a second buffer to ping-pong with */
	if ((audioChannel[channelNum].buf1 = (Ptr)MEM_alloc(IDRAM, 
													    SAMPLE_BUF_SIZE, 
													    0)) == NULL) {
        SYS_abort("MEM_alloc failed");
	}
	
	/* give both buffers to outStream to prime it */
	if (SIO_issue(audioChannel[channelNum].outStream, 
				  audioChannel[channelNum].buf, 
				  0, 
				  NULL) < 0) {
		SYS_abort("error on issue for chan %d", channelNum);
	}
	if (SIO_issue(audioChannel[channelNum].outStream, 
				  audioChannel[channelNum].buf1, 
				  0, 
				  NULL) < 0) {
		SYS_abort("error on issue for chan %d", channelNum);
	}
	
    /* prime the input stream; this means getting all three buffer addresses */
    /* an issuing two of them to the input stream; the third will be issued */
    /* inside the processChannel call */
	LOG_printf(&trace1, "sio_issue uses buffer 0x%x", audioChannel[channelNum].buf1);
    /* get a buffer to ping-pong with */
    if (SIO_staticbuf(audioChannel[channelNum].inStream, 
    				  &audioChannel[channelNum].buf) == 0) {
        SYS_abort("Cannot get static buffer");
    }   
	/* get a second buffer to ping-pong with */
    if (SIO_staticbuf(audioChannel[channelNum].inStream, 
    				  &audioChannel[channelNum].buf1) == 0) {
        SYS_abort("Cannot get static buffer");
    }   
	/* get a third buffer to ping-pong with */
    if (SIO_staticbuf(audioChannel[channelNum].inStream, 
    				  &audioChannel[channelNum].buf2) == 0) {
        SYS_abort("Cannot get static buffer");
    }
    
    /* give two of the buffers to inStream to prime it; the third will be */
    /* given to the stream in processChannel */   
	if (SIO_issue(audioChannel[channelNum].inStream, 
				  audioChannel[channelNum].buf2, 
				  audioChannel[channelNum].bufSize, 
				  NULL) < 0) {
		SYS_abort("error on issue for chan %d", channelNum);
	}
	if (SIO_issue(audioChannel[channelNum].inStream, 
				  audioChannel[channelNum].buf1, 
				  audioChannel[channelNum].bufSize, 
				  NULL) < 0) {
		SYS_abort("error on issue for chan %d", channelNum);
	}

	while (TRUE) {
		LOG_printf(&trace1, "channel %d", channelNum);
		
		if (!processChannel(&audioChannel[channelNum])) {
			LOG_printf(&trace, "processing error on channel %d", channelNum);
		}
		
	}
}

main()
{
	initChannelData();
}