[ros-diffs] [nyadav] 51955: [AUDSRV] Modify Architecture of server to use RPC

Author: nyadav
Date: Fri May 27 09:48:26 2011
New Revision: 51955

URL: http://svn.reactos.org/svn/reactos?rev=51955&view=rev
Log:
[AUDSRV] Modify Architecture of server to use RPC

Added:
    branches/nyadav-audio-branch/base/services/audsrv/   (with props)
    branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt   (with props)
    branches/nyadav-audio-branch/base/services/audsrv/audsrv.c   (with props)
    branches/nyadav-audio-branch/base/services/audsrv/audsrv.h   (with props)
    branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc   (with props)
    branches/nyadav-audio-branch/base/services/audsrv/rpc.c   (with props)
Removed:
    branches/nyadav-audio-branch/base/services/audiosrv2/
Modified:
    branches/nyadav-audio-branch/base/services/CMakeLists.txt

Modified: branches/nyadav-audio-branch/base/services/CMakeLists.txt
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/CMakeLists.txt [iso-8859-1] (original)
+++ branches/nyadav-audio-branch/base/services/CMakeLists.txt [iso-8859-1] Fri May 27
09:48:26 2011
@@ -1,6 +1,6 @@
 
 add_subdirectory(audiosrv)
-add_subdirectory(audiosrv2)
+add_subdirectory(audsrv)
 add_subdirectory(eventlog)
 add_subdirectory(rpcss)
 add_subdirectory(spoolsv)

Propchange: branches/nyadav-audio-branch/base/services/audsrv/
------------------------------------------------------------------------------
--- bugtraq:logregex (added)
+++ bugtraq:logregex Fri May 27 09:48:26 2011
@@ -1,0 +1,2 @@
+([Ii]ssue|[Bb]ug)s? #?(\d+)(,? ?#?(\d+))*(,? ?(and |or )?#?(\d+))?
+(\d+)

Propchange: branches/nyadav-audio-branch/base/services/audsrv/
------------------------------------------------------------------------------
    bugtraq:message = See issue #%BUGID% for more details.

Propchange: branches/nyadav-audio-branch/base/services/audsrv/
------------------------------------------------------------------------------
    bugtraq:url = http://www.reactos.org/bugzilla/show_bug.cgi?id=%BUGID%

Propchange: branches/nyadav-audio-branch/base/services/audsrv/
------------------------------------------------------------------------------
    tsvn:logminsize = 10

Added: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt (added)
+++ branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt [iso-8859-1] Fri May
27 09:48:26 2011
@@ -1,0 +1,19 @@
+
+include_directories(${REACTOS_BINARY_DIR}/include/reactos/idl)
+
+set_unicode()
+
+list(APPEND SOURCE
+    audsrv.c
+    audsrv.rc
+    rpc.c)
+
+add_executable(audsrv ${SOURCE})
+
+target_link_libraries(audsrv audsrvrpc ${PSEH_LIB})
+
+add_pch(audsrv ${CMAKE_CURRENT_SOURCE_DIR}/audsrv.h ${SOURCE})
+
+set_module_type(audsrv win32cui)
+add_importlibs(audsrv advapi32 rpcrt4 msvcrt kernel32 ntdll user32 ksuser setupapi)
+add_cab_target(audsrv 1)

Propchange: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
------------------------------------------------------------------------------
    evn:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
------------------------------------------------------------------------------
    evn:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
------------------------------------------------------------------------------
    sv:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
------------------------------------------------------------------------------
    sv:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/CMakeLists.txt
------------------------------------------------------------------------------
    svn:eol-style = native

