connpt.c File Reference

#include <assert.h>
#include <stdarg.h>
#include <string.h>
#include "winerror.h"
#include "windef.h"
#include "winbase.h"
#include "wingdi.h"
#include "winuser.h"
#include "ole2.h"
#include "olectl.h"
#include "connpt.h"
#include "wine/debug.h"

Include dependency graph for connpt.c:

Go to the source code of this file.

Classes
struct	ConnectionPointImpl
struct	EnumConnectionsImpl

Macros
#define	COBJMACROS
#define	MAXSINKS   10

Typedefs
typedef struct ConnectionPointImpl	ConnectionPointImpl
typedef struct EnumConnectionsImpl	EnumConnectionsImpl

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (ole)
static EnumConnectionsImpl *	EnumConnectionsImpl_Construct (IUnknown *pUnk, DWORD nSinks, CONNECTDATA *pCD)
static ConnectionPointImpl *	impl_from_IConnectionPoint (IConnectionPoint *iface)
static EnumConnectionsImpl *	impl_from_IEnumConnections (IEnumConnections *iface)
static void	ConnectionPointImpl_Destroy (ConnectionPointImpl *Obj)
static HRESULT WINAPI	ConnectionPointImpl_QueryInterface (IConnectionPoint *iface, REFIID riid, void **ppvObject)
static ULONG WINAPI	ConnectionPointImpl_AddRef (IConnectionPoint *iface)
static ULONG WINAPI	ConnectionPointImpl_Release (IConnectionPoint *iface)
static HRESULT WINAPI	ConnectionPointImpl_GetConnectionInterface (IConnectionPoint *iface, IID *piid)
static HRESULT WINAPI	ConnectionPointImpl_GetConnectionPointContainer (IConnectionPoint *iface, IConnectionPointContainer **ppCPC)
static HRESULT WINAPI	ConnectionPointImpl_Advise (IConnectionPoint *iface, IUnknown *lpUnk, DWORD *pdwCookie)
static HRESULT WINAPI	ConnectionPointImpl_Unadvise (IConnectionPoint *iface, DWORD dwCookie)
static HRESULT WINAPI	ConnectionPointImpl_EnumConnections (IConnectionPoint *iface, LPENUMCONNECTIONS *ppEnum)
static void	EnumConnectionsImpl_Destroy (EnumConnectionsImpl *Obj)
static HRESULT WINAPI	EnumConnectionsImpl_QueryInterface (IEnumConnections *iface, REFIID riid, void **ppvObject)
static ULONG WINAPI	EnumConnectionsImpl_AddRef (IEnumConnections *iface)
static ULONG WINAPI	EnumConnectionsImpl_Release (IEnumConnections *iface)
static HRESULT WINAPI	EnumConnectionsImpl_Next (IEnumConnections *iface, ULONG cConn, LPCONNECTDATA pCD, ULONG *pEnum)
static HRESULT WINAPI	EnumConnectionsImpl_Skip (IEnumConnections *iface, ULONG cSkip)
static HRESULT WINAPI	EnumConnectionsImpl_Reset (IEnumConnections *iface)
static HRESULT WINAPI	EnumConnectionsImpl_Clone (IEnumConnections *iface, LPENUMCONNECTIONS *ppEnum)
HRESULT	CreateConnectionPoint (IUnknown *pUnk, REFIID riid, IConnectionPoint **pCP)

Variables
static const IConnectionPointVtbl	ConnectionPointImpl_VTable
static const IEnumConnectionsVtbl	EnumConnectionsImpl_VTable

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 29 of file connpt.c.

MAXSINKS

#define MAXSINKS   10

Definition at line 44 of file connpt.c.

Typedef Documentation

ConnectionPointImpl

typedef struct ConnectionPointImpl ConnectionPointImpl

EnumConnectionsImpl

typedef struct EnumConnectionsImpl EnumConnectionsImpl

Function Documentation

ConnectionPointImpl_AddRef()

static ULONG WINAPI ConnectionPointImpl_AddRef ( IConnectionPoint *  iface )

static

