git.c 10.4 KB
Newer Older
1 2 3 4 5 6 7 8 9
/*
 * Implementation of the StdGlobalInterfaceTable object
 *
 * The GlobalInterfaceTable (GIT) object is used to marshal interfaces between
 * threading apartments (contexts). When you want to pass an interface but not
 * as a parameter, it wouldn't get marshalled automatically, so you can use this
 * object to insert the interface into a table, and you get back a cookie.
 * Then when it's retrieved, it'll be unmarshalled into the right apartment.
 *
Mike Hearn's avatar
Mike Hearn committed
10
 * Copyright 2003 Mike Hearn <mike@theoretic.com>
11 12 13 14 15 16 17 18 19 20 21 22 23
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
24
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
25 26
 */

27
#include <stdarg.h>
28

29 30 31 32
#define COBJMACROS
#define NONAMELESSUNION
#define NONAMELESSSTRUCT

33
#include "windef.h"
34
#include "winbase.h"
35
#include "winuser.h"
36 37 38 39 40 41
#include "objbase.h"
#include "ole2.h"
#include "winerror.h"

#include "compobj_private.h" 

42
#include "wine/list.h"
43 44 45 46 47 48 49 50 51 52 53 54 55 56 57
#include "wine/debug.h"

WINE_DEFAULT_DEBUG_CHANNEL(ole);

/****************************************************************************
 * StdGlobalInterfaceTable definition
 *
 * This class implements IGlobalInterfaceTable and is a process-wide singleton
 * used for marshalling interfaces between threading apartments using cookies.
 */

/* Each entry in the linked list of GIT entries */
typedef struct StdGITEntry
{
  DWORD cookie;
58
  IID iid;         /* IID of the interface */
59 60
  IStream* stream; /* Holds the marshalled interface */

61
  struct list entry;
62 63 64 65 66
} StdGITEntry;

/* Class data */
typedef struct StdGlobalInterfaceTableImpl
{
67
  const IGlobalInterfaceTableVtbl *lpVtbl;
68 69

  ULONG ref;
70
  struct list list;
71 72 73 74
  ULONG nextCookie;
  
} StdGlobalInterfaceTableImpl;

75 76
void* StdGlobalInterfaceTableInstance;

77 78 79 80 81
static CRITICAL_SECTION git_section;
static CRITICAL_SECTION_DEBUG critsect_debug =
{
    0, 0, &git_section,
    { &critsect_debug.ProcessLocksList, &critsect_debug.ProcessLocksList },
82
      0, 0, { (DWORD_PTR)(__FILE__ ": global interface table") }
83 84 85 86
};
static CRITICAL_SECTION git_section = { &critsect_debug, -1, 0, 0, 0, 0 };


87
/** This destroys it again. It should revoke all the held interfaces first **/
88 89
static void StdGlobalInterfaceTable_Destroy(void* self)
{
90 91 92 93
  TRACE("(%p)\n", self);
  FIXME("Revoke held interfaces here\n");
  
  HeapFree(GetProcessHeap(), 0, self);
94
  StdGlobalInterfaceTableInstance = NULL;
95 96 97 98
}

/***
 * A helper function to traverse the list and find the entry that matches the cookie.
99
 * Returns NULL if not found. Must be called inside git_section critical section.
100
 */
101 102 103
static StdGITEntry*
StdGlobalInterfaceTable_FindEntry(IGlobalInterfaceTable* iface, DWORD cookie)
{
104 105 106
  StdGlobalInterfaceTableImpl* const self = (StdGlobalInterfaceTableImpl*) iface;
  StdGITEntry* e;

107
  TRACE("iface=%p, cookie=0x%x\n", iface, cookie);
108

109
  LIST_FOR_EACH_ENTRY(e, &self->list, StdGITEntry, entry) {
110
    if (e->cookie == cookie)
111
      return e;
112
  }
113
  
114
  TRACE("Entry not found\n");
115 116 117 118 119 120 121
  return NULL;
}

/***
 * Here's the boring boilerplate stuff for IUnknown
 */

122 123 124 125
static HRESULT WINAPI
StdGlobalInterfaceTable_QueryInterface(IGlobalInterfaceTable* iface,
               REFIID riid, void** ppvObject)
{
126 127 128 129 130 131
  /* Make sure silly coders can't crash us */
  if (ppvObject == 0) return E_INVALIDARG;

  *ppvObject = 0; /* assume we don't have the interface */

  /* Do we implement that interface? */
132 133 134 135 136
  if (IsEqualIID(&IID_IUnknown, riid) ||
      IsEqualIID(&IID_IGlobalInterfaceTable, riid))
    *ppvObject = iface;
  else
    return E_NOINTERFACE;
137 138

  /* Now inc the refcount */
139
  IGlobalInterfaceTable_AddRef(iface);
140 141 142
  return S_OK;
}

