aaci_dmaold.c

此压缩包为杰得开发得z228的BSP的源代码,可以实现很多功能,尤其是视频解码有很好的效果.

#include <windows.h>
#include <pkfuncs.h>
#include <ceddk.h>
#include <oalfuncs.h>
#include <dma.h>
#include "oalintr.h"
#include "wavemdd.h"

#define DebugMsg_Normal 0x01
#define DebugMsg_Important 0x02
#define DebugMsg_Trace	0x04
#define DebugMsgMask (DebugMsg_Important|DebugMsg_Normal)

int ReleasePlayDMA(void);
int InitPlayDMA();
int AllocPlayDMA(void);
void GetPlayBuffer( unsigned int *buf );
int InitAll();
int StartPlayDMA( unsigned int bufphy, int size ,  int* actualbuffered );
int ReleaseAll();
int AllocRecordDMA(void);
int InitRecordDMA(void);
int StartRecordDMA( LPSTR buffer , DWORD size , int* actualbuffered);
DWORD AudioDMAThread(LPVOID p);

static HANDLE DmaPlayEvent = 0;
static HANDLE DmaRecordEvent = 0;
static volatile int DMAPlayCmd;
static volatile int DMARecordCmd;
static int TotalPlayBufferCnt = 0;
static volatile int PlayBufferPlayIndex = 0;
static volatile int PlayBufferStoreIndex = 0;

static int PlayDMAChannelNumber = -1;
static int PlayDmaIntID = 0;
static int RecordDMAChannelNumber = -1;
static int RecordDmaIntID = 0;
static HANDLE DmaThread = 0;
static HANDLE DmaRecordThread = 0;

WAVEFORMATEX	RecordFormat;

static int playcount = 0;
static int playedcount = 0;
int InRemove = 0;


#define DMA_PLAY_STOP  0
#define DMA_PLAY_START 1
#define DMA_PLAY_EXIT  2

#define DMA_RECORD_STOP  0
#define DMA_RECORD_START 1
#define DMA_RECORD_EXIT  2

//static char RecordTemp[4][0x1000];
static int RecordIndex = 0;

int OnInit()
{
	int error = 0;
	if( InitAll() != 0 )
		error = 1;
	if( error )
	{
		DMAPlayCmd = DMA_PLAY_EXIT;
		DMARecordCmd = DMA_RECORD_EXIT;
	}
	else
	{
		DMAPlayCmd = DMA_PLAY_STOP;
		DMARecordCmd = DMA_RECORD_STOP;
	}
	return error;
}

int OnDeinit()
{
	int error = 0;	
	ReleaseAll();
	return error;
}

int OnRecordOpen()
{
	int error = 0;
	DMARecordCmd = DMA_RECORD_STOP;	
	RETAILMSG( (DebugMsgMask&DebugMsg_Normal) , (TEXT( "OnRecordOpen\r\n" ) ));
	return error;
}
int OnRecordStart()
{
	int error = 0;
	DMARecordCmd = DMA_RECORD_START;
	RETAILMSG( (DebugMsgMask&DebugMsg_Normal), (TEXT( "OnRecordStart\r\n" ) ));
	SetEvent( DmaRecordEvent );
	return error;
}
int OnRecordStop()
{
	int error = 0;
	DMARecordCmd = DMA_RECORD_STOP;
	return error;
}

int OnRecordClose()
{
	int error = 0;
	DMARecordCmd = DMA_RECORD_STOP;
	SetEvent( DmaRecordEvent );
	//RETAILMSG( (DebugMsgMask&DebugMsg_Normal), (TEXT( "OnRecordClose\r\n" ) ));
	return error;
}

int OnPlayOpen()
{
	int error = 0;
	PlayBufferPlayIndex = PlayBufferStoreIndex = 0;
	DMAPlayCmd = DMA_PLAY_START;	
	playcount = playedcount = 0;
	//RETAILMSG( (DebugMsgMask&DebugMsg_Normal), (TEXT( "OnPlayOpen\r\n" ) ));
	return error;
}

