1/**
 2 * This file has no copyright assigned and is placed in the Public Domain.
 3 * This file is part of the mingw-w64 runtime package.
 4 * No warranty is given; refer to the file DISCLAIMER.PD within this package.
 5 */
 6#ifndef __MSPCALL_H_
 7#define __MSPCALL_H_
 8
 9class ATL_NO_VTABLE CMSPCallBase : public CComObjectRootEx<CComMultiThreadModelNoCS>,public IDispatchImpl<ITStreamControl,&IID_ITStreamControl,&LIBID_TAPI3Lib> {
10public:
11  DECLARE_POLY_AGGREGATABLE(CMSPCallBase)
12  BEGIN_COM_MAP(CMSPCallBase)
13    COM_INTERFACE_ENTRY(IDispatch)
14    COM_INTERFACE_ENTRY(ITStreamControl)
15  END_COM_MAP()
16  DECLARE_GET_CONTROLLING_UNKNOWN()
17  DECLARE_VQI()
18  CMSPCallBase();
19  virtual ~CMSPCallBase();
20  virtual ULONG MSPCallAddRef (void) = 0;
21  virtual ULONG MSPCallRelease (void) = 0;
22  STDMETHOD (CreateStream) (__LONG32 lMediaType,TERMINAL_DIRECTION Direction,ITStream **ppStream);
23  STDMETHOD (EnumerateStreams) (IEnumStream **ppEnumStream);
24  STDMETHOD (RemoveStream) (ITStream *pStream) = 0;
25  STDMETHOD (get_Streams) (VARIANT *pStreams);
26  virtual HRESULT Init(CMSPAddress *pMSPAddress,MSP_HANDLE htCall,DWORD dwReserved,DWORD dwMediaType) = 0;
27  virtual HRESULT ShutDown() = 0;
28  virtual HRESULT ReceiveTSPCallData(PBYTE pBuffer,DWORD dwSize);
29  HRESULT HandleStreamEvent(MSPEVENTITEM *EventItem) const;
30protected:
31  virtual HRESULT InternalCreateStream(DWORD dwMediaType,TERMINAL_DIRECTION Direction,ITStream **ppStream) = 0;
32  virtual HRESULT CreateStreamObject(DWORD dwMediaType,TERMINAL_DIRECTION Direction,IMediaEvent *pGraph,ITStream **ppStream) = 0;
33protected:
34  CMSPAddress *m_pMSPAddress;
35  MSP_HANDLE m_htCall;
36  DWORD m_dwMediaType;
37  CMSPArray <ITStream *> m_Streams;
38  CMSPCritSection m_lock;
39};
40
41class ATL_NO_VTABLE CMSPCallMultiGraph : public CMSPCallBase {
42public:
43  typedef struct {
44    CMSPCallMultiGraph *pMSPCall;
45    ITStream *pITStream;
46    IMediaEvent *pIMediaEvent;
47  } MSPSTREAMCONTEXT,*PMSPSTREAMCONTEXT;
48  typedef struct _THREADPOOLWAITBLOCK {
49    HANDLE hWaitHandle;
50    MSPSTREAMCONTEXT *pContext;
51    WINBOOL operator ==(struct _THREADPOOLWAITBLOCK &t) { return ((hWaitHandle==t.hWaitHandle) && (pContext==t.pContext)); }
52  } THREADPOOLWAITBLOCK,*PTHREADPOOLWAITBLOCK;
53public:
54  CMSPCallMultiGraph();
55  virtual ~CMSPCallMultiGraph();
56  STDMETHOD (RemoveStream) (ITStream *ppStream);
57  HRESULT Init(CMSPAddress *pMSPAddress,MSP_HANDLE htCall,DWORD dwReserved,DWORD dwMediaType);
58  HRESULT ShutDown();
59  static VOID NTAPI DispatchGraphEvent(VOID *pContext,BOOLEAN bFlag);
60  virtual VOID HandleGraphEvent(MSPSTREAMCONTEXT *pContext);
61  virtual HRESULT ProcessGraphEvent(ITStream *pITStream,__LONG32 lEventCode,LONG_PTR lParam1,LONG_PTR lParam2);
62protected:
63  HRESULT RegisterWaitEvent(IMediaEvent *pIMediaEvent,ITStream *pITStream);
64  HRESULT UnregisterWaitEvent(int index);
65  virtual HRESULT InternalCreateStream(DWORD dwMediaType,TERMINAL_DIRECTION Direction,ITStream **ppStream);
66protected:
67  CMSPArray <THREADPOOLWAITBLOCK> m_ThreadPoolWaitBlocks;
68};
69
70struct MULTI_GRAPH_EVENT_DATA {
71  CMSPCallMultiGraph *pCall;
72  ITStream *pITStream;
73  __LONG32 lEventCode;
74  LONG_PTR lParam1;
75  LONG_PTR lParam2;
76  IMediaEvent *pIMediaEvent;
77  MULTI_GRAPH_EVENT_DATA() : pIMediaEvent(NULL),pITStream(NULL),lEventCode(0),lParam1(0),lParam2(0) { }
78};
79
80DWORD WINAPI AsyncMultiGraphEvent(LPVOID pVoid);
81#endif