143 144 145
static ULONG WINAPI
StdGlobalInterfaceTable_AddRef(IGlobalInterfaceTable* iface)
{
146 147
  StdGlobalInterfaceTableImpl* const self = (StdGlobalInterfaceTableImpl*) iface;

148
  /* InterlockedIncrement(&self->ref); */
149 150 151
  return self->ref;
}

152 153 154
static ULONG WINAPI
StdGlobalInterfaceTable_Release(IGlobalInterfaceTable* iface)
{
155 156
  StdGlobalInterfaceTableImpl* const self = (StdGlobalInterfaceTableImpl*) iface;

157
  /* InterlockedDecrement(&self->ref); */
158 159 160 161 162 163 164 165 166 167 168 169 170
  if (self->ref == 0) {
    /* Hey ho, it's time to go, so long again 'till next weeks show! */
    StdGlobalInterfaceTable_Destroy(self);
    return 0;
  }

  return self->ref;
}

/***
 * Now implement the actual IGlobalInterfaceTable interface
 */

171 172 173 174 175
static HRESULT WINAPI
StdGlobalInterfaceTable_RegisterInterfaceInGlobal(
               IGlobalInterfaceTable* iface, IUnknown* pUnk,
               REFIID riid, DWORD* pdwCookie)
{
176 177 178 179
  StdGlobalInterfaceTableImpl* const self = (StdGlobalInterfaceTableImpl*) iface;
  IStream* stream = NULL;
  HRESULT hres;
  StdGITEntry* entry;
180
  LARGE_INTEGER zero;
181

182
  TRACE("iface=%p, pUnk=%p, riid=%s, pdwCookie=0x%p\n", iface, pUnk, debugstr_guid(riid), pdwCookie);
183 184 185 186

  if (pUnk == NULL) return E_INVALIDARG;
  
  /* marshal the interface */
187
  TRACE("About to marshal the interface\n");
188 189

  hres = CreateStreamOnHGlobal(0, TRUE, &stream);
190
  if (hres) return hres;
191 192 193 194 195 196 197
  hres = CoMarshalInterface(stream, riid, pUnk, MSHCTX_INPROC, NULL, MSHLFLAGS_TABLESTRONG);
  if (hres)
  {
    IStream_Release(stream);
    return hres;
  }

198
  zero.QuadPart = 0;
199
  IStream_Seek(stream, zero, STREAM_SEEK_SET, NULL);
200

201 202
  entry = HeapAlloc(GetProcessHeap(), 0, sizeof(StdGITEntry));
  if (entry == NULL) return E_OUTOFMEMORY;
203 204

  EnterCriticalSection(&git_section);
205 206 207 208 209 210 211
  
  entry->iid = *riid;
  entry->stream = stream;
  entry->cookie = self->nextCookie;
  self->nextCookie++; /* inc the cookie count */

  /* insert the new entry at the end of the list */
212
  list_add_tail(&self->list, &entry->entry);
213 214 215

  /* and return the cookie */
  *pdwCookie = entry->cookie;
216 217 218
  
  LeaveCriticalSection(&git_section);
  
219
  TRACE("Cookie is 0x%x\n", entry->cookie);
220 221 222
  return S_OK;
}

223 224 225 226
static HRESULT WINAPI
StdGlobalInterfaceTable_RevokeInterfaceFromGlobal(
               IGlobalInterfaceTable* iface, DWORD dwCookie)
{
227
  StdGITEntry* entry;
228
  HRESULT hr;
229

230
  TRACE("iface=%p, dwCookie=0x%x\n", iface, dwCookie);
231 232 233

  EnterCriticalSection(&git_section);

234 235 236
  entry = StdGlobalInterfaceTable_FindEntry(iface, dwCookie);
  if (entry == NULL) {
    TRACE("Entry not found\n");
237
    LeaveCriticalSection(&git_section);
238 239
    return E_INVALIDARG; /* not found */
  }
240 241 242 243

  list_remove(&entry->entry);

  LeaveCriticalSection(&git_section);
244 245
  
  /* Free the stream */
246 247 248
  hr = CoReleaseMarshalData(entry->stream);
  if (hr != S_OK)
  {
249
    WARN("Failed to release marshal data, hr = 0x%08x\n", hr);
250 251
    return hr;
  }
252 253
  IStream_Release(entry->stream);
		    
254 255 256 257
  HeapFree(GetProcessHeap(), 0, entry);
  return S_OK;
}

