[nyadav] 52167: [AUDSRV] mixer routine for signed 16 bit data

Author: nyadav
Date: Thu Jun  9 23:06:06 2011
New Revision: 52167

URL: http://svn.reactos.org/svn/reactos?rev=52167&view=rev
Log:
[AUDSRV] mixer routine for signed 16 bit data

Modified:
    branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
    branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
    branches/nyadav-audio-branch/base/services/audsrv/mixer.c
    branches/nyadav-audio-branch/base/services/audsrv/stream.c
    branches/nyadav-audio-branch/drivers/wdm/audio/backpln/audclient/audclient.c
    branches/nyadav-audio-branch/include/reactos/libs/audsrv/audsrvapi.h

Modified: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/audsrv.c [iso-8859-1] (original)
+++ branches/nyadav-audio-branch/base/services/audsrv/audsrv.c [iso-8859-1] Thu Jun  9
23:06:06 2011
@@ -159,7 +159,7 @@
 MixAndFill(MixerEngine * mixer,
            int buffer)
 {
-    while(WaitForSingleObject(mixer->streampresent,
+    while(WaitForSingleObject(mixer->newStreamEvent,
                               100) != 0)
     {
         if(mixer->dead)
@@ -583,7 +583,7 @@
                                     FALSE,
                                     NULL);
 
-        pengine->streampresent=CreateEvent(NULL,
+        pengine->newStreamEvent=CreateEvent(NULL,
                                            TRUE,
                                            FALSE,
                                            NULL);
@@ -625,7 +625,7 @@
     pengine->masterbuf[1] = NULL;
     pengine->played=CreateEvent(NULL,FALSE,FALSE,NULL);
     pengine->filled=CreateEvent(NULL,FALSE,FALSE,NULL);
-    pengine->streampresent=CreateEvent(NULL,TRUE,FALSE,NULL);
+    pengine->newStreamEvent=CreateEvent(NULL,TRUE,FALSE,NULL);
     SetConsoleCtrlHandler(Close,TRUE);
     SpawnMixerThread(pengine);
     SpawnPlayerThread(pengine);

Modified: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/audsrv.h [iso-8859-1] (original)
+++ branches/nyadav-audio-branch/base/services/audsrv/audsrv.h [iso-8859-1] Thu Jun  9
23:06:06 2011
@@ -69,7 +69,7 @@
     long streamidpool;
     HANDLE played;
     HANDLE filled;
-    HANDLE streampresent;
+    HANDLE newStreamEvent;
     HANDLE mixerthread;
     HANDLE playerthread;
     HANDLE rpcthread;

Modified: branches/nyadav-audio-branch/base/services/audsrv/mixer.c
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/mixer.c [iso-8859-1] (original)
+++ branches/nyadav-audio-branch/base/services/audsrv/mixer.c [iso-8859-1] Thu Jun  9
23:06:06 2011
@@ -14,9 +14,58 @@
 }
 void * MixS16(MixerEngine * mixer,int buffer)
 {
-    mixer->masterbuf[buffer] = HeapAlloc(GetProcessHeap(), 0,
mixer->serverstreamlist->length_filtered);
+	int length=0;
+	short minsamplevalue,maxsamplevalue;
+	float coefficient = 1.0;
+	int streamcount = 0,i;
+	PSHORT localsinkbuf,localsrcbuf;
+	ServerStream * stream = mixer->serverstreamlist;
+
+	/*TODOAssert(mixer->serverstreamlist == NULL)*/
+
+	/*Find the Longest Buffer within all ServerStreams*/
+	length = stream->length_filtered;
+	while(stream->next != NULL)
+	{
+		if(stream->length_filtered > length && stream->ready == TRUE )
+			length = stream->length_filtered;
+		stream = stream->next;
+	}
+
+	/*Allocate MasterBuffer*/
+    mixer->masterbuf[buffer] = HeapAlloc(GetProcessHeap(), 0, length);
+	localsinkbuf = mixer->masterbuf[buffer];
+    mixer->bytes_to_play = length;
+
+	/*Perform Actual Mixing*/
+	stream = mixer->serverstreamlist;
+	minsamplevalue = *(short *) stream->minsamplevalue;
+	maxsamplevalue = *(short *) stream->maxsamplevalue;
+	while(stream->next != NULL)
+	{
+		localsrcbuf = stream->filteredbuf;
+		if(stream->ready == TRUE )
+		{
+			if( *(short *)stream->maxsamplevalue != maxsamplevalue ||
+			    *(short *)stream->minsamplevalue != minsamplevalue  )
+			{
+				if( (float) maxsamplevalue / (float)*(short *)stream->maxsamplevalue < 
+				    (float) minsamplevalue / (float)*(short *)stream->minsamplevalue )
+					coefficient = (float) maxsamplevalue / (float)*(short *)stream->maxsamplevalue;
+				else
+					coefficient = (float) minsamplevalue / (float)*(short *)stream->minsamplevalue;
+				
+				for(i=0;i<stream->length_filtered;i++)
+				{
+					localsinkbuf[i] = (short) (( (localsinkbuf[i] * streamcount) + ((short)((float) 
localsrcbuf[i] ) * coefficient) ) / (streamcount +1));
+				}
+			}
+		}
+		stream->ready = 0;
+		streamcount++;
+		stream = stream->next;
+	}
    
CopyMemory(mixer->masterbuf[buffer],mixer->serverstreamlist->filteredbuf,mixer->serverstreamlist->length_filtered);
-    mixer->bytes_to_play = mixer->serverstreamlist->length_filtered;
 
     return NULL;
 }

Modified: branches/nyadav-audio-branch/base/services/audsrv/stream.c
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/stream.c [iso-8859-1] (original)
+++ branches/nyadav-audio-branch/base/services/audsrv/stream.c [iso-8859-1] Thu Jun  9
23:06:06 2011
@@ -192,7 +192,7 @@
             localstream = localstream->next;
         localstream->next = newstream;
     }
-    SetEvent(pengine->streampresent);
+    SetEvent(pengine->newStreamEvent);
     return newstream->streamid;
 
 error:

Modified: branches/nyadav-audio-branch/drivers/wdm/audio/backpln/audclient/audclient.c
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/drivers/wdm…
==============================================================================
--- branches/nyadav-audio-branch/drivers/wdm/audio/backpln/audclient/audclient.c
[iso-8859-1] (original)
+++ branches/nyadav-audio-branch/drivers/wdm/audio/backpln/audclient/audclient.c
[iso-8859-1] Thu Jun  9 23:06:06 2011
@@ -12,6 +12,9 @@
 
 #include <audsrvapi.h>
 #include <stdio.h>
+#include <debug.h>
+#include <windows.h>
+#include <winbase.h>
 
 void OpenComplete (int error );
 void BufferCopied (int error );
@@ -28,7 +31,7 @@
 DWORD WINAPI RunAudioThread(LPVOID param)
 {
     ClientStream * localstream = (ClientStream *) param;
-    playaudio(localstream);
+    PlayAudio(localstream);
 
     return 0;
 }
@@ -45,7 +48,6 @@
 }
 void PlayComplete (int error )
 {
-    OutputDebugStringA("Playback Completed\n");
 }
 int
 __cdecl
@@ -55,11 +57,11 @@
     DWORD dwID;
     HANDLE audiothread = NULL;
     char input='\0';
-    OutputDebugStringA("ReactOS Audio Mixer Sample Client.Enter 'a' to
Stop.\n");
+    printf("ReactOS Audio Mixer Sample Client.Enter 'a' to Stop.\n");
     //if (clientstream->callbacks.OpenComplete == NULL ||
clientstream->callbacks.BufferCopied == NULL || clientstream->callbacks.PlayComplete
== NULL) printf("");
 
     /*[out]HANDLE * streamhandle,[in] long frequency,[in] int number of channels,[in] int
bitspersample,[in]ULONG channelmask,[in] int volume,[in] int mute,[in] float balance*/
-    error = initstream ( &clientstream ,
+    error = InitStream ( &clientstream ,
                          44100 ,
                          2 ,
                          16 ,
@@ -71,20 +73,17 @@
 
     if ( error )
     {
-        OutputDebugStringA("Failed to Initialize Stream.Error \n");
         goto error;
     }
     else
     {
-        OutputDebugStringA("StreamID : %ld\n",clientstream.stream);
         audiothread = CreateThread(NULL,0,RunAudioThread,&clientstream,0,&dwID);
     }
 
     while ( input != 'a' )
         scanf("%c",&input);
 
-    OutputDebugStringA("Stoping Audio Stream.\n");
-    stopaudio(&clientstream);
+    StopAudio(&clientstream);
     WaitForSingleObject(audiothread,INFINITE);
 
     return 0;

Modified: branches/nyadav-audio-branch/include/reactos/libs/audsrv/audsrvapi.h
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/include/rea…
==============================================================================
--- branches/nyadav-audio-branch/include/reactos/libs/audsrv/audsrvapi.h [iso-8859-1]
(original)
+++ branches/nyadav-audio-branch/include/reactos/libs/audsrv/audsrvapi.h [iso-8859-1] Thu
Jun  9 23:06:06 2011
@@ -24,7 +24,7 @@
 } ClientStream;
 
 /********************API Functions******************/
-WINAPI int initstream (ClientStream * clientstream,
+WINAPI int InitStream (ClientStream * clientstream,
                        LONG frequency,
                        int channels,
                        int bitspersample,
@@ -34,8 +34,8 @@
                        int mute,
                        float balance);
 
-WINAPI int playaudio ( ClientStream * clientstream);
-WINAPI int stopaudio (ClientStream * clientstream );
+WINAPI int PlayAudio ( ClientStream * clientstream);
+WINAPI int StopAudio (ClientStream * clientstream );
 
 WINAPI int Volume(ClientStream * clientstream,
                   int * volume );