ole32 [6/9]: Remove hand-written proxies for IClassFactory and IRemUnknown.
Dan Hipschman
dsh at linux.ucla.edu
Fri Nov 9 18:09:33 CST 2007
The previous patch allows Wine to use widl-generated proxies for unknwn.idl
and dcom.idl, but it didn't remove the existing hand-written proxies since
there's a lot of code that's getting replaced, while the logical changes
going on are fairly small. So this patch just removes everything we don't
need anymore.
---
dlls/ole32/oleproxy.c | 937 -------------------------------------------------
1 files changed, 0 insertions(+), 937 deletions(-)
diff --git a/dlls/ole32/oleproxy.c b/dlls/ole32/oleproxy.c
index ebc5c32..9895641 100644
--- a/dlls/ole32/oleproxy.c
+++ b/dlls/ole32/oleproxy.c
@@ -63,946 +63,9 @@
WINE_DEFAULT_DEBUG_CHANNEL(ole);
-static ULONG WINAPI RURpcProxyBufferImpl_Release(LPRPCPROXYBUFFER iface);
-
-/* From: http://msdn.microsoft.com/library/en-us/com/cmi_m_4lda.asp
- *
- * The first time a client requests a pointer to an interface on a
- * particular object, COM loads an IClassFactory stub in the server
- * process and uses it to marshal the first pointer back to the
- * client. In the client process, COM loads the generic proxy for the
- * class factory object and calls its implementation of IMarshal to
- * unmarshal that first pointer. COM then creates the first interface
- * proxy and hands it a pointer to the RPC channel. Finally, COM returns
- * the IClassFactory pointer to the client, which uses it to call
- * IClassFactory::CreateInstance, passing it a reference to the interface.
- *
- * Back in the server process, COM now creates a new instance of the
- * object, along with a stub for the requested interface. This stub marshals
- * the interface pointer back to the client process, where another object
- * proxy is created, this time for the object itself. Also created is a
- * proxy for the requested interface, a pointer to which is returned to
- * the client. With subsequent calls to other interfaces on the object,
- * COM will load the appropriate interface stubs and proxies as needed.
- */
-typedef struct _CFStub {
- const IRpcStubBufferVtbl *lpvtbl;
- LONG ref;
-
- LPUNKNOWN pUnkServer;
-} CFStub;
-
-static HRESULT WINAPI
-CFStub_QueryInterface(LPRPCSTUBBUFFER iface, REFIID riid, LPVOID *ppv) {
- if (IsEqualIID(&IID_IUnknown,riid)||IsEqualIID(&IID_IRpcStubBuffer,riid)) {
- *ppv = (LPVOID)iface;
- IUnknown_AddRef(iface);
- return S_OK;
- }
- FIXME("(%s), interface not supported.\n",debugstr_guid(riid));
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI
-CFStub_AddRef(LPRPCSTUBBUFFER iface) {
- CFStub *This = (CFStub *)iface;
- return InterlockedIncrement(&This->ref);
-}
-
-static ULONG WINAPI
-CFStub_Release(LPRPCSTUBBUFFER iface) {
- CFStub *This = (CFStub *)iface;
- ULONG ref;
-
- ref = InterlockedDecrement(&This->ref);
- if (!ref) {
- IRpcStubBuffer_Disconnect(iface);
- HeapFree(GetProcessHeap(),0,This);
- }
- return ref;
-}
-
-static HRESULT WINAPI
-CFStub_Connect(LPRPCSTUBBUFFER iface, IUnknown *pUnkServer) {
- CFStub *This = (CFStub *)iface;
-
- This->pUnkServer = pUnkServer;
- IUnknown_AddRef(pUnkServer);
- return S_OK;
-}
-
-static void WINAPI
-CFStub_Disconnect(LPRPCSTUBBUFFER iface) {
- CFStub *This = (CFStub *)iface;
-
- if (This->pUnkServer) {
- IUnknown_Release(This->pUnkServer);
- This->pUnkServer = NULL;
- }
-}
-
-static HRESULT WINAPI
-CFStub_Invoke(
- LPRPCSTUBBUFFER iface,RPCOLEMESSAGE* msg,IRpcChannelBuffer* chanbuf
-) {
- CFStub *This = (CFStub *)iface;
- HRESULT hres;
-
- if (msg->iMethod == 3) { /* CreateInstance */
- IID iid;
- IClassFactory *classfac;
- IUnknown *ppv;
- IStream *pStm;
- STATSTG ststg;
- ULARGE_INTEGER newpos;
- LARGE_INTEGER seekto;
- ULONG res;
-
- if (msg->cbBuffer < sizeof(IID)) {
- FIXME("Not enough bytes in buffer (%d)?\n",msg->cbBuffer);
- return E_FAIL;
- }
- memcpy(&iid,msg->Buffer,sizeof(iid));
- TRACE("->CreateInstance(%s)\n",debugstr_guid(&iid));
- hres = IUnknown_QueryInterface(This->pUnkServer,&IID_IClassFactory,(LPVOID*)&classfac);
- if (hres) {
- FIXME("Ole server does not provide an IClassFactory?\n");
- return hres;
- }
- hres = IClassFactory_CreateInstance(classfac,NULL,&iid,(LPVOID*)&ppv);
- IClassFactory_Release(classfac);
- msg->cbBuffer = 0;
- if (hres) {
- FIXME("Failed to create an instance of %s\n",debugstr_guid(&iid));
- goto getbuffer;
- }
- hres = CreateStreamOnHGlobal(0,TRUE,&pStm);
- if (hres) {
- FIXME("Failed to create stream on hglobal\n");
- goto getbuffer;
- }
- hres = IStream_Write(pStm, &ppv, sizeof(ppv), NULL);
- if (hres) {
- ERR("IStream_Write failed, 0x%08x\n", hres);
- goto getbuffer;
- }
- if (ppv) {
- hres = CoMarshalInterface(pStm,&iid,ppv,0,NULL,0);
- IUnknown_Release(ppv);
- if (hres) {
- FIXME("CoMarshalInterface failed, %x!\n",hres);
- goto getbuffer;
- }
- }
- hres = IStream_Stat(pStm,&ststg,0);
- if (hres) {
- FIXME("Stat failed.\n");
- goto getbuffer;
- }
-
- msg->cbBuffer = ststg.cbSize.u.LowPart;
-
-getbuffer:
- IRpcChannelBuffer_GetBuffer(chanbuf, msg, &IID_IClassFactory);
- if (hres) return hres;
-
- seekto.u.LowPart = 0;seekto.u.HighPart = 0;
- hres = IStream_Seek(pStm,seekto,SEEK_SET,&newpos);
- if (hres) {
- FIXME("IStream_Seek failed, %x\n",hres);
- return hres;
- }
- hres = IStream_Read(pStm,msg->Buffer,msg->cbBuffer,&res);
- if (hres) {
- FIXME("Stream Read failed, %x\n",hres);
- return hres;
- }
- IStream_Release(pStm);
- return S_OK;
- }
- FIXME("(%p,%p), stub!\n",msg,chanbuf);
- FIXME("iMethod is %d\n",msg->iMethod);
- FIXME("cbBuffer is %d\n",msg->cbBuffer);
- return E_FAIL;
-}
-
-static LPRPCSTUBBUFFER WINAPI
-CFStub_IsIIDSupported(LPRPCSTUBBUFFER iface,REFIID riid) {
- FIXME("(%s), stub!\n",debugstr_guid(riid));
- return NULL;
-}
-
-static ULONG WINAPI
-CFStub_CountRefs(LPRPCSTUBBUFFER iface) {
- FIXME("(), stub!\n");
- return 1;
-}
-
-static HRESULT WINAPI
-CFStub_DebugServerQueryInterface(LPRPCSTUBBUFFER iface,void** ppv) {
- FIXME("(%p), stub!\n",ppv);
- return E_FAIL;
-}
-static void WINAPI
-CFStub_DebugServerRelease(LPRPCSTUBBUFFER iface,void *pv) {
- FIXME("(%p), stub!\n",pv);
-}
-
-static const IRpcStubBufferVtbl cfstubvt = {
- CFStub_QueryInterface,
- CFStub_AddRef,
- CFStub_Release,
- CFStub_Connect,
- CFStub_Disconnect,
- CFStub_Invoke,
- CFStub_IsIIDSupported,
- CFStub_CountRefs,
- CFStub_DebugServerQueryInterface,
- CFStub_DebugServerRelease
-};
-
-static HRESULT
-CFStub_Construct(LPRPCSTUBBUFFER *ppv) {
- CFStub *cfstub;
- cfstub = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(CFStub));
- if (!cfstub)
- return E_OUTOFMEMORY;
- *ppv = (LPRPCSTUBBUFFER)cfstub;
- cfstub->lpvtbl = &cfstubvt;
- cfstub->ref = 1;
- return S_OK;
-}
-
-/* Since we create proxy buffers and classfactory in a pair, there is
- * no need for 2 separate structs. Just put them in one, but remember
- * the refcount.
- */
-typedef struct _CFProxy {
- const IClassFactoryVtbl *lpvtbl_cf;
- const IRpcProxyBufferVtbl *lpvtbl_proxy;
- LONG ref;
-
- IRpcChannelBuffer *chanbuf;
- IUnknown *outer_unknown;
-} CFProxy;
-
-static HRESULT WINAPI IRpcProxyBufferImpl_QueryInterface(LPRPCPROXYBUFFER iface,REFIID riid,LPVOID *ppv) {
- *ppv = NULL;
- if (IsEqualIID(riid,&IID_IRpcProxyBuffer)||IsEqualIID(riid,&IID_IUnknown)) {
- IRpcProxyBuffer_AddRef(iface);
- *ppv = (LPVOID)iface;
- return S_OK;
- }
- FIXME("(%s), no interface.\n",debugstr_guid(riid));
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI IRpcProxyBufferImpl_AddRef(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_proxy,iface);
- return InterlockedIncrement(&This->ref);
-}
-
-static ULONG WINAPI IRpcProxyBufferImpl_Release(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_proxy,iface);
- ULONG ref = InterlockedDecrement(&This->ref);
-
- if (!ref) {
- IRpcProxyBuffer_Disconnect(iface);
- HeapFree(GetProcessHeap(),0,This);
- }
- return ref;
-}
-
-static HRESULT WINAPI IRpcProxyBufferImpl_Connect(LPRPCPROXYBUFFER iface,IRpcChannelBuffer* pRpcChannelBuffer) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_proxy,iface);
-
- This->chanbuf = pRpcChannelBuffer;
- IRpcChannelBuffer_AddRef(This->chanbuf);
- return S_OK;
-}
-static void WINAPI IRpcProxyBufferImpl_Disconnect(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_proxy,iface);
- if (This->chanbuf) {
- IRpcChannelBuffer_Release(This->chanbuf);
- This->chanbuf = NULL;
- }
-}
-
-static HRESULT WINAPI
-CFProxy_QueryInterface(LPCLASSFACTORY iface,REFIID riid, LPVOID *ppv) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_cf,iface);
- if (This->outer_unknown) return IUnknown_QueryInterface(This->outer_unknown, riid, ppv);
- *ppv = NULL;
- if (IsEqualIID(&IID_IClassFactory,riid) || IsEqualIID(&IID_IUnknown,riid)) {
- *ppv = (LPVOID)iface;
- IClassFactory_AddRef(iface);
- return S_OK;
- }
- if (IsEqualIID(riid,&IID_IMarshal)) /* just to avoid debug output */
- return E_NOINTERFACE;
- FIXME("Unhandled interface: %s\n",debugstr_guid(riid));
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI CFProxy_AddRef(LPCLASSFACTORY iface) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_cf,iface);
- if (This->outer_unknown) return IUnknown_AddRef(This->outer_unknown);
- return InterlockedIncrement(&This->ref);
-}
-
-static ULONG WINAPI CFProxy_Release(LPCLASSFACTORY iface) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_cf,iface);
- if (This->outer_unknown)
- return IUnknown_Release(This->outer_unknown);
- else
- return IRpcProxyBufferImpl_Release((IRpcProxyBuffer *)&This->lpvtbl_proxy);
-}
-
-static HRESULT WINAPI CFProxy_CreateInstance(
- LPCLASSFACTORY iface,
- LPUNKNOWN pUnkOuter,/* [in] */
- REFIID riid, /* [in] */
- LPVOID *ppv /* [out] */
-) {
- ICOM_THIS_MULTI(CFProxy,lpvtbl_cf,iface);
- HRESULT hres;
- LPSTREAM pStream;
- HGLOBAL hGlobal;
- ULONG srstatus;
- RPCOLEMESSAGE msg;
-
- TRACE("(%p,%s,%p)\n",pUnkOuter,debugstr_guid(riid),ppv);
-
- /* Send CreateInstance to the remote classfactory.
- *
- * Data: Only the 'IID'.
- */
- msg.iMethod = 3;
- msg.cbBuffer = sizeof(*riid);
- msg.Buffer = NULL;
- hres = IRpcChannelBuffer_GetBuffer(This->chanbuf,&msg,&IID_IClassFactory);
- if (hres) {
- FIXME("IRpcChannelBuffer_GetBuffer failed with %x?\n",hres);
- return hres;
- }
- memcpy(msg.Buffer,riid,sizeof(*riid));
- hres = IRpcChannelBuffer_SendReceive(This->chanbuf,&msg,&srstatus);
- if (hres) {
- FIXME("IRpcChannelBuffer_SendReceive failed with %x?\n",hres);
- IRpcChannelBuffer_FreeBuffer(This->chanbuf,&msg);
- return hres;
- }
-
- if (!msg.cbBuffer) { /* interface not found on remote */
- IRpcChannelBuffer_FreeBuffer(This->chanbuf,&msg);
- return srstatus;
- }
-
- /* We got back: [Marshalled Interface data] */
- TRACE("got %d bytes data.\n",msg.cbBuffer);
- hGlobal = GlobalAlloc(GMEM_MOVEABLE|GMEM_NODISCARD|GMEM_SHARE,msg.cbBuffer);
- memcpy(GlobalLock(hGlobal),msg.Buffer,msg.cbBuffer);
- hres = CreateStreamOnHGlobal(hGlobal,TRUE,&pStream);
- if (hres != S_OK) {
- FIXME("CreateStreamOnHGlobal failed with %x\n",hres);
- IRpcChannelBuffer_FreeBuffer(This->chanbuf,&msg);
- GlobalFree(hGlobal);
- return hres;
- }
- hres = IStream_Read(pStream, ppv, sizeof(*ppv), NULL);
- if (hres != S_OK)
- hres = E_FAIL;
- else if (*ppv) {
- hres = CoUnmarshalInterface(
- pStream,
- riid,
- ppv
- );
- }
- IStream_Release(pStream); /* Does GlobalFree hGlobal too. */
-
- IRpcChannelBuffer_FreeBuffer(This->chanbuf,&msg);
-
- if (hres) {
- FIXME("CoMarshalInterface failed, %x\n",hres);
- return hres;
- }
- return S_OK;
-}
-
-static HRESULT WINAPI CFProxy_LockServer(LPCLASSFACTORY iface,BOOL fLock) {
- /*ICOM_THIS_MULTI(CFProxy,lpvtbl_cf,iface);*/
- FIXME("(%d), stub!\n",fLock);
- /* basically: write BOOL, read empty */
- return S_OK;
-}
-
-static const IRpcProxyBufferVtbl pspbvtbl = {
- IRpcProxyBufferImpl_QueryInterface,
- IRpcProxyBufferImpl_AddRef,
- IRpcProxyBufferImpl_Release,
- IRpcProxyBufferImpl_Connect,
- IRpcProxyBufferImpl_Disconnect
-};
-static const IClassFactoryVtbl cfproxyvt = {
- CFProxy_QueryInterface,
- CFProxy_AddRef,
- CFProxy_Release,
- CFProxy_CreateInstance,
- CFProxy_LockServer
-};
-
-static HRESULT
-CFProxy_Construct(IUnknown *pUnkOuter, LPVOID *ppv,LPVOID *ppProxy) {
- CFProxy *cf;
-
- cf = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(CFProxy));
- if (!cf)
- return E_OUTOFMEMORY;
-
- cf->lpvtbl_cf = &cfproxyvt;
- cf->lpvtbl_proxy = &pspbvtbl;
- /* one reference for the proxy buffer */
- cf->ref = 1;
- cf->outer_unknown = pUnkOuter;
- *ppv = &(cf->lpvtbl_cf);
- *ppProxy = &(cf->lpvtbl_proxy);
- /* and one reference for the object */
- IUnknown_AddRef((IUnknown *)*ppv);
- return S_OK;
-}
-
-
-/********************* IRemUnknown Proxy/Stub ********************************/
-
-typedef struct
-{
- const IRpcStubBufferVtbl *lpVtbl;
- LONG refs;
- IRemUnknown *iface;
-} RemUnkStub;
-
-static HRESULT WINAPI RemUnkStub_QueryInterface(LPRPCSTUBBUFFER iface,
- REFIID riid,
- LPVOID *obj)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- TRACE("(%p)->QueryInterface(%s,%p)\n",This,debugstr_guid(riid),obj);
- if (IsEqualGUID(&IID_IUnknown,riid) ||
- IsEqualGUID(&IID_IRpcStubBuffer,riid)) {
- *obj = This;
- return S_OK;
- }
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI RemUnkStub_AddRef(LPRPCSTUBBUFFER iface)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- TRACE("(%p)->AddRef()\n",This);
- return InterlockedIncrement(&This->refs);
-}
-
-static ULONG WINAPI RemUnkStub_Release(LPRPCSTUBBUFFER iface)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- ULONG refs;
- TRACE("(%p)->Release()\n",This);
- refs = InterlockedDecrement(&This->refs);
- if (!refs)
- HeapFree(GetProcessHeap(), 0, This);
- return refs;
-}
-
-static HRESULT WINAPI RemUnkStub_Connect(LPRPCSTUBBUFFER iface,
- LPUNKNOWN lpUnkServer)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- TRACE("(%p)->Connect(%p)\n",This,lpUnkServer);
- This->iface = (IRemUnknown*)lpUnkServer;
- IRemUnknown_AddRef(This->iface);
- return S_OK;
-}
-
-static void WINAPI RemUnkStub_Disconnect(LPRPCSTUBBUFFER iface)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- TRACE("(%p)->Disconnect()\n",This);
- IUnknown_Release(This->iface);
- This->iface = NULL;
-}
-
-static HRESULT WINAPI RemUnkStub_Invoke(LPRPCSTUBBUFFER iface,
- PRPCOLEMESSAGE pMsg,
- LPRPCCHANNELBUFFER pChannel)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- ULONG iMethod = pMsg->iMethod;
- LPBYTE buf = pMsg->Buffer;
- HRESULT hr = RPC_E_INVALIDMETHOD;
-
- TRACE("(%p)->Invoke(%p,%p) method %d\n", This, pMsg, pChannel, iMethod);
- switch (iMethod)
- {
- case 3: /* RemQueryInterface */
- {
- IPID ipid;
- ULONG cRefs;
- USHORT cIids;
- IID *iids;
- REMQIRESULT *pQIResults = NULL;
-
- /* in */
- memcpy(&ipid, buf, sizeof(ipid));
- buf += sizeof(ipid);
- memcpy(&cRefs, buf, sizeof(cRefs));
- buf += sizeof(cRefs);
- memcpy(&cIids, buf, sizeof(cIids));
- buf += sizeof(cIids);
- iids = (IID *)buf;
-
- hr = IRemUnknown_RemQueryInterface(This->iface, &ipid, cRefs, cIids, iids, &pQIResults);
-
- /* out */
- pMsg->cbBuffer = cIids * sizeof(REMQIRESULT) + sizeof(HRESULT);
-
- IRpcChannelBuffer_GetBuffer(pChannel, pMsg, &IID_IRemUnknown);
-
- buf = pMsg->Buffer;
- *(HRESULT *)buf = hr;
- buf += sizeof(HRESULT);
-
- if (hr) return hr;
- /* FIXME: pQIResults is a unique pointer so pQIResults can be NULL! */
- memcpy(buf, pQIResults, cIids * sizeof(REMQIRESULT));
-
- break;
- }
- case 4: /* RemAddRef */
- {
- USHORT cIids;
- REMINTERFACEREF *ir;
- HRESULT *pResults;
-
- /* in */
- memcpy(&cIids, buf, sizeof(USHORT));
- buf += sizeof(USHORT);
- ir = (REMINTERFACEREF*)buf;
- pResults = CoTaskMemAlloc(cIids * sizeof(HRESULT));
- if (!pResults) return E_OUTOFMEMORY;
-
- hr = IRemUnknown_RemAddRef(This->iface, cIids, ir, pResults);
-
- /* out */
- pMsg->cbBuffer = cIids * sizeof(HRESULT);
-
- IRpcChannelBuffer_GetBuffer(pChannel, pMsg, &IID_IRemUnknown);
- if (!hr)
- {
- buf = pMsg->Buffer;
- memcpy(buf, pResults, cIids * sizeof(HRESULT));
- }
-
- CoTaskMemFree(pResults);
-
- break;
- }
- case 5: /* RemRelease */
- {
- USHORT cIids;
- REMINTERFACEREF *ir;
-
- /* in */
- memcpy(&cIids, buf, sizeof(USHORT));
- buf += sizeof(USHORT);
- ir = (REMINTERFACEREF*)buf;
-
- hr = IRemUnknown_RemRelease(This->iface, cIids, ir);
-
- /* out */
- pMsg->cbBuffer = 0;
- IRpcChannelBuffer_GetBuffer(pChannel, pMsg, &IID_IRemUnknown);
- break;
- }
- }
- return hr;
-}
-
-static LPRPCSTUBBUFFER WINAPI RemUnkStub_IsIIDSupported(LPRPCSTUBBUFFER iface,
- REFIID riid)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- TRACE("(%p)->IsIIDSupported(%s)\n", This, debugstr_guid(riid));
- return IsEqualGUID(&IID_IRemUnknown, riid) ? iface : NULL;
-}
-
-static ULONG WINAPI RemUnkStub_CountRefs(LPRPCSTUBBUFFER iface)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- FIXME("(%p)->CountRefs()\n", This);
- return 1;
-}
-
-static HRESULT WINAPI RemUnkStub_DebugServerQueryInterface(LPRPCSTUBBUFFER iface,
- LPVOID *ppv)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- FIXME("(%p)->DebugServerQueryInterface(%p)\n",This,ppv);
- return E_NOINTERFACE;
-}
-
-static void WINAPI RemUnkStub_DebugServerRelease(LPRPCSTUBBUFFER iface,
- LPVOID pv)
-{
- RemUnkStub *This = (RemUnkStub *)iface;
- FIXME("(%p)->DebugServerRelease(%p)\n", This, pv);
-}
-
-static const IRpcStubBufferVtbl RemUnkStub_VTable =
-{
- RemUnkStub_QueryInterface,
- RemUnkStub_AddRef,
- RemUnkStub_Release,
- RemUnkStub_Connect,
- RemUnkStub_Disconnect,
- RemUnkStub_Invoke,
- RemUnkStub_IsIIDSupported,
- RemUnkStub_CountRefs,
- RemUnkStub_DebugServerQueryInterface,
- RemUnkStub_DebugServerRelease
-};
-
-static HRESULT RemUnkStub_Construct(IRpcStubBuffer **ppStub)
-{
- RemUnkStub *This = HeapAlloc(GetProcessHeap(), 0, sizeof(*This));
- if (!This) return E_OUTOFMEMORY;
- This->lpVtbl = &RemUnkStub_VTable;
- This->refs = 1;
- This->iface = NULL;
- *ppStub = (IRpcStubBuffer*)This;
- return S_OK;
-}
-
-
-typedef struct _RemUnkProxy {
- const IRemUnknownVtbl *lpvtbl_remunk;
- const IRpcProxyBufferVtbl *lpvtbl_proxy;
- LONG refs;
-
- IRpcChannelBuffer *chan;
- IUnknown *outer_unknown;
-} RemUnkProxy;
-
-static HRESULT WINAPI RemUnkProxy_QueryInterface(LPREMUNKNOWN iface, REFIID riid, void **ppv)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
- if (This->outer_unknown)
- return IUnknown_QueryInterface(This->outer_unknown, riid, ppv);
- if (IsEqualIID(riid, &IID_IUnknown) ||
- IsEqualIID(riid, &IID_IRemUnknown))
- {
- IRemUnknown_AddRef(iface);
- *ppv = (LPVOID)iface;
- return S_OK;
- }
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI RemUnkProxy_AddRef(LPREMUNKNOWN iface)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
- ULONG refs;
-
- TRACE("(%p)->AddRef()\n",This);
-
- if (This->outer_unknown)
- refs = IUnknown_AddRef(This->outer_unknown);
- else
- refs = InterlockedIncrement(&This->refs);
- return refs;
-}
-
-static ULONG WINAPI RemUnkProxy_Release(LPREMUNKNOWN iface)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
-
- TRACE("(%p)->Release()\n",This);
- if (This->outer_unknown)
- return IUnknown_Release(This->outer_unknown);
- else
- return IRpcProxyBufferImpl_Release((IRpcProxyBuffer *)&This->lpvtbl_proxy);
-}
-
-static HRESULT WINAPI RemUnkProxy_RemQueryInterface(LPREMUNKNOWN iface,
- REFIPID ripid,
- ULONG cRefs,
- USHORT cIids,
- IID* iids,
- REMQIRESULT** ppQIResults)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
- RPCOLEMESSAGE msg;
- HRESULT hr = S_OK;
- ULONG status;
-
- TRACE("(%p)->(%s,%d,%d,%p,%p)\n",This,
- debugstr_guid(ripid),cRefs,cIids,iids,ppQIResults);
-
- *ppQIResults = NULL;
- memset(&msg, 0, sizeof(msg));
- msg.iMethod = 3;
- msg.cbBuffer = sizeof(IPID) + sizeof(ULONG) +
- sizeof(USHORT) + cIids*sizeof(IID);
- hr = IRpcChannelBuffer_GetBuffer(This->chan, &msg, &IID_IRemUnknown);
- if (SUCCEEDED(hr)) {
- LPBYTE buf = msg.Buffer;
- memcpy(buf, ripid, sizeof(IPID));
- buf += sizeof(IPID);
- memcpy(buf, &cRefs, sizeof(ULONG));
- buf += sizeof(ULONG);
- memcpy(buf, &cIids, sizeof(USHORT));
- buf += sizeof(USHORT);
- memcpy(buf, iids, cIids*sizeof(IID));
-
- hr = IRpcChannelBuffer_SendReceive(This->chan, &msg, &status);
-
- buf = msg.Buffer;
-
- if (SUCCEEDED(hr)) {
- hr = *(HRESULT *)buf;
- buf += sizeof(HRESULT);
- }
-
- if (SUCCEEDED(hr)) {
- *ppQIResults = CoTaskMemAlloc(cIids*sizeof(REMQIRESULT));
- memcpy(*ppQIResults, buf, cIids*sizeof(REMQIRESULT));
- }
-
- IRpcChannelBuffer_FreeBuffer(This->chan, &msg);
- }
-
- return hr;
-}
-
-static HRESULT WINAPI RemUnkProxy_RemAddRef(LPREMUNKNOWN iface,
- USHORT cInterfaceRefs,
- REMINTERFACEREF* InterfaceRefs,
- HRESULT* pResults)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
- RPCOLEMESSAGE msg;
- HRESULT hr = S_OK;
- ULONG status;
-
- TRACE("(%p)->(%d,%p,%p)\n",This,
- cInterfaceRefs,InterfaceRefs,pResults);
-
- memset(&msg, 0, sizeof(msg));
- msg.iMethod = 4;
- msg.cbBuffer = sizeof(USHORT) + cInterfaceRefs*sizeof(REMINTERFACEREF);
- hr = IRpcChannelBuffer_GetBuffer(This->chan, &msg, &IID_IRemUnknown);
- if (SUCCEEDED(hr)) {
- LPBYTE buf = msg.Buffer;
- memcpy(buf, &cInterfaceRefs, sizeof(USHORT));
- buf += sizeof(USHORT);
- memcpy(buf, InterfaceRefs, cInterfaceRefs*sizeof(REMINTERFACEREF));
-
- hr = IRpcChannelBuffer_SendReceive(This->chan, &msg, &status);
-
- if (SUCCEEDED(hr)) {
- buf = msg.Buffer;
- memcpy(pResults, buf, cInterfaceRefs*sizeof(HRESULT));
- }
-
- IRpcChannelBuffer_FreeBuffer(This->chan, &msg);
- }
-
- return hr;
-}
-
-static HRESULT WINAPI RemUnkProxy_RemRelease(LPREMUNKNOWN iface,
- USHORT cInterfaceRefs,
- REMINTERFACEREF* InterfaceRefs)
-{
- RemUnkProxy *This = (RemUnkProxy *)iface;
- RPCOLEMESSAGE msg;
- HRESULT hr = S_OK;
- ULONG status;
-
- TRACE("(%p)->(%d,%p)\n",This,
- cInterfaceRefs,InterfaceRefs);
-
- memset(&msg, 0, sizeof(msg));
- msg.iMethod = 5;
- msg.cbBuffer = sizeof(USHORT) + cInterfaceRefs*sizeof(REMINTERFACEREF);
- hr = IRpcChannelBuffer_GetBuffer(This->chan, &msg, &IID_IRemUnknown);
- if (SUCCEEDED(hr)) {
- LPBYTE buf = msg.Buffer;
- memcpy(buf, &cInterfaceRefs, sizeof(USHORT));
- buf += sizeof(USHORT);
- memcpy(buf, InterfaceRefs, cInterfaceRefs*sizeof(REMINTERFACEREF));
-
- hr = IRpcChannelBuffer_SendReceive(This->chan, &msg, &status);
-
- IRpcChannelBuffer_FreeBuffer(This->chan, &msg);
- }
-
- return hr;
-}
-
-static const IRemUnknownVtbl RemUnkProxy_VTable =
-{
- RemUnkProxy_QueryInterface,
- RemUnkProxy_AddRef,
- RemUnkProxy_Release,
- RemUnkProxy_RemQueryInterface,
- RemUnkProxy_RemAddRef,
- RemUnkProxy_RemRelease
-};
-
-
-static HRESULT WINAPI RURpcProxyBufferImpl_QueryInterface(LPRPCPROXYBUFFER iface,REFIID riid,LPVOID *ppv) {
- *ppv = NULL;
- if (IsEqualIID(riid,&IID_IRpcProxyBuffer)||IsEqualIID(riid,&IID_IUnknown)) {
- IRpcProxyBuffer_AddRef(iface);
- *ppv = (LPVOID)iface;
- return S_OK;
- }
- FIXME("(%s), no interface.\n",debugstr_guid(riid));
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI RURpcProxyBufferImpl_AddRef(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(RemUnkProxy,lpvtbl_proxy,iface);
- TRACE("%p, %d\n", iface, This->refs + 1);
- return InterlockedIncrement(&This->refs);
-}
-
-static ULONG WINAPI RURpcProxyBufferImpl_Release(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(RemUnkProxy,lpvtbl_proxy,iface);
- ULONG ref = InterlockedDecrement(&This->refs);
- TRACE("%p, %d\n", iface, ref);
- if (!ref) {
- IRpcProxyBuffer_Disconnect(iface);
- HeapFree(GetProcessHeap(),0,This);
- }
- return ref;
-}
-
-static HRESULT WINAPI RURpcProxyBufferImpl_Connect(LPRPCPROXYBUFFER iface,IRpcChannelBuffer* pRpcChannelBuffer) {
- ICOM_THIS_MULTI(RemUnkProxy,lpvtbl_proxy,iface);
-
- TRACE("%p, %p\n", iface, pRpcChannelBuffer);
- This->chan = pRpcChannelBuffer;
- IRpcChannelBuffer_AddRef(This->chan);
- return S_OK;
-}
-static void WINAPI RURpcProxyBufferImpl_Disconnect(LPRPCPROXYBUFFER iface) {
- ICOM_THIS_MULTI(RemUnkProxy,lpvtbl_proxy,iface);
- TRACE("%p, %p\n", iface, This->chan);
- if (This->chan) {
- IRpcChannelBuffer_Release(This->chan);
- This->chan = NULL;
- }
-}
-
-
-static const IRpcProxyBufferVtbl RURpcProxyBuffer_VTable = {
- RURpcProxyBufferImpl_QueryInterface,
- RURpcProxyBufferImpl_AddRef,
- RURpcProxyBufferImpl_Release,
- RURpcProxyBufferImpl_Connect,
- RURpcProxyBufferImpl_Disconnect
-};
-
-static HRESULT
-RemUnkProxy_Construct(IUnknown *pUnkOuter, LPVOID *ppv,LPVOID *ppProxy) {
- RemUnkProxy *This;
-
- This = HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,sizeof(*This));
- if (!This)
- return E_OUTOFMEMORY;
-
- This->lpvtbl_remunk = &RemUnkProxy_VTable;
- This->lpvtbl_proxy = &RURpcProxyBuffer_VTable;
- /* only one reference for the proxy buffer */
- This->refs = 1;
- This->outer_unknown = pUnkOuter;
- *ppv = &(This->lpvtbl_remunk);
- *ppProxy = &(This->lpvtbl_proxy);
- /* and one reference for the object */
- IUnknown_AddRef((IUnknown *)*ppv);
- return S_OK;
-}
-
-
-/********************* OLE Proxy/Stub Factory ********************************/
-static HRESULT WINAPI
-PSFacBuf_QueryInterface(LPPSFACTORYBUFFER iface, REFIID iid, LPVOID *ppv) {
- if (IsEqualIID(iid,&IID_IPSFactoryBuffer)||IsEqualIID(iid,&IID_IUnknown)) {
- *ppv = (LPVOID)iface;
- /* No ref counting, static class */
- return S_OK;
- }
- FIXME("(%s) unknown IID?\n",debugstr_guid(iid));
- return E_NOINTERFACE;
-}
-
-static ULONG WINAPI PSFacBuf_AddRef(LPPSFACTORYBUFFER iface) { return 2; }
-static ULONG WINAPI PSFacBuf_Release(LPPSFACTORYBUFFER iface) { return 1; }
-
-static HRESULT WINAPI
-PSFacBuf_CreateProxy(
- LPPSFACTORYBUFFER iface, IUnknown* pUnkOuter, REFIID riid,
- IRpcProxyBuffer **ppProxy, LPVOID *ppv
-) {
- if (IsEqualIID(&IID_IClassFactory,riid))
- return CFProxy_Construct(pUnkOuter, ppv,(LPVOID*)ppProxy);
- else if (IsEqualIID(&IID_IRemUnknown,riid))
- return RemUnkProxy_Construct(pUnkOuter, ppv,(LPVOID*)ppProxy);
- FIXME("proxying not implemented for (%s) yet!\n",debugstr_guid(riid));
- return E_FAIL;
-}
-
-static HRESULT WINAPI
-PSFacBuf_CreateStub(
- LPPSFACTORYBUFFER iface, REFIID riid,IUnknown *pUnkServer,
- IRpcStubBuffer** ppStub
-) {
- HRESULT hres;
-
- TRACE("(%s,%p,%p)\n",debugstr_guid(riid),pUnkServer,ppStub);
-
- if (IsEqualIID(&IID_IClassFactory, riid) ||
- IsEqualIID(&IID_IUnknown, riid) /* FIXME: fixup stub manager and remove this*/) {
- hres = CFStub_Construct(ppStub);
- if (!hres)
- IRpcStubBuffer_Connect((*ppStub),pUnkServer);
- return hres;
- } else if (IsEqualIID(&IID_IRemUnknown,riid)) {
- hres = RemUnkStub_Construct(ppStub);
- if (!hres)
- IRpcStubBuffer_Connect((*ppStub),pUnkServer);
- return hres;
- }
- FIXME("stubbing not implemented for (%s) yet!\n",debugstr_guid(riid));
- return E_FAIL;
-}
-
static CStdPSFactoryBuffer PSFactoryBuffer;
CSTDSTUBBUFFERRELEASE(&PSFactoryBuffer)
-static const IPSFactoryBufferVtbl psfacbufvtbl = {
- PSFacBuf_QueryInterface,
- PSFacBuf_AddRef,
- PSFacBuf_Release,
- PSFacBuf_CreateProxy,
- PSFacBuf_CreateStub
-};
-
-/* This is the whole PSFactoryBuffer object, just the vtableptr */
-static const IPSFactoryBufferVtbl *lppsfac = &psfacbufvtbl;
-
extern const ExtendedProxyFileInfo dcom_ProxyFileInfo;
extern const ExtendedProxyFileInfo ole32_unknwn_ProxyFileInfo;
More information about the wine-patches
mailing list