258 259 260 261 262
static HRESULT WINAPI
StdGlobalInterfaceTable_GetInterfaceFromGlobal(
               IGlobalInterfaceTable* iface, DWORD dwCookie,
               REFIID riid, void **ppv)
{
263 264
  StdGITEntry* entry;
  HRESULT hres;
265 266
  IStream *stream;

267
  TRACE("dwCookie=0x%x, riid=%s, ppv=%p\n", dwCookie, debugstr_guid(riid), ppv);
268 269 270

  EnterCriticalSection(&git_section);

271
  entry = StdGlobalInterfaceTable_FindEntry(iface, dwCookie);
272
  if (entry == NULL) {
273
    WARN("Entry for cookie 0x%x not found\n", dwCookie);
274 275 276
    LeaveCriticalSection(&git_section);
    return E_INVALIDARG;
  }
277

278
  TRACE("entry=%p\n", entry);
279 280 281 282 283 284 285 286 287 288

  hres = IStream_Clone(entry->stream, &stream);

  LeaveCriticalSection(&git_section);

  if (hres) {
    WARN("Failed to clone stream with error 0x%08x\n", hres);
    return hres;
  }

289
  /* unmarshal the interface */
290 291
  hres = CoUnmarshalInterface(stream, riid, ppv);
  IStream_Release(stream);
292

293 294 295 296 297
  if (hres) {
    WARN("Failed to unmarshal stream\n");
    return hres;
  }

298
  TRACE("ppv=%p\n", *ppv);
299 300
  return S_OK;
}
301 302 303

/* Classfactory definition - despite what MSDN says, some programs need this */

304 305 306
static HRESULT WINAPI
GITCF_QueryInterface(LPCLASSFACTORY iface,REFIID riid, LPVOID *ppv)
{
307
  *ppv = NULL;
308 309 310
  if (IsEqualIID(riid,&IID_IUnknown) ||
      IsEqualIID(riid,&IID_IGlobalInterfaceTable))
  {
311 312 313 314 315 316
    *ppv = (LPVOID)iface;
    return S_OK;
  }
  return E_NOINTERFACE;
}

317 318 319 320 321 322 323 324 325 326 327 328 329 330
static ULONG WINAPI GITCF_AddRef(LPCLASSFACTORY iface)
{
  return 2;
}

static ULONG WINAPI GITCF_Release(LPCLASSFACTORY iface)
{
  return 1;
}

static HRESULT WINAPI
GITCF_CreateInstance(LPCLASSFACTORY iface, LPUNKNOWN pUnk,
                     REFIID riid, LPVOID *ppv)
{
331 332 333 334 335 336 337 338 339 340
  if (IsEqualIID(riid,&IID_IGlobalInterfaceTable)) {
    if (StdGlobalInterfaceTableInstance == NULL) 
      StdGlobalInterfaceTableInstance = StdGlobalInterfaceTable_Construct();
    return IGlobalInterfaceTable_QueryInterface( (IGlobalInterfaceTable*) StdGlobalInterfaceTableInstance, riid, ppv);
  }

  FIXME("(%s), not supported.\n",debugstr_guid(riid));
  return E_NOINTERFACE;
}

341 342
static HRESULT WINAPI GITCF_LockServer(LPCLASSFACTORY iface, BOOL fLock)
{
343 344 345 346
    FIXME("(%d), stub!\n",fLock);
    return S_OK;
}

347
static const IClassFactoryVtbl GITClassFactoryVtbl = {
348 349 350 351 352 353
    GITCF_QueryInterface,
    GITCF_AddRef,
    GITCF_Release,
    GITCF_CreateInstance,
    GITCF_LockServer
};
354

355
static const IClassFactoryVtbl *PGITClassFactoryVtbl = &GITClassFactoryVtbl;
356

357 358
HRESULT StdGlobalInterfaceTable_GetFactory(LPVOID *ppv)
{
359 360 361 362
  *ppv = &PGITClassFactoryVtbl;
  TRACE("Returning GIT classfactory\n");
  return S_OK;
}
363 364

/* Virtual function table */
365
static const IGlobalInterfaceTableVtbl StdGlobalInterfaceTableImpl_Vtbl =
366 367 368 369 370 371 372 373 374 375
{
  StdGlobalInterfaceTable_QueryInterface,
  StdGlobalInterfaceTable_AddRef,
  StdGlobalInterfaceTable_Release,
  StdGlobalInterfaceTable_RegisterInterfaceInGlobal,
  StdGlobalInterfaceTable_RevokeInterfaceFromGlobal,
  StdGlobalInterfaceTable_GetInterfaceFromGlobal
};

/** This function constructs the GIT. It should only be called once **/
376
void* StdGlobalInterfaceTable_Construct(void)
377 378 379 380 381 382 383 384
{
  StdGlobalInterfaceTableImpl* newGIT;

  newGIT = HeapAlloc(GetProcessHeap(), 0, sizeof(StdGlobalInterfaceTableImpl));
  if (newGIT == 0) return newGIT;

  newGIT->lpVtbl = &StdGlobalInterfaceTableImpl_Vtbl;
  newGIT->ref = 1;      /* Initialise the reference count */
385
  list_init(&newGIT->list);
386 387 388 389 390
  newGIT->nextCookie = 0xf100; /* that's where windows starts, so that's where we start */
  TRACE("Created the GIT at %p\n", newGIT);

  return (void*)newGIT;
}