int OnPlayStart()
{
	int error = 0;
	DMAPlayCmd = DMA_PLAY_START;
	RETAILMSG( (DebugMsgMask&DebugMsg_Normal), (TEXT( "OnPlayStart\r\n" ) ));
	return error;
}
int OnPlayStop()
{
	int error = 0;
	DMAPlayCmd = DMA_PLAY_STOP;
	SetEvent( DmaPlayEvent );
	return error;
}
int OnPlayClose()
{
	int error = 0;
	DMAPlayCmd = DMA_PLAY_STOP;
	//RETAILMSG( (DebugMsgMask&DebugMsg_Normal), (TEXT( "OnPlayClose\r\n" ) ));
	return error;
}
/*
int RemoveRecordBuffer( int toremove )
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_IN);
	if( gsi[WAPI_IN].bStarted == TRUE )
	{				
		g_pwh = gsi[WAPI_IN].pwh;				
		while( g_pwh && (g_pwh->reserved == 0 || g_pwh->dwBytesRecorded != 0) )
			g_pwh = g_pwh->lpNext;
		while( toremove-- && g_pwh )
		{	//memcpy(dest,src,length)	
			memcpy( g_pwh->lpData , RecordTemp[g_pwh->reserved-1 ] , g_pwh->dwBufferLength );
			g_pwh->dwBytesRecorded = g_pwh->dwBufferLength;
			g_pwh->reserved = 0;
			MARK_BUFFER_DONE(g_pwh);
			g_pwh = g_pwh->lpNext;
		}
		RemoveCompleteBlocks(WAPI_IN);
	}
	else
	{
		error = 1;
	}
	UNLOCK_GSI(WAPI_IN);
	return error;
}
*/

//add whs 用原来不拷贝BUFF的方法
int RemoveRecordBuffer( int toremove )
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_IN);
	if( gsi[WAPI_IN].bStarted == TRUE )
	{				
		g_pwh = gsi[WAPI_IN].pwh;				
		while( g_pwh && g_pwh->dwBytesRecorded == g_pwh->dwBufferLength)
			g_pwh = g_pwh->lpNext;
		while( toremove-- && g_pwh )
		{				
			g_pwh->dwBytesRecorded = g_pwh->dwBufferLength;
			g_pwh = g_pwh->lpNext;
		}
		MarkFullAsDone(WAPI_IN);
		RemoveCompleteBlocks(WAPI_IN);						
	}
	else
	{
		error = 1;
	}
	UNLOCK_GSI(WAPI_IN);
	return error;
}


int RemovePlayBuffer( int toremove )
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_OUT);
	if( gsi[WAPI_OUT].bStarted == TRUE )
	{				
		g_pwh = gsi[WAPI_OUT].pwh;				
		while( g_pwh && g_pwh->dwBytesRecorded == g_pwh->dwBufferLength)
			g_pwh = g_pwh->lpNext;
		while( toremove-- && g_pwh )
		{				
			g_pwh->dwBytesRecorded = g_pwh->dwBufferLength;
			g_pwh = g_pwh->lpNext;
			playedcount ++;
		}
		MarkFullAsDone(WAPI_OUT);
		InRemove = 1;
		RemoveCompleteBlocks(WAPI_OUT);						
		InRemove = 0;
	}
	else
	{
		error = 1;
	}
	UNLOCK_GSI(WAPI_OUT);
	return error;
}