Definition at line 169 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  ULONG refCount = InterlockedIncrement(&This->ref);
 
  TRACE("(%p)->(ref before=%d)\n", This, refCount - 1);
 
  return refCount;
}

ConnectionPointImpl_Advise()

static HRESULT WINAPI ConnectionPointImpl_Advise ( IConnectionPoint *  iface, IUnknown *  lpUnk, DWORD *  pdwCookie  )

static

Definition at line 232 of file connpt.c.

{
  DWORD i;
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  IUnknown *lpSink;
  TRACE("(%p)->(%p, %p)\n", This, lpUnk, pdwCookie);
 
  *pdwCookie = 0;
  if(FAILED(IUnknown_QueryInterface(lpUnk, &This->iid, (void**)&lpSink)))
    return CONNECT_E_CANNOTCONNECT;
 
  for(i = 0; i < This->maxSinks; i++) {
    if(This->sinks[i] == NULL)
      break;
  }
  if(i == This->maxSinks) {
    This->maxSinks += MAXSINKS;
    This->sinks = HeapReAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, This->sinks,
                  This->maxSinks * sizeof(IUnknown *));
  }
  This->sinks[i] = lpSink;
  This->nSinks++;
  *pdwCookie = i + 1;
  return S_OK;
}

ConnectionPointImpl_Destroy()

static void ConnectionPointImpl_Destroy ( ConnectionPointImpl *  Obj )

static

Definition at line 107 of file connpt.c.

{
  DWORD i;
  for(i = 0; i < Obj->maxSinks; i++) {
    if(Obj->sinks[i]) {
      IUnknown_Release(Obj->sinks[i]);
      Obj->sinks[i] = NULL;
    }
  }
  HeapFree(GetProcessHeap(), 0, Obj->sinks);
  HeapFree(GetProcessHeap(), 0, Obj);
  return;
}

Referenced by ConnectionPointImpl_Release().

ConnectionPointImpl_EnumConnections()

static HRESULT WINAPI ConnectionPointImpl_EnumConnections ( IConnectionPoint *  iface, LPENUMCONNECTIONS *  ppEnum  )

static

Definition at line 285 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  CONNECTDATA *pCD;
  DWORD i, nextslot;
  EnumConnectionsImpl *EnumObj;
  HRESULT hr;
 
  TRACE("(%p)->(%p)\n", This, ppEnum);
 
  *ppEnum = NULL;
 
  if(This->nSinks == 0) return OLE_E_NOCONNECTION;
 
  pCD = HeapAlloc(GetProcessHeap(), 0, sizeof(CONNECTDATA) * This->nSinks);
 
  for(i = 0, nextslot = 0; i < This->maxSinks; i++) {
    if(This->sinks[i] != NULL) {
      pCD[nextslot].pUnk = This->sinks[i];
      pCD[nextslot].dwCookie = i + 1;
      nextslot++;
    }
  }
  assert(nextslot == This->nSinks);
 
  /* Bump the ref count of this object up by one.  It gets Released in
     IEnumConnections_Release */
  IConnectionPoint_AddRef(iface);
 
  EnumObj = EnumConnectionsImpl_Construct((IUnknown*)iface, This->nSinks, pCD);
  hr = IEnumConnections_QueryInterface(&EnumObj->IEnumConnections_iface,
                                       &IID_IEnumConnections, (void**)ppEnum);
  IEnumConnections_Release(&EnumObj->IEnumConnections_iface);
 
  HeapFree(GetProcessHeap(), 0, pCD);
  return hr;
}

ConnectionPointImpl_GetConnectionInterface()

static HRESULT WINAPI ConnectionPointImpl_GetConnectionInterface ( IConnectionPoint *  iface, IID *  piid  )

static

Definition at line 204 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  TRACE("(%p)->(%p) returning %s\n", This, piid, debugstr_guid(&(This->iid)));
  *piid = This->iid;
  return S_OK;
}

ConnectionPointImpl_GetConnectionPointContainer()

static HRESULT WINAPI ConnectionPointImpl_GetConnectionPointContainer ( IConnectionPoint *  iface, IConnectionPointContainer **  ppCPC  )

