service_group.cpp File Reference

#include "private.hpp"
#include <debug.h>

Include dependency graph for service_group.cpp:

Go to the source code of this file.

Classes
struct	GROUP_ENTRY
class	CServiceGroup

Macros
#define	NDEBUG

Typedefs
typedef struct GROUP_ENTRY *	PGROUP_ENTRY

Functions
VOID NTAPI	IServiceGroupDpc (IN struct _KDPC *Dpc, IN PVOID DeferredContext, IN PVOID SystemArgument1, IN PVOID SystemArgument2)
NTSTATUS NTAPI	PcNewServiceGroup (OUT PSERVICEGROUP *OutServiceGroup, IN PUNKNOWN OuterUnknown OPTIONAL)

Macro Definition Documentation

NDEBUG

#define NDEBUG

Definition at line 11 of file service_group.cpp.

Typedef Documentation

PGROUP_ENTRY

typedef struct GROUP_ENTRY * PGROUP_ENTRY

Function Documentation

IServiceGroupDpc()

VOID NTAPI IServiceGroupDpc	(	IN struct _KDPC *	Dpc,
		IN PVOID	DeferredContext,
		IN PVOID	SystemArgument1,
		IN PVOID	SystemArgument2
	)

Definition at line 226 of file service_group.cpp.

{
    PLIST_ENTRY CurEntry;
    PGROUP_ENTRY Entry;
    CServiceGroup * This = (CServiceGroup*)DeferredContext;
 
    // acquire service group list lock
    KeAcquireSpinLockAtDpcLevel(&This->m_Lock);
 
    // grab first entry
    CurEntry = This->m_ServiceSinkHead.Flink;
 
    // loop the list and call the attached service sink/group
    while (CurEntry != &This->m_ServiceSinkHead)
    {
        //grab current entry
        Entry = (PGROUP_ENTRY)CONTAINING_RECORD(CurEntry, GROUP_ENTRY, Entry);
 
        // call service sink/group
        Entry->pServiceSink->RequestService();
 
        // move to next entry
        CurEntry = CurEntry->Flink;
    }
 
    // release service group list lock
    KeReleaseSpinLockFromDpcLevel(&This->m_Lock);
}

PcNewServiceGroup()

NTSTATUS NTAPI PcNewServiceGroup	(	OUT PSERVICEGROUP *	OutServiceGroup,
		IN PUNKNOWN OuterUnknown	OPTIONAL
	)

Definition at line 303 of file service_group.cpp.

{
    CServiceGroup * This;
    NTSTATUS Status;
 
    DPRINT("PcNewServiceGroup entered\n");
 
    //FIXME support aggregation
    PC_ASSERT(OuterUnknown == NULL);
 
    // allocate a service group object
    This = new(NonPagedPool, TAG_PORTCLASS)CServiceGroup(OuterUnknown);
 
    if (!This)
    {
        // out of memory
        return STATUS_INSUFFICIENT_RESOURCES;
    }
 
    // request IServiceSink interface
    Status = This->QueryInterface(IID_IServiceSink, (PVOID*)OutServiceGroup);
 
    if (!NT_SUCCESS(Status))
    {
        // failed to acquire service sink interface
        delete This;
        return Status;
    }
 
    // done
    return Status;
}

Referenced by CMiniportWaveStreamCMI::Init(), and CMiniportStream::Init().