/*
int AddRecordBuffer( int* left , int* morebuffer)
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_IN);
	if( gsi[WAPI_IN].bStarted == TRUE )
	{
		g_pwh = gsi[WAPI_IN].pwh;				
		while( g_pwh && (g_pwh->dwBytesRecorded != 0 || g_pwh->reserved != 0) )
			g_pwh = g_pwh->lpNext;
		if( g_pwh )
		{
			//StartRecordDMA( g_pwh->lpData , g_pwh->dwBufferLength , left );
			//
			StartRecordDMA( RecordTemp[RecordIndex] , g_pwh->dwBufferLength , left );
			RecordIndex ++;
			g_pwh->reserved = RecordIndex;
			if( RecordIndex >= 4 )
				RecordIndex = 0;
			if( g_pwh->lpNext )
				*morebuffer = 1;
			else
				*morebuffer = 0;
			RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT("aaci : addrecord : %x , %x\r\n")  ,g_pwh->lpData , g_pwh->dwBufferLength));
		}
		else
		{
			error = 2;
			*morebuffer = 0;
		}
	}
	else
	{
		//DMARecordCmd = DMA_RECORD_STOP;
		error = 1;
	}
	UNLOCK_GSI(WAPI_IN);
	return error;
}
*/
//add whs
/*
 wave data block header 
typedef struct wavehdr_tag {
    LPSTR       lpData;                  pointer to locked data buffer 
    DWORD       dwBufferLength;         //* length of data buffer 
    DWORD       dwBytesRecorded;        //* used for input only 
    DWORD       dwUser;                 // for client's use 
    DWORD       dwFlags;                //* assorted flags (see defines) 
    DWORD       dwLoops;                //* loop control counter 
   struct wavehdr_tag FAR *lpNext;    //* reserved for driver 
   DWORD       reserved;              / /* reserved for driver 
} WAVEHDR, *PWAVEHDR, NEAR *NPWAVEHDR, FAR *LPWAVEHDR;
*/
int AddRecordBuffer( int* left , int* morebuffer)
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_IN);
	if( gsi[WAPI_IN].bStarted == TRUE )
	{
		g_pwh = gsi[WAPI_IN].pwh;				
		while( g_pwh && g_pwh->dwBytesRecorded != 0)
			g_pwh = g_pwh->lpNext;
		if( g_pwh )
		{//g_pwh->lpData----pointer to locked data buffer 
		//dwBufferLength;         //* length of data buffer 
			StartRecordDMA( g_pwh->lpData , g_pwh->dwBufferLength , left );
			g_pwh->dwBytesRecorded = g_pwh->dwBufferLength/2;
			if( g_pwh->lpNext )
				*morebuffer = 1;
			else
				*morebuffer = 0;
			RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT("aaci : addrecord : %x , %x\r\n")  ,g_pwh->lpData , g_pwh->dwBufferLength));
		}
		else
		{
			error = 2;
			*morebuffer = 0;
		}
	}
	else
	{
		//DMARecordCmd = DMA_RECORD_STOP;
		error = 1;
	}
	UNLOCK_GSI(WAPI_IN);
	return error;
}