static

Definition at line 218 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  TRACE("(%p)->(%p)\n", This, ppCPC);
 
  return IUnknown_QueryInterface(This->Obj, &IID_IConnectionPointContainer, (void**)ppCPC);
}

ConnectionPointImpl_QueryInterface()

static HRESULT WINAPI ConnectionPointImpl_QueryInterface ( IConnectionPoint *  iface, REFIID  riid, void **  ppvObject  )

static

Definition at line 126 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), ppvObject);
 
  /*
   * Perform a sanity check on the parameters.
   */
  if (!ppvObject)
    return E_INVALIDARG;
 
  /*
   * Initialize the return parameter.
   */
  *ppvObject = 0;
 
 
  if (IsEqualIID(&IID_IConnectionPoint, riid) || IsEqualIID(&IID_IUnknown, riid))
    *ppvObject = iface;
 
  /*
   * Check that we obtained an interface.
   */
  if ((*ppvObject)==0)
  {
    FIXME("() : asking for unsupported interface %s\n", debugstr_guid(riid));
    return E_NOINTERFACE;
  }
 
  IUnknown_AddRef((IUnknown*)*ppvObject);
 
  return S_OK;
}

ConnectionPointImpl_Release()

static ULONG WINAPI ConnectionPointImpl_Release ( IConnectionPoint *  iface )

static

Definition at line 184 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  ULONG refCount = InterlockedDecrement(&This->ref);
 
  TRACE("(%p)->(ref before=%d)\n", This, refCount + 1);
 
  /*
   * If the reference count goes down to 0, perform suicide.
   */
  if (!refCount) ConnectionPointImpl_Destroy(This);
 
  return refCount;
}

ConnectionPointImpl_Unadvise()

static HRESULT WINAPI ConnectionPointImpl_Unadvise ( IConnectionPoint *  iface, DWORD  dwCookie  )

static

Definition at line 265 of file connpt.c.

{
  ConnectionPointImpl *This = impl_from_IConnectionPoint(iface);
  TRACE("(%p)->(%d)\n", This, dwCookie);
 
  if(dwCookie == 0 || dwCookie > This->maxSinks) return E_INVALIDARG;
 
  if(This->sinks[dwCookie-1] == NULL) return CONNECT_E_NOCONNECTION;
 
  IUnknown_Release(This->sinks[dwCookie-1]);
  This->sinks[dwCookie-1] = NULL;
  This->nSinks--;
  return S_OK;
}

CreateConnectionPoint()

HRESULT CreateConnectionPoint	(	IUnknown *	pUnk,
		REFIID	riid,
		IConnectionPoint **	pCP
	)

Definition at line 572 of file connpt.c.

{
  ConnectionPointImpl *Obj;
 
  TRACE("(%p %s %p)\n", pUnk, debugstr_guid(riid), pCP);
 
  *pCP = NULL;
  Obj = HeapAlloc(GetProcessHeap(), 0, sizeof(*Obj));
  if (!Obj)
    return E_OUTOFMEMORY;
 
  Obj->IConnectionPoint_iface.lpVtbl = &ConnectionPointImpl_VTable;
  Obj->Obj = pUnk;
  Obj->ref = 1;
  Obj->iid = *riid;
  Obj->maxSinks = MAXSINKS;
  Obj->sinks = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(IUnknown*) * MAXSINKS);
  Obj->nSinks = 0;
 
  *pCP = &Obj->IConnectionPoint_iface;
  return S_OK;
}

Referenced by OLEFontImpl_Clone(), OLEFontImpl_Construct(), and OLEPictureImpl_Construct().

EnumConnectionsImpl_AddRef()

static ULONG WINAPI EnumConnectionsImpl_AddRef ( IEnumConnections *  iface )

static

Definition at line 426 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  ULONG refCount = InterlockedIncrement(&This->ref);
 
  TRACE("(%p)->(ref before=%d)\n", This, refCount - 1);
 
  IUnknown_AddRef(This->pUnk);
  return refCount;
}

EnumConnectionsImpl_Clone()