Added: 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 (added)
+++ branches/nyadav-audio-branch/base/services/audsrv/audsrv.c [iso-8859-1] Fri May 27
09:48:26 2011
@@ -1,0 +1,521 @@
+/*
+ * PROJECT:          ReactOS kernel
+ * LICENSE:          GPL - See COPYING in the top level directory
+ * FILE:             services/audsrv.c
+ * PURPOSE:          Audio Server
+ * COPYRIGHT:        Copyright 2011 Pankaj Yadav
+
+ */
+
+/* INCLUDES *****************************************************************/
+
+#include "audsrv.h"
+
+/* GLOBALS ******************************************************************/
+
+static VOID CALLBACK ServiceMain(DWORD, LPWSTR *);
+static DWORD ServiceInit(VOID);
+static BOOL WINAPI close ( DWORD dwCtrlType );
+static WCHAR ServiceName[] = L"AudSrv";
+static SERVICE_TABLE_ENTRYW ServiceTable[2] =
+{
+    { ServiceName, ServiceMain },
+    { NULL, NULL }
+};
+
+SERVICE_STATUS ServiceStatus;
+SERVICE_STATUS_HANDLE ServiceStatusHandle;
+
+
+HANDLE MyHeap = NULL;
+
+#define _2pi                6.283185307179586476925286766559
+
+GUID CategoryGuid = {STATIC_KSCATEGORY_AUDIO};
+
+const GUID KSPROPSETID_Pin                     = {0x8C134960L, 0x51AD, 0x11CF, {0x87,
0x8A, 0x94, 0xF8, 0x01, 0xC1, 0x00, 0x00}};
+const GUID KSPROPSETID_Connection               = {0x1D58C920L, 0xAC9B, 0x11CF, {0xA5,
0xD6, 0x28, 0xDB, 0x04, 0xC1, 0x00, 0x00}};
+const GUID KSPROPSETID_Sysaudio                 = {0xCBE3FAA0L, 0xCC75, 0x11D0, {0xB4,
0x65, 0x00, 0x00, 0x1A, 0x18, 0x18, 0xE6}};
+const GUID KSPROPSETID_General                  = {0x1464EDA5L, 0x6A8F, 0x11D1, {0x9A,
0xA7, 0x00, 0xA0, 0xC9, 0x22, 0x31, 0x96}};
+const GUID KSINTERFACESETID_Standard            = {0x1A8766A0L, 0x62CE, 0x11CF, {0xA5,
0xD6, 0x28, 0xDB, 0x04, 0xC1, 0x00, 0x00}};
+const GUID KSMEDIUMSETID_Standard               = {0x4747B320L, 0x62CE, 0x11CF, {0xA5,
0xD6, 0x28, 0xDB, 0x04, 0xC1, 0x00, 0x00}};
+const GUID KSDATAFORMAT_TYPE_AUDIO              = {0x73647561L, 0x0000, 0x0010, {0x80,
0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71}};
+const GUID KSDATAFORMAT_SUBTYPE_PCM             = {0x00000001L, 0x0000, 0x0010, {0x80,
0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71}};
+const GUID KSDATAFORMAT_SPECIFIER_WAVEFORMATEX  = {0x05589f81L, 0xc356, 0x11ce, {0xbf,
0x01, 0x00, 0xaa, 0x00, 0x55, 0x59, 0x5a}};
+
+MixerEngine engine,*pengine;
+/* FUNCTIONS ****************************************************************/
+
+static VOID
+UpdateServiceStatus(DWORD dwState)
+{
+    ServiceStatus.dwServiceType = SERVICE_WIN32_OWN_PROCESS;
+    ServiceStatus.dwCurrentState = dwState;
+    ServiceStatus.dwControlsAccepted = 0;
+    ServiceStatus.dwWin32ExitCode = 0;
+    ServiceStatus.dwServiceSpecificExitCode = 0;
+    ServiceStatus.dwCheckPoint = 0;
+
+    if (dwState == SERVICE_START_PENDING ||
+        dwState == SERVICE_STOP_PENDING ||
+        dwState == SERVICE_PAUSE_PENDING ||
+        dwState == SERVICE_CONTINUE_PENDING)
+        ServiceStatus.dwWaitHint = 10000;
+    else
+        ServiceStatus.dwWaitHint = 0;
+
+    SetServiceStatus(ServiceStatusHandle,
+                     &ServiceStatus);
+}
+
+static DWORD WINAPI
+ServiceControlHandler(DWORD dwControl,
+                      DWORD dwEventType,
+                      LPVOID lpEventData,
+                      LPVOID lpContext)
+{
+    DPRINT("ServiceControlHandler() called\n");
+
+    switch (dwControl)
+    {
+        case SERVICE_CONTROL_STOP:
+            DPRINT("  SERVICE_CONTROL_STOP received\n");
+			close(CTRL_CLOSE_EVENT);
+            UpdateServiceStatus(SERVICE_STOPPED);
+            return ERROR_SUCCESS;
+
+        case SERVICE_CONTROL_PAUSE:
+            DPRINT("  SERVICE_CONTROL_PAUSE received\n");
+            UpdateServiceStatus(SERVICE_PAUSED);
+            return ERROR_SUCCESS;
+
+        case SERVICE_CONTROL_CONTINUE:
+            DPRINT("  SERVICE_CONTROL_CONTINUE received\n");
+            UpdateServiceStatus(SERVICE_RUNNING);
+            return ERROR_SUCCESS;
+
+        case SERVICE_CONTROL_INTERROGATE:
+            DPRINT("  SERVICE_CONTROL_INTERROGATE received\n");
+            SetServiceStatus(ServiceStatusHandle,
+                             &ServiceStatus);
+            return ERROR_SUCCESS;
+
+        case SERVICE_CONTROL_SHUTDOWN:
+            DPRINT("  SERVICE_CONTROL_SHUTDOWN received\n");
+			close(CTRL_CLOSE_EVENT);
+            UpdateServiceStatus(SERVICE_STOPPED);
+            return ERROR_SUCCESS;
+
+        default :
+            DPRINT1("  Control %lu received\n");
+            return ERROR_CALL_NOT_IMPLEMENTED;
+    }
+}
+
+static VOID CALLBACK
+ServiceMain(DWORD argc,
+            LPWSTR *argv)
+{
+    DWORD dwError;
+
+    UNREFERENCED_PARAMETER(argc);
+    UNREFERENCED_PARAMETER(argv);
+
+    DPRINT("ServiceMain() called\n");
+
+    ServiceStatusHandle = RegisterServiceCtrlHandlerExW(ServiceName,
+                                                        ServiceControlHandler,
+                                                        NULL);
+    if (!ServiceStatusHandle)
+    {
+        dwError = GetLastError();
+        DPRINT1("RegisterServiceCtrlHandlerW() failed! (Error %lu)\n",
dwError);
+        return;
+    }
+
+    UpdateServiceStatus(SERVICE_START_PENDING);
+
+    dwError = ServiceInit();
+    if (dwError != ERROR_SUCCESS)
+    {
+        DPRINT("Service stopped (dwError: %lu\n", dwError);
+        UpdateServiceStatus(SERVICE_START_PENDING);
+    }
+    else
+    {
+        DPRINT("Service started\n");
+        UpdateServiceStatus(SERVICE_RUNNING);
+    }
+
+    DPRINT("ServiceMain() done\n");
+}
+
+
+
+
+void fill(MixerEngine * mixer)
+{
+	DWORD Length;
+	UINT i = 0;
+	mixer->mastervolume = 1000;
+	mixer->masterchannels=2;
+	mixer->masterfreq=48000;
+	mixer->masterbitspersample=16;
+	mixer->masterchannelmask = KSAUDIO_SPEAKER_STEREO;
+	Length = mixer->masterfreq * mixer->masterchannels * mixer->masterbitspersample
/ 8;
+	mixer->masterbuf = (PSHORT)HeapAlloc(GetProcessHeap(), 0, Length);
+    while (i < Length / 2)
+    {
+        mixer->masterbuf[i] = 0x7FFF * sin(0.5 * (i - 1) * 500 * _2pi / 48000);
+        i++;
+        mixer->masterbuf[i] = 0x7FFF * sin(0.5 * (i - 2) * 500 * _2pi / 48000);
+        i++;
+    }
+}
+
+void initdevice(MixerEngine * mixer)
+{
+	SP_DEVICE_INTERFACE_DATA InterfaceData;
+    SP_DEVINFO_DATA DeviceData;
+    PSP_DEVICE_INTERFACE_DETAIL_DATA DetailData;
+    HDEVINFO DeviceHandle;
+    PKSDATAFORMAT DataFormat;
+    PWAVEFORMATEXTENSIBLE WaveFormat;
+    PKSPIN_CONNECT PinConnect;
+    KSSTATE State;
+    DWORD Length;
+    BOOL Result;
+    NTSTATUS Status;
+
+    //
+    // Get a handle to KS Audio Interfaces
+    //
+    DeviceHandle = SetupDiGetClassDevs(&CategoryGuid,
+                                       NULL,
+                                       NULL,
+                                       DIGCF_DEVICEINTERFACE |DIGCF_PRESENT);
+
+   printf("DeviceHandle %p\n", DeviceHandle);
+
+    //
+    // Enumerate the first interface
+    //
+    InterfaceData.cbSize = sizeof(InterfaceData);
+    InterfaceData.Reserved = 0;
+    Result = SetupDiEnumDeviceInterfaces(DeviceHandle,
+                                NULL,
+                                &CategoryGuid,
+                                1,
+                                &InterfaceData);
+
+   printf("SetupDiEnumDeviceInterfaces %u Error %ld\n", Result,
GetLastError());
+
+    //
+    // Get the interface details (namely the device path)
+    //
+    Length = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA) + MAX_PATH * sizeof(WCHAR);
+    DetailData = (PSP_DEVICE_INTERFACE_DETAIL_DATA)HeapAlloc(GetProcessHeap(),
+                                                             HEAP_ZERO_MEMORY,
+                                                             Length);
+    DetailData->cbSize = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA);
+    DeviceData.cbSize = sizeof(DeviceData);
+    DeviceData.Reserved = 0;
+    Result = SetupDiGetDeviceInterfaceDetail(DeviceHandle,
+                                    &InterfaceData,
+                                    DetailData,
+                                    Length,
+                                    NULL,
+                                    &DeviceData);
+
+    wprintf(L"SetupDiGetDeviceInterfaceDetail %u Path DetailData %s\n", Result,
(LPWSTR)&DetailData->DevicePath[0]);
+
+    //
+    // Open a handle to the device
+    //
+    mixer->FilterHandle = CreateFile(DetailData->DevicePath,
+                              GENERIC_READ | GENERIC_WRITE,
+                              0,
+                              NULL,
+                              OPEN_EXISTING,
+                              FILE_ATTRIBUTE_NORMAL,
+                              NULL);
+
+    printf("Handle %p\n", mixer->FilterHandle);
+
+    //
+    // Close the interface handle and clean up
+    //
+    //SetupDiDestroyDeviceInfoList(DeviceHandle);
+
+    //
+    // Allocate a KS Pin Connection Request Structure
+    //
+    Length = sizeof(KSPIN_CONNECT) + sizeof(KSDATAFORMAT_WAVEFORMATEX) +
sizeof(WAVEFORMATEXTENSIBLE)-sizeof(WAVEFORMATEX);
+    PinConnect = (PKSPIN_CONNECT)HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, Length);
+    DataFormat = (PKSDATAFORMAT)(PinConnect + 1);
+    WaveFormat = (PWAVEFORMATEXTENSIBLE)(DataFormat + 1);
+
+    //
+    // Setup the KS Pin Data
+    //
+
+    PinConnect->Interface.Set = KSINTERFACESETID_Standard;
+    PinConnect->Interface.Id = KSINTERFACE_STANDARD_STREAMING;
+    PinConnect->Interface.Flags = 0;
+    PinConnect->Medium.Set = KSMEDIUMSETID_Standard;
+    PinConnect->Medium.Id = KSMEDIUM_TYPE_ANYINSTANCE;
+    PinConnect->Medium.Flags = 0;
+    PinConnect->PinId = 0;
+    PinConnect->PinToHandle = NULL;
+    PinConnect->Priority.PriorityClass = KSPRIORITY_NORMAL;
+    PinConnect->Priority.PrioritySubClass = 1;
+
+    //
+    // Setup the KS Data Format Information
+    //
+    printf("DataFormat %p %p\n", DataFormat,(PVOID)((((ULONG_PTR)DataFormat +
7)) & ~7));
+
+    DataFormat->Flags = 0;
+    DataFormat->Reserved = 0;
+    DataFormat->MajorFormat = KSDATAFORMAT_TYPE_AUDIO;
+    DataFormat->SubFormat = KSDATAFORMAT_SUBTYPE_PCM;
+    DataFormat->Specifier = KSDATAFORMAT_SPECIFIER_WAVEFORMATEX;
+    DataFormat->SampleSize = mixer->masterchannels * mixer->masterbitspersample
/ 8;
+    DataFormat->FormatSize = sizeof(KSDATAFORMAT) + sizeof(WAVEFORMATEXTENSIBLE);
+
+    WaveFormat->Format.wFormatTag = WAVE_FORMAT_EXTENSIBLE;
+	WaveFormat->Format.nChannels = mixer->masterchannels;
+    WaveFormat->Format.nSamplesPerSec = mixer->masterfreq;
+    WaveFormat->Format.nBlockAlign = (mixer->masterchannels *
mixer->masterbitspersample)/8;;
+    WaveFormat->Format.nAvgBytesPerSec = WaveFormat->Format.nSamplesPerSec *
WaveFormat->Format.nBlockAlign;
+    WaveFormat->Format.wBitsPerSample = mixer->masterbitspersample;
+    WaveFormat->Format.cbSize = sizeof(WAVEFORMATEXTENSIBLE) - sizeof(WAVEFORMATEX);
+	WaveFormat->dwChannelMask = mixer->masterchannelmask;
+    WaveFormat->Samples.wValidBitsPerSample = mixer->masterbitspersample;
+    WaveFormat->SubFormat = KSDATAFORMAT_SUBTYPE_PCM;
+
+    printf("Creating pin\n");
+
+	//
+    // Create the pin
+    //
+    Status = KsCreatePin(mixer->FilterHandle, PinConnect, GENERIC_READ|GENERIC_WRITE,
&(mixer->PinHandle));
+
+    printf("PinHandle %p Status %lx\n", mixer->PinHandle, Status);
+
+
+    Length = mixer->masterfreq * mixer->masterchannels *
mixer->masterbitspersample / 8;
+    //
+    // Create and fill out the KS Stream Packet
+    //
+    mixer->Packet = (PKSSTREAM_HEADER)HeapAlloc(GetProcessHeap(),
+                                         HEAP_ZERO_MEMORY,
+                                         sizeof(KSSTREAM_HEADER));
+	mixer->Packet->Data = mixer->masterbuf;
+    mixer->Packet->FrameExtent = Length;
+    mixer->Packet->DataUsed = Length;
+    mixer->Packet->Size = sizeof(KSSTREAM_HEADER);
+    mixer->Packet->PresentationTime.Numerator = 1;
+    mixer->Packet->PresentationTime.Denominator = 1;
+
+    //
+    // Setup a KS Property to change the state
+    //
+    mixer->Property = (PKSPROPERTY)HeapAlloc(GetProcessHeap(), 0,
sizeof(KSPROPERTY));
+    mixer->Property->Set = KSPROPSETID_Connection;
+    mixer->Property->Id = KSPROPERTY_CONNECTION_STATE;
+    mixer->Property->Flags = KSPROPERTY_TYPE_SET;
+
+    //
+    // Change the state to run
+    //
+    State = KSSTATE_RUN;
+    DeviceIoControl(mixer->PinHandle,
+                    IOCTL_KS_PROPERTY,
+                    mixer->Property,
+                    sizeof(KSPROPERTY),
+                    &State,
+                    sizeof(State),
+                    &Length,
+                    NULL);
+}
+void playbuffer(MixerEngine * mixer)
+{
+    DWORD Length = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA) + MAX_PATH * sizeof(WCHAR);
+    //
+    // Play our 1-second buffer
+    //
+
+    DeviceIoControl(mixer->PinHandle,
+                    IOCTL_KS_WRITE_STREAM,
+                    NULL,
+                    0,
+                    mixer->Packet,
+                    mixer->Packet->Size,
+                    &Length,
+                    NULL);
+
+}
+void closedevice(MixerEngine * mixer)
+{
+    KSSTATE State;
+	DWORD Length = sizeof(SP_DEVICE_INTERFACE_DETAIL_DATA) + MAX_PATH * sizeof(WCHAR);
+    //
+    // Change the state to stop
+    //
+    State = KSSTATE_STOP;
+    DeviceIoControl(mixer->PinHandle,
+                    IOCTL_KS_PROPERTY,
+                    mixer->Property,
+                    sizeof(KSPROPERTY),
+                    &State,
+                    sizeof(State),
+                    &Length,
+                    NULL);
+
+    CloseHandle(mixer->PinHandle);
+    CloseHandle(mixer->FilterHandle);
+
+}
+DWORD WINAPI RunMixerThread(LPVOID param)
+{
+	MixerEngine * mixer = (MixerEngine *) param;
+	SetEvent(mixer->EventPool[0]);
+	while(1)
+	{
+	while(WaitForSingleObject(mixer->EventPool[0],100)!=0){if(mixer->dead)goto DEAD;}
+	fill(mixer);
+	SetEvent(mixer->EventPool[1]);
+	}
+DEAD:
+	printf("\nMixer Thread Ended\n");
+	return 0;
+}
+DWORD WINAPI RunPlayerThread(LPVOID param)
+{
+	MixerEngine * mixer = (MixerEngine *) param;
+	while(1)
+	{
+		while(WaitForSingleObject(mixer->EventPool[1],100)!=0){if(mixer->dead)goto
DEAD;}
+	initdevice(mixer);
+		playbuffer(mixer);
+	closedevice(mixer);
+		SetEvent(mixer->EventPool[0]);
+	}
+
+DEAD:
+	printf("\nPlayer Thread Ended\n");
+	return 0;
+}
+void SpawnMixerThread(MixerEngine * mixer)
+{
+	DWORD dwID;
+	mixer->mixerthread=CreateThread(NULL,0,RunMixerThread,pengine,0,&dwID);
+}
+void SpawnPlayerThread(MixerEngine * mixer)
+{
+	DWORD dwID;
+	mixer->playerthread=CreateThread(NULL,0,RunPlayerThread,pengine,0,&dwID);
+}
+void SpawnRPCThread(MixerEngine * mixer)
+{
+	DWORD dwID;
+	mixer->rpcthread=CreateThread(NULL,0,RunRPCThread,pengine,0,&dwID);
+}
+void ShutdownRPC(void)
+{
+    RPC_STATUS status;
+ 
+    status = RpcMgmtStopServerListening(NULL);
+ 
+    if (status) 
+    {
+       exit(status);
+    }
+ 
+    status = RpcServerUnregisterIf(NULL, NULL, FALSE);
+ 
+    if (status) 
+    {
+       exit(status);
+    }
+}
+static BOOL WINAPI close ( DWORD dwCtrlType )
+{
+	pengine->dead=1;
+	WaitForSingleObject(pengine->mixerthread,INFINITE);
+	WaitForSingleObject(pengine->playerthread,INFINITE);
+	ShutdownRPC();
+	WaitForSingleObject(pengine->rpcthread,INFINITE);
+
+	CloseHandle(pengine->mixerthread);
+	CloseHandle(pengine->playerthread);
+	CloseHandle(pengine->rpcthread);
+	return TRUE;
+}
+
+INT wmain(int argc, char *argv[])
+{
+    INT RetCode = 0;
+/*For Temporary Debug purpose, If there is any argument it acts as simple command line
app,otherwise it is a NTSERVICE*/
+if(argc==1)
+{
+printf("Under Construction.Please User audsrv.exe -n to start as normal command line
application.\n");
+    MyHeap = HeapCreate(0, 1024 * 256, 0);
+
+    if (!MyHeap)
+    {
+        DPRINT1("FATAL ERROR, can't create heap.\n");
+        RetCode = 1;
+        goto err;
+    }
+
+    StartServiceCtrlDispatcher(ServiceTable);
+}
+else
+{
+	pengine=&engine;
+
+	/*Later these will be loaded from a Conf file*/
+	pengine->mastervolume=1000;
+	pengine->mute=FALSE;
+
+	pengine->dead=0;
+	pengine->EventPool[0]=CreateEvent(NULL,FALSE,FALSE,NULL);
+	pengine->EventPool[1]=CreateEvent(NULL,FALSE,FALSE,NULL);
+	SetConsoleCtrlHandler(close,TRUE);
+	SpawnMixerThread(pengine);
+	SpawnPlayerThread(pengine);
+	SpawnRPCThread(pengine);
+	WaitForSingleObject(pengine->mixerthread,INFINITE);
+	WaitForSingleObject(pengine->playerthread,INFINITE);
+	WaitForSingleObject(pengine->rpcthread,INFINITE);
+}
+  err:
+CloseHandle(pengine->mixerthread);
+CloseHandle(pengine->playerthread);
+CloseHandle(pengine->rpcthread);
+    if (MyHeap)
+        HeapDestroy(MyHeap);
+
+    return RetCode;
+}
+static DWORD
+ServiceInit(VOID)
+{
+	pengine=&engine;
+
+	/*Later these will be loaded from a Conf file*/
+	pengine->mastervolume=1000;
+	pengine->mute=FALSE;
+
+	pengine->dead=0;
+	pengine->EventPool[0]=CreateEvent(NULL,FALSE,FALSE,NULL);
+	pengine->EventPool[1]=CreateEvent(NULL,FALSE,FALSE,NULL);
+	SetConsoleCtrlHandler(close,TRUE);
+	SpawnMixerThread(pengine);
+	SpawnPlayerThread(pengine);
+	SpawnRPCThread(pengine);
+
+    return ERROR_SUCCESS;
+}

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
------------------------------------------------------------------------------
    evn:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
------------------------------------------------------------------------------
    evn:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
------------------------------------------------------------------------------
    sv:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
------------------------------------------------------------------------------
    sv:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.c
------------------------------------------------------------------------------
    svn:eol-style = native

Added: 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 (added)
+++ branches/nyadav-audio-branch/base/services/audsrv/audsrv.h [iso-8859-1] Fri May 27
09:48:26 2011
@@ -1,0 +1,71 @@
+/*
+ * PROJECT:          ReactOS kernel
+ * LICENSE:          GPL - See COPYING in the top level directory
+ * FILE:             services/audsrv/audsrv.h
+ * PURPOSE:          Event logging service
+ * COPYRIGHT:        Copyright 2011 Pankaj Yadav
+ */
+
+#ifndef __AUDSRV_H__
+#define __AUDSRV_H__
+
+#define NDEBUG
+#define WIN32_NO_STATUS
+
+#include <windows.h>
+#include <wincon.h>
+#include <memory.h>
+#include <mmsystem.h>
+#include <stdio.h>
+#include <math.h>
+#include <setupapi.h>
+#include <ndk/ntndk.h>
+#include <ks.h>
+#include <ksmedia.h>
+#include <ks.h>
+#include <debug.h>
+#include "audsrvrpc_s.h"
+
+
+typedef struct PortStream
+{
+	int volume;
+	LONG freq;
+	int bitspersample;
+	int channels;
+	ULONG channelmask;
+	HANDLE thread;
+	struct PortStream * next;
+} PortStream;
+
+typedef struct MixerEngine
+{
+/*Should be Initialized at Server Start*/
+	char dead;
+	HANDLE EventPool[2];//0=Played,1=Ready
+	HANDLE mixerthread;
+	HANDLE playerthread;
+	HANDLE rpcthread;
+/*Should be Initialized at Server Start from configuration file,Currently there is no
configuration file so initialized to a fixed value at start*/
+	int mastervolume;
+	BOOL mute;
+/*Should be Initialized before playing First Stream*/
+	long masterfreq;
+	int masterchannels;
+	unsigned long masterchannelmask;
+	int masterbitspersample;
+	PSHORT masterbuf;
+/*Currently don't know the future of following variables*/
+	HANDLE FilterHandle;
+    HANDLE PinHandle;
+	PKSPROPERTY Property;
+	PKSSTREAM_HEADER Packet;
+} MixerEngine;
+
+extern MixerEngine engine;
+
+/* rpc.c */
+DWORD WINAPI RunRPCThread(LPVOID lpParameter);
+/********************************/
+
+#endif  /* __AUDSRV_H__ */

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
------------------------------------------------------------------------------
    evn:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
------------------------------------------------------------------------------
    evn:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
------------------------------------------------------------------------------
    sv:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
------------------------------------------------------------------------------
    sv:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc (added)
+++ branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc [iso-8859-1] Fri May 27
09:48:26 2011
@@ -1,0 +1,4 @@
+#define REACTOS_STR_FILE_DESCRIPTION	"Audio Server\0"
+#define REACTOS_STR_INTERNAL_NAME	"Audsrv\0"
+#define REACTOS_STR_ORIGINAL_FILENAME	"Audsrv.exe\0"
+#include <reactos/version.rc>

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
------------------------------------------------------------------------------
    evn:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
------------------------------------------------------------------------------
    evn:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
------------------------------------------------------------------------------
    sv:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
------------------------------------------------------------------------------
    sv:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/audsrv.rc
------------------------------------------------------------------------------
    svn:eol-style = native

Added: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
URL:
http://svn.reactos.org/svn/reactos/branches/nyadav-audio-branch/base/servic…
==============================================================================
--- branches/nyadav-audio-branch/base/services/audsrv/rpc.c (added)
+++ branches/nyadav-audio-branch/base/services/audsrv/rpc.c [iso-8859-1] Fri May 27
09:48:26 2011
@@ -1,0 +1,69 @@
+/*
+ * PROJECT:          ReactOS kernel
+ * LICENSE:          GPL - See COPYING in the top level directory
+ * FILE:             services/audsrv/rpc.c
+ * PURPOSE:          Audio Server
+ * COPYRIGHT:        Copyright 2011 Pankaj Yadav
+  */
+
+/* INCLUDES *****************************************************************/
+
+#include "audsrv.h"
+
+LIST_ENTRY LogHandleListHead;
+
+/* FUNCTIONS ****************************************************************/
+
+DWORD WINAPI RunRPCThread(LPVOID lpParameter)
+{
+    RPC_STATUS Status;
+
+    InitializeListHead(&LogHandleListHead);
+printf("reached\n");
+    Status = RpcServerUseProtseqEpW(L"ncacn_np", 20,
L"\\pipe\\EventLog", NULL);
+    if (Status != RPC_S_OK)
+    {
+        DPRINT("RpcServerUseProtseqEpW() failed (Status %lx)\n", Status);
+        return 0;
+    }
+
+    Status = RpcServerRegisterIf(audsrv_v0_0_s_ifspec, NULL, NULL);
+    if (Status != RPC_S_OK)
+    {
+        DPRINT("RpcServerRegisterIf() failed (Status %lx)\n", Status);
+        return 0;
+    }
+
+    Status = RpcServerListen(1, RPC_C_LISTEN_MAX_CALLS_DEFAULT, FALSE);
+    if (Status != RPC_S_OK)
+    {
+        DPRINT("RpcServerListen() failed (Status %lx)\n", Status);
+    }
+
+    return 0;
+}
+
+
+/*************************RPC Functions**********************************/
+
+NTSTATUS AUDInitStream(	AUDSRV_HANDLE *streamthread)
+{
+    UNIMPLEMENTED;/*Coolest Macro I have ever seen*/
+    return STATUS_NOT_IMPLEMENTED;
+}
+/*************************************************************************/
+void __RPC_FAR *__RPC_USER midl_user_allocate(SIZE_T len)
+{
+    return HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, len);
+}
+
+
+void __RPC_USER midl_user_free(void __RPC_FAR * ptr)
+{
+    HeapFree(GetProcessHeap(), 0, ptr);
+}
+
+
+void __RPC_USER IELF_HANDLE_rundown(AUDSRV_HANDLE LogHandle)
+{
+}

Propchange: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
------------------------------------------------------------------------------
    evn:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
------------------------------------------------------------------------------
    evn:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
------------------------------------------------------------------------------
    sv:eol-style = native

Propchange: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
------------------------------------------------------------------------------
    sv:mime-type = text/plain

Propchange: branches/nyadav-audio-branch/base/services/audsrv/rpc.c
------------------------------------------------------------------------------
    svn:eol-style = native