int AddPlayBuffer( int* left )
{
	PWAVEHDR g_pwh;
	int error = 0;
	LOCK_GSI(WAPI_OUT);
	if( gsi[WAPI_OUT].bStarted == TRUE )
	{
		g_pwh = gsi[WAPI_OUT].pwh;				
		while( g_pwh && g_pwh->dwBytesRecorded != 0)
			g_pwh = g_pwh->lpNext;
		if( g_pwh )
		{
			DWORD bufphy;
			int size = g_pwh->dwBufferLength;
			g_pwh->dwBytesRecorded = size/2;					
			GetPlayBuffer( &bufphy );
			StartPlayDMA( bufphy , size , left );
		}
		else
			error = 2;
	}
	else
	{
	//	DMAPlayCmd = DMA_PLAY_STOP;
		error = 1;
	}
	UNLOCK_GSI(WAPI_OUT);
	return error;
}
//定义record buff=1
#define RecordBufferCount 1
//record thread
DWORD AudioRecordThread( LPVOID p )
{
	int leftrecordblock = 0 , bufferedrecordblock = 0 , moreinputblock = 0 , error = 0;
	SetProcPermissions( 0xFFFFFFFF );
	RETAILMSG( (DebugMsgMask&DebugMsg_Important ), (TEXT( "AACI : DMA : Enter record Thread\r\n" ) ));
/*
if(0)
	{
		int time = GetTickCount() , loopcount = 0;
		while( !error && DMARecordCmd != DMA_RECORD_EXIT )
		{
			if( (loopcount++%1000) == 0 )
				RETAILMSG( 1 , (TEXT("AudioRecordThread loop %d\n" ) , bufferedrecordblock ));
			if( DMARecordCmd == DMA_RECORD_STOP || moreinputblock == 0 )
				WaitForSingleObject( DmaRecordEvent , INFINITE );
			if( (DMARecordCmd != DMA_RECORD_START) )
				continue;
			if( AddRecordBuffer( &leftrecordblock , &moreinputblock ) == 0 )
			{
				while( GetTickCount() - time < 20 )
				{
					Sleep( 5 );
				}
				time = GetTickCount();
				RemoveRecordBuffer(1);
			}
		}
	}
*/
	while( !error && DMARecordCmd != DMA_RECORD_EXIT )//当没有出现错误并且DMARecordCmd ！=DMA_RECORD_EXIT的时候循环
	{
//如果DMARecordCmd =  DMA_RECORD_STOP 停此录音
		if( DMARecordCmd == DMA_RECORD_STOP )
		{
			int param1 = 0 , param2 = 1;
			KernelIoControl( HAL_IOCTL_AACI_CLEARSTATUS , &param1 , sizeof(int) , &param2 , sizeof(int) , 0);
			bufferedrecordblock = 0;
			RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT( "AACI : record : stoped \r\n" ) ));
		}
              //#define RecordBufferCount 1
		//如果当前状态为DMA_RECORD_STOP|| bufferedrecordblock==1|| moreinputblock == 0 
		//现在我们每次只录一个BUFF所以当kernel中有一个buff的时候就等待
		if(  DMARecordCmd == DMA_RECORD_STOP || bufferedrecordblock == RecordBufferCount || moreinputblock == 0 )
		{
			RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT( "AACI : record : wait %d %d\r\n" ), bufferedrecordblock , moreinputblock ));
			WaitForSingleObject( DmaRecordEvent , INFINITE );//这个事件在初始化的时候和DMA中断关联起来
			//当DMA完成了一个传送即kernel中的一个buff填充了好数据，
		}
		if( (DMARecordCmd != DMA_RECORD_START) )
			continue;
		RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT( "AACI : DMA : start work\r\n" ) ));
//由于我们现在在kernel 中的buff 只有一个所以当一个DMA传送完成后kernel中的leftrecordblock应该为0了
//获取当前kernel里面的没有准备好的BUFF的数目即leftrecordblock
		KernelIoControl( HAL_IOCTL_AACI_GETBUFFER , 0 , 0 , &leftrecordblock , sizeof(int) , 0);
		
		if( DMARecordCmd == DMA_RECORD_START )
			if( (leftrecordblock!=bufferedrecordblock) || bufferedrecordblock < RecordBufferCount) 
			{
				RETAILMSG( (DebugMsgMask&DebugMsg_Trace) , (TEXT("aaci : to add buffer %d %d\r\n") , bufferedrecordblock, leftrecordblock ));				
				if( AddRecordBuffer( &leftrecordblock , &moreinputblock ) == 0 )
					bufferedrecordblock ++;
				if( moreinputblock == 0 )
					RETAILMSG( 0, (TEXT("aaci : record : no more input block\r\n" )));
			}
				
		if( leftrecordblock < bufferedrecordblock )
		{
			int toremove = bufferedrecordblock - leftrecordblock;
			if( RemoveRecordBuffer( toremove ) == 0 )
				bufferedrecordblock = leftrecordblock;
			InterruptDone( RecordDmaIntID );//通知kernel中断完成
		}