static HRESULT WINAPI EnumConnectionsImpl_Clone ( IEnumConnections *  iface, LPENUMCONNECTIONS *  ppEnum  )

static

Definition at line 533 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  EnumConnectionsImpl *newObj;
  TRACE("(%p)->(%p)\n", This, ppEnum);
 
  newObj = EnumConnectionsImpl_Construct(This->pUnk, This->nConns, This->pCD);
  newObj->nCur = This->nCur;
  *ppEnum = &newObj->IEnumConnections_iface;
  IUnknown_AddRef(This->pUnk);
  return S_OK;
}

EnumConnectionsImpl_Construct()

static EnumConnectionsImpl * EnumConnectionsImpl_Construct ( IUnknown *  pUnk, DWORD  nSinks, CONNECTDATA *  pCD  )

static

Definition at line 343 of file connpt.c.

{
  EnumConnectionsImpl *Obj = HeapAlloc(GetProcessHeap(), 0, sizeof(*Obj));
  DWORD i;
 
  Obj->IEnumConnections_iface.lpVtbl = &EnumConnectionsImpl_VTable;
  Obj->ref = 1;
  Obj->pUnk = pUnk;
  Obj->pCD = HeapAlloc(GetProcessHeap(), 0, nSinks * sizeof(CONNECTDATA));
  Obj->nConns = nSinks;
  Obj->nCur = 0;
 
  for(i = 0; i < nSinks; i++) {
    Obj->pCD[i] = pCD[i];
    IUnknown_AddRef(Obj->pCD[i].pUnk);
  }
  return Obj;
}

Referenced by ConnectionPointImpl_EnumConnections(), and EnumConnectionsImpl_Clone().

EnumConnectionsImpl_Destroy()

static void EnumConnectionsImpl_Destroy ( EnumConnectionsImpl *  Obj )

static

Definition at line 367 of file connpt.c.

{
  DWORD i;
 
  for(i = 0; i < Obj->nConns; i++)
    IUnknown_Release(Obj->pCD[i].pUnk);
 
  HeapFree(GetProcessHeap(), 0, Obj->pCD);
  HeapFree(GetProcessHeap(), 0, Obj);
  return;
}

Referenced by EnumConnectionsImpl_Release().

EnumConnectionsImpl_Next()

static HRESULT WINAPI EnumConnectionsImpl_Next ( IEnumConnections *  iface, ULONG  cConn, LPCONNECTDATA  pCD, ULONG *  pEnum  )

static

Definition at line 463 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  DWORD nRet = 0;
  TRACE("(%p)->(%d, %p, %p)\n", This, cConn, pCD, pEnum);
 
  if(pEnum == NULL) {
    if(cConn != 1)
      return E_POINTER;
  } else
    *pEnum = 0;
 
  if(This->nCur >= This->nConns)
    return S_FALSE;
 
  while(This->nCur < This->nConns && cConn) {
    *pCD++ = This->pCD[This->nCur];
    IUnknown_AddRef(This->pCD[This->nCur].pUnk);
    This->nCur++;
    cConn--;
    nRet++;
  }
 
  if(pEnum)
    *pEnum = nRet;
 
  return S_OK;
}

EnumConnectionsImpl_QueryInterface()

static HRESULT WINAPI EnumConnectionsImpl_QueryInterface ( IEnumConnections *  iface, REFIID  riid, void **  ppvObject  )

static

Definition at line 384 of file connpt.c.

{
  ConnectionPointImpl *This = (ConnectionPointImpl *)iface;
  TRACE("(%p)->(%s, %p)\n", This, debugstr_guid(riid), ppvObject);
 
  /*
   * Perform a sanity check on the parameters.
   */
  if (!ppvObject)
    return E_INVALIDARG;
 
  /*
   * Initialize the return parameter.
   */
  *ppvObject = 0;
 
  if (IsEqualIID(&IID_IEnumConnections, riid) || IsEqualIID(&IID_IUnknown, riid))
    *ppvObject = iface;
 
  /*
   * Check that we obtained an interface.
   */
  if ((*ppvObject)==0)
  {
    FIXME("() : asking for unsupported interface %s\n", debugstr_guid(riid));
    return E_NOINTERFACE;
  }
 
  IUnknown_AddRef((IUnknown*)*ppvObject);
 
  return S_OK;
}

