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/service... ============================================================================== --- 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/service... ============================================================================== --- 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/service... ============================================================================== --- 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/service... ============================================================================== --- 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/service... ============================================================================== --- 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/service... ============================================================================== --- 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
-
nyadav＠svn.reactos.org