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/services/CMakeLists.txt?rev=51955&r1=51954&r2=51955&view=diff
==============================================================================
--- 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/services/audsrv/CMakeLists.txt?rev=51955&view=auto
==============================================================================
--- 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/services/audsrv/audsrv.c?rev=51955&view=auto
==============================================================================
--- 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/services/audsrv/audsrv.h?rev=51955&view=auto
==============================================================================
--- 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/services/audsrv/audsrv.rc?rev=51955&view=auto
==============================================================================
--- 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/services/audsrv/rpc.c?rev=51955&view=auto
==============================================================================
--- 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