EnumConnectionsImpl_Release()

static ULONG WINAPI EnumConnectionsImpl_Release ( IEnumConnections *  iface )

static

Definition at line 442 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  ULONG refCount = InterlockedDecrement(&This->ref);
 
  TRACE("(%p)->(ref before=%d)\n", This, refCount + 1);
 
  IUnknown_Release(This->pUnk);
 
  /*
   * If the reference count goes down to 0, perform suicide.
   */
  if (!refCount) EnumConnectionsImpl_Destroy(This);
 
  return refCount;
}

EnumConnectionsImpl_Reset()

static HRESULT WINAPI EnumConnectionsImpl_Reset ( IEnumConnections *  iface )

static

Definition at line 518 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  TRACE("(%p)\n", This);
 
  This->nCur = 0;
 
  return S_OK;
}

EnumConnectionsImpl_Skip()

static HRESULT WINAPI EnumConnectionsImpl_Skip ( IEnumConnections *  iface, ULONG  cSkip  )

static

Definition at line 499 of file connpt.c.

{
  EnumConnectionsImpl *This = impl_from_IEnumConnections(iface);
  TRACE("(%p)->(%d)\n", This, cSkip);
 
  if(This->nCur + cSkip >= This->nConns)
    return S_FALSE;
 
  This->nCur += cSkip;
 
  return S_OK;
}

impl_from_IConnectionPoint()

static ConnectionPointImpl * impl_from_IConnectionPoint ( IConnectionPoint *  iface )

inlinestatic

Definition at line 94 of file connpt.c.

{
  return CONTAINING_RECORD(iface, ConnectionPointImpl, IConnectionPoint_iface);
}

Referenced by ConnectionPointImpl_AddRef(), ConnectionPointImpl_Advise(), ConnectionPointImpl_EnumConnections(), ConnectionPointImpl_GetConnectionInterface(), ConnectionPointImpl_GetConnectionPointContainer(), ConnectionPointImpl_QueryInterface(), ConnectionPointImpl_Release(), and ConnectionPointImpl_Unadvise().

impl_from_IEnumConnections()

static EnumConnectionsImpl * impl_from_IEnumConnections ( IEnumConnections *  iface )

inlinestatic

Definition at line 99 of file connpt.c.

{
  return CONTAINING_RECORD(iface, EnumConnectionsImpl, IEnumConnections_iface);
}

Referenced by EnumConnectionsImpl_AddRef(), EnumConnectionsImpl_Clone(), EnumConnectionsImpl_Next(), EnumConnectionsImpl_Release(), EnumConnectionsImpl_Reset(), and EnumConnectionsImpl_Skip().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

ole

)

Variable Documentation

ConnectionPointImpl_VTable

const IConnectionPointVtbl ConnectionPointImpl_VTable

static

Initial value:

=
{
  ConnectionPointImpl_QueryInterface,
  ConnectionPointImpl_AddRef,
  ConnectionPointImpl_Release,
  ConnectionPointImpl_GetConnectionInterface,
  ConnectionPointImpl_GetConnectionPointContainer,
  ConnectionPointImpl_Advise,
  ConnectionPointImpl_Unadvise,
  ConnectionPointImpl_EnumConnections
}

Definition at line 325 of file connpt.c.

Referenced by CreateConnectionPoint().

EnumConnectionsImpl_VTable

static const IEnumConnectionsVtbl EnumConnectionsImpl_VTable

static

Initial value:

=
{
  EnumConnectionsImpl_QueryInterface,
  EnumConnectionsImpl_AddRef,
  EnumConnectionsImpl_Release,
  EnumConnectionsImpl_Next,
  EnumConnectionsImpl_Skip,
  EnumConnectionsImpl_Reset,
  EnumConnectionsImpl_Clone
}

Definition at line 338 of file connpt.c.

Referenced by EnumConnectionsImpl_Construct().