dlls/mf/topology.c

   1 /*
   2  * Copyright 2017 Nikolay Sivov
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Lesser General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2.1 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Lesser General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Lesser General Public
  15  * License along with this library; if not, write to the Free Software
  16  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  17  */
  18
  19
  20 #include <stdarg.h>
  21
  22 #define COBJMACROS
  23
  24 #include "windef.h"
  25 #include "winbase.h"
  26
  27 #undef INITGUID
  28 #include <guiddef.h>
  29 #include "mfidl.h"
  30
  31 #include "wine/debug.h"
  32
  33 #include "mf_private.h"
  34
  35 WINE_DEFAULT_DEBUG_CHANNEL(mfplat);
  36
  37 static LONG next_node_id;
  38 static TOPOID next_topology_id;
  39
  40 struct node_stream
  41 {
  42     IMFMediaType *preferred_type;
  43     struct topology_node *connection;
  44     DWORD connection_stream;
  45 };
  46
  47 struct node_streams
  48 {
  49     struct node_stream *streams;
  50     size_t size;
  51     size_t count;
  52 };
  53
  54 struct topology_node
  55 {
  56     IMFTopologyNode IMFTopologyNode_iface;
  57     LONG refcount;
  58     IMFAttributes *attributes;
  59     MF_TOPOLOGY_TYPE node_type;
  60     TOPOID id;
  61     IUnknown *object;
  62     IMFMediaType *input_type; /* Only for tee nodes. */
  63     struct node_streams inputs;
  64     struct node_streams outputs;
  65     CRITICAL_SECTION cs;
  66 };
  67
  68 struct topology
  69 {
  70     IMFTopology IMFTopology_iface;
  71     LONG refcount;
  72     IMFAttributes *attributes;
  73     struct
  74     {
  75         struct topology_node **nodes;
  76         size_t size;
  77         size_t count;
  78     } nodes;
  79     TOPOID id;
  80 };
  81
  82 struct topology_loader
  83 {
  84     IMFTopoLoader IMFTopoLoader_iface;
  85     LONG refcount;
  86 };
  87
  88 struct seq_source
  89 {
  90     IMFSequencerSource IMFSequencerSource_iface;
  91     IMFMediaSourceTopologyProvider IMFMediaSourceTopologyProvider_iface;
  92     LONG refcount;
  93 };
  94
  95 static inline struct topology *impl_from_IMFTopology(IMFTopology *iface)
  96 {
  97     return CONTAINING_RECORD(iface, struct topology, IMFTopology_iface);
  98 }
  99
 100 static struct topology_node *impl_from_IMFTopologyNode(IMFTopologyNode *iface)
 101 {
 102     return CONTAINING_RECORD(iface, struct topology_node, IMFTopologyNode_iface);
 103 }
 104
 105 static const IMFTopologyNodeVtbl topologynodevtbl;
 106
 107 static struct topology_node *unsafe_impl_from_IMFTopologyNode(IMFTopologyNode *iface)
 108 {
 109     if (!iface || iface->lpVtbl != &topologynodevtbl)
 110         return NULL;
 111     return impl_from_IMFTopologyNode(iface);
 112 }
 113
 114 static HRESULT create_topology_node(MF_TOPOLOGY_TYPE node_type, struct topology_node **node);
 115 static HRESULT topology_node_connect_output(struct topology_node *node, DWORD output_index,
 116         struct topology_node *connection, DWORD input_index);
 117
 118 static struct topology *unsafe_impl_from_IMFTopology(IMFTopology *iface);
 119
 120 static struct topology_loader *impl_from_IMFTopoLoader(IMFTopoLoader *iface)
 121 {
 122     return CONTAINING_RECORD(iface, struct topology_loader, IMFTopoLoader_iface);
 123 }
 124
 125 static struct seq_source *impl_from_IMFSequencerSource(IMFSequencerSource *iface)
 126 {
 127     return CONTAINING_RECORD(iface, struct seq_source, IMFSequencerSource_iface);
 128 }
 129
 130 static struct seq_source *impl_from_IMFMediaSourceTopologyProvider(IMFMediaSourceTopologyProvider *iface)
 131 {
 132     return CONTAINING_RECORD(iface, struct seq_source, IMFMediaSourceTopologyProvider_iface);
 133 }
 134
 135 static HRESULT topology_node_reserve_streams(struct node_streams *streams, DWORD index)
 136 {
 137     if (!mf_array_reserve((void **)&streams->streams, &streams->size, index + 1, sizeof(*streams->streams)))
 138         return E_OUTOFMEMORY;
 139
 140     if (index >= streams->count)
 141     {
 142         memset(&streams->streams[streams->count], 0, (index - streams->count + 1) * sizeof(*streams->streams));
 143         streams->count = index + 1;
 144     }
 145
 146     return S_OK;
 147 }
 148
 149 static HRESULT WINAPI topology_QueryInterface(IMFTopology *iface, REFIID riid, void **out)
 150 {
 151     struct topology *topology = impl_from_IMFTopology(iface);
 152
 153     TRACE("%p, %s, %p.\n", iface, debugstr_guid(riid), out);
 154
 155     if (IsEqualIID(riid, &IID_IMFTopology) ||
 156             IsEqualIID(riid, &IID_IMFAttributes) ||
 157             IsEqualIID(riid, &IID_IUnknown))
 158     {
 159         *out = &topology->IMFTopology_iface;
 160     }
 161     else
 162     {
 163         FIXME("(%s, %p)\n", debugstr_guid(riid), out);
 164         *out = NULL;
 165         return E_NOINTERFACE;
 166     }
 167
 168     IUnknown_AddRef((IUnknown*)*out);
 169     return S_OK;
 170 }
 171
 172 static ULONG WINAPI topology_AddRef(IMFTopology *iface)
 173 {
 174     struct topology *topology = impl_from_IMFTopology(iface);
 175     ULONG refcount = InterlockedIncrement(&topology->refcount);
 176
 177     TRACE("%p, refcount %u.\n", iface, refcount);
 178
 179     return refcount;
 180 }
 181
 182 static HRESULT topology_node_disconnect_output(struct topology_node *node, DWORD output_index)
 183 {
 184     struct topology_node *connection = NULL;
 185     struct node_stream *stream;
 186     DWORD connection_stream;
 187     HRESULT hr = S_OK;
 188
 189     EnterCriticalSection(&node->cs);
 190
 191     if (output_index < node->outputs.count)
 192     {
 193         stream = &node->outputs.streams[output_index];
 194
 195         if (stream->connection)
 196         {
 197             connection = stream->connection;
 198             connection_stream = stream->connection_stream;
 199             stream->connection = NULL;
 200             stream->connection_stream = 0;
 201         }
 202         else
 203             hr = MF_E_NOT_FOUND;
 204     }
 205     else
 206         hr = E_INVALIDARG;
 207
 208     LeaveCriticalSection(&node->cs);
 209
 210     if (connection)
 211     {
 212         EnterCriticalSection(&connection->cs);
 213
 214         if (connection_stream < connection->inputs.count)
 215         {
 216             stream = &connection->inputs.streams[connection_stream];
 217
 218             if (stream->connection)
 219             {
 220                 stream->connection = NULL;
 221                 stream->connection_stream = 0;
 222             }
 223         }
 224
 225         LeaveCriticalSection(&connection->cs);
 226
 227         IMFTopologyNode_Release(&connection->IMFTopologyNode_iface);
 228         IMFTopologyNode_Release(&node->IMFTopologyNode_iface);
 229     }
 230
 231     return hr;
 232 }
 233
 234 static void topology_node_disconnect(struct topology_node *node)
 235 {
 236     struct node_stream *stream;
 237     size_t i;
 238
 239     for (i = 0; i < node->outputs.count; ++i)
 240         topology_node_disconnect_output(node, i);
 241
 242     for (i = 0; i < node->inputs.count; ++i)
 243     {
 244         stream = &node->inputs.streams[i];
 245         if (stream->connection)
 246             topology_node_disconnect_output(stream->connection, stream->connection_stream);
 247     }
 248 }
 249
 250 static void topology_clear(struct topology *topology)
 251 {
 252     size_t i;
 253
 254     for (i = 0; i < topology->nodes.count; ++i)
 255     {
 256         topology_node_disconnect(topology->nodes.nodes[i]);
 257         IMFTopologyNode_Release(&topology->nodes.nodes[i]->IMFTopologyNode_iface);
 258     }
 259     heap_free(topology->nodes.nodes);
 260     topology->nodes.nodes = NULL;
 261     topology->nodes.count = 0;
 262     topology->nodes.size = 0;
 263 }
 264
 265 static ULONG WINAPI topology_Release(IMFTopology *iface)
 266 {
 267     struct topology *topology = impl_from_IMFTopology(iface);
 268     ULONG refcount = InterlockedDecrement(&topology->refcount);
 269
 270     TRACE("%p, refcount %u.\n", iface, refcount);
 271
 272     if (!refcount)
 273     {
 274         if (topology->attributes)
 275             IMFAttributes_Release(topology->attributes);
 276         topology_clear(topology);
 277         heap_free(topology);
 278     }
 279
 280     return refcount;
 281 }
 282
 283 static HRESULT WINAPI topology_GetItem(IMFTopology *iface, REFGUID key, PROPVARIANT *value)
 284 {
 285     struct topology *topology = impl_from_IMFTopology(iface);
 286
 287     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 288
 289     return IMFAttributes_GetItem(topology->attributes, key, value);
 290 }
 291
 292 static HRESULT WINAPI topology_GetItemType(IMFTopology *iface, REFGUID key, MF_ATTRIBUTE_TYPE *type)
 293 {
 294     struct topology *topology = impl_from_IMFTopology(iface);
 295
 296     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), type);
 297
 298     return IMFAttributes_GetItemType(topology->attributes, key, type);
 299 }
 300
 301 static HRESULT WINAPI topology_CompareItem(IMFTopology *iface, REFGUID key, REFPROPVARIANT value, BOOL *result)
 302 {
 303     struct topology *topology = impl_from_IMFTopology(iface);
 304
 305     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), value, result);
 306
 307     return IMFAttributes_CompareItem(topology->attributes, key, value, result);
 308 }
 309
 310 static HRESULT WINAPI topology_Compare(IMFTopology *iface, IMFAttributes *theirs, MF_ATTRIBUTES_MATCH_TYPE type,
 311         BOOL *result)
 312 {
 313     struct topology *topology = impl_from_IMFTopology(iface);
 314
 315     TRACE("%p, %p, %d, %p.\n", iface, theirs, type, result);
 316
 317     return IMFAttributes_Compare(topology->attributes, theirs, type, result);
 318 }
 319
 320 static HRESULT WINAPI topology_GetUINT32(IMFTopology *iface, REFGUID key, UINT32 *value)
 321 {
 322     struct topology *topology = impl_from_IMFTopology(iface);
 323
 324     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 325
 326     return IMFAttributes_GetUINT32(topology->attributes, key, value);
 327 }
 328
 329 static HRESULT WINAPI topology_GetUINT64(IMFTopology *iface, REFGUID key, UINT64 *value)
 330 {
 331     struct topology *topology = impl_from_IMFTopology(iface);
 332
 333     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 334
 335     return IMFAttributes_GetUINT64(topology->attributes, key, value);
 336 }
 337
 338 static HRESULT WINAPI topology_GetDouble(IMFTopology *iface, REFGUID key, double *value)
 339 {
 340     struct topology *topology = impl_from_IMFTopology(iface);
 341
 342     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 343
 344     return IMFAttributes_GetDouble(topology->attributes, key, value);
 345 }
 346
 347 static HRESULT WINAPI topology_GetGUID(IMFTopology *iface, REFGUID key, GUID *value)
 348 {
 349     struct topology *topology = impl_from_IMFTopology(iface);
 350
 351     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 352
 353     return IMFAttributes_GetGUID(topology->attributes, key, value);
 354 }
 355
 356 static HRESULT WINAPI topology_GetStringLength(IMFTopology *iface, REFGUID key, UINT32 *length)
 357 {
 358     struct topology *topology = impl_from_IMFTopology(iface);
 359
 360     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), length);
 361
 362     return IMFAttributes_GetStringLength(topology->attributes, key, length);
 363 }
 364
 365 static HRESULT WINAPI topology_GetString(IMFTopology *iface, REFGUID key, WCHAR *value,
 366         UINT32 size, UINT32 *length)
 367 {
 368     struct topology *topology = impl_from_IMFTopology(iface);
 369
 370     TRACE("%p, %s, %p, %d, %p.\n", iface, debugstr_guid(key), value, size, length);
 371
 372     return IMFAttributes_GetString(topology->attributes, key, value, size, length);
 373 }
 374
 375 static HRESULT WINAPI topology_GetAllocatedString(IMFTopology *iface, REFGUID key,
 376         WCHAR **value, UINT32 *length)
 377 {
 378     struct topology *topology = impl_from_IMFTopology(iface);
 379
 380     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), value, length);
 381
 382     return IMFAttributes_GetAllocatedString(topology->attributes, key, value, length);
 383 }
 384
 385 static HRESULT WINAPI topology_GetBlobSize(IMFTopology *iface, REFGUID key, UINT32 *size)
 386 {
 387     struct topology *topology = impl_from_IMFTopology(iface);
 388
 389     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), size);
 390
 391     return IMFAttributes_GetBlobSize(topology->attributes, key, size);
 392 }
 393
 394 static HRESULT WINAPI topology_GetBlob(IMFTopology *iface, REFGUID key, UINT8 *buf,
 395         UINT32 bufsize, UINT32 *blobsize)
 396 {
 397     struct topology *topology = impl_from_IMFTopology(iface);
 398
 399     TRACE("%p, %s, %p, %d, %p.\n", iface, debugstr_guid(key), buf, bufsize, blobsize);
 400
 401     return IMFAttributes_GetBlob(topology->attributes, key, buf, bufsize, blobsize);
 402 }
 403
 404 static HRESULT WINAPI topology_GetAllocatedBlob(IMFTopology *iface, REFGUID key, UINT8 **buf, UINT32 *size)
 405 {
 406     struct topology *topology = impl_from_IMFTopology(iface);
 407
 408     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), buf, size);
 409
 410     return IMFAttributes_GetAllocatedBlob(topology->attributes, key, buf, size);
 411 }
 412
 413 static HRESULT WINAPI topology_GetUnknown(IMFTopology *iface, REFGUID key, REFIID riid, void **ppv)
 414 {
 415     struct topology *topology = impl_from_IMFTopology(iface);
 416
 417     TRACE("%p, %s, %s, %p.\n", iface, debugstr_guid(key), debugstr_guid(riid), ppv);
 418
 419     return IMFAttributes_GetUnknown(topology->attributes, key, riid, ppv);
 420 }
 421
 422 static HRESULT WINAPI topology_SetItem(IMFTopology *iface, REFGUID key, REFPROPVARIANT value)
 423 {
 424     struct topology *topology = impl_from_IMFTopology(iface);
 425
 426     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 427
 428     return IMFAttributes_SetItem(topology->attributes, key, value);
 429 }
 430
 431 static HRESULT WINAPI topology_DeleteItem(IMFTopology *iface, REFGUID key)
 432 {
 433     struct topology *topology = impl_from_IMFTopology(iface);
 434
 435     TRACE("%p, %s.\n", topology, debugstr_guid(key));
 436
 437     return IMFAttributes_DeleteItem(topology->attributes, key);
 438 }
 439
 440 static HRESULT WINAPI topology_DeleteAllItems(IMFTopology *iface)
 441 {
 442     struct topology *topology = impl_from_IMFTopology(iface);
 443
 444     TRACE("%p.\n", iface);
 445
 446     return IMFAttributes_DeleteAllItems(topology->attributes);
 447 }
 448
 449 static HRESULT WINAPI topology_SetUINT32(IMFTopology *iface, REFGUID key, UINT32 value)
 450 {
 451     struct topology *topology = impl_from_IMFTopology(iface);
 452
 453     TRACE("%p, %s, %d.\n", iface, debugstr_guid(key), value);
 454
 455     return IMFAttributes_SetUINT32(topology->attributes, key, value);
 456 }
 457
 458 static HRESULT WINAPI topology_SetUINT64(IMFTopology *iface, REFGUID key, UINT64 value)
 459 {
 460     struct topology *topology = impl_from_IMFTopology(iface);
 461
 462     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), wine_dbgstr_longlong(value));
 463
 464     return IMFAttributes_SetUINT64(topology->attributes, key, value);
 465 }
 466
 467 static HRESULT WINAPI topology_SetDouble(IMFTopology *iface, REFGUID key, double value)
 468 {
 469     struct topology *topology = impl_from_IMFTopology(iface);
 470
 471     TRACE("%p, %s, %f.\n", iface, debugstr_guid(key), value);
 472
 473     return IMFAttributes_SetDouble(topology->attributes, key, value);
 474 }
 475
 476 static HRESULT WINAPI topology_SetGUID(IMFTopology *iface, REFGUID key, REFGUID value)
 477 {
 478     struct topology *topology = impl_from_IMFTopology(iface);
 479
 480     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), debugstr_guid(value));
 481
 482     return IMFAttributes_SetGUID(topology->attributes, key, value);
 483 }
 484
 485 static HRESULT WINAPI topology_SetString(IMFTopology *iface, REFGUID key, const WCHAR *value)
 486 {
 487     struct topology *topology = impl_from_IMFTopology(iface);
 488
 489     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), debugstr_w(value));
 490
 491     return IMFAttributes_SetString(topology->attributes, key, value);
 492 }
 493
 494 static HRESULT WINAPI topology_SetBlob(IMFTopology *iface, REFGUID key, const UINT8 *buf, UINT32 size)
 495 {
 496     struct topology *topology = impl_from_IMFTopology(iface);
 497
 498     TRACE("%p, %s, %p, %d.\n", iface, debugstr_guid(key), buf, size);
 499
 500     return IMFAttributes_SetBlob(topology->attributes, key, buf, size);
 501 }
 502
 503 static HRESULT WINAPI topology_SetUnknown(IMFTopology *iface, REFGUID key, IUnknown *unknown)
 504 {
 505     struct topology *topology = impl_from_IMFTopology(iface);
 506
 507     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), unknown);
 508
 509     return IMFAttributes_SetUnknown(topology->attributes, key, unknown);
 510 }
 511
 512 static HRESULT WINAPI topology_LockStore(IMFTopology *iface)
 513 {
 514     struct topology *topology = impl_from_IMFTopology(iface);
 515
 516     TRACE("%p.\n", iface);
 517
 518     return IMFAttributes_LockStore(topology->attributes);
 519 }
 520
 521 static HRESULT WINAPI topology_UnlockStore(IMFTopology *iface)
 522 {
 523     struct topology *topology = impl_from_IMFTopology(iface);
 524
 525     TRACE("%p.\n", iface);
 526
 527     return IMFAttributes_UnlockStore(topology->attributes);
 528 }
 529
 530 static HRESULT WINAPI topology_GetCount(IMFTopology *iface, UINT32 *count)
 531 {
 532     struct topology *topology = impl_from_IMFTopology(iface);
 533
 534     TRACE("%p, %p.\n", iface, count);
 535
 536     return IMFAttributes_GetCount(topology->attributes, count);
 537 }
 538
 539 static HRESULT WINAPI topology_GetItemByIndex(IMFTopology *iface, UINT32 index, GUID *key, PROPVARIANT *value)
 540 {
 541     struct topology *topology = impl_from_IMFTopology(iface);
 542
 543     TRACE("%p, %u, %p, %p.\n", iface, index, key, value);
 544
 545     return IMFAttributes_GetItemByIndex(topology->attributes, index, key, value);
 546 }
 547
 548 static HRESULT WINAPI topology_CopyAllItems(IMFTopology *iface, IMFAttributes *dest)
 549 {
 550     struct topology *topology = impl_from_IMFTopology(iface);
 551
 552     TRACE("%p, %p.\n", iface, dest);
 553
 554     return IMFAttributes_CopyAllItems(topology->attributes, dest);
 555 }
 556
 557 static HRESULT WINAPI topology_GetTopologyID(IMFTopology *iface, TOPOID *id)
 558 {
 559     struct topology *topology = impl_from_IMFTopology(iface);
 560
 561     TRACE("%p, %p.\n", iface, id);
 562
 563     if (!id)
 564         return E_POINTER;
 565
 566     *id = topology->id;
 567
 568     return S_OK;
 569 }
 570
 571 static HRESULT topology_get_node_by_id(const struct topology *topology, TOPOID id, struct topology_node **node)
 572 {
 573     size_t i = 0;
 574
 575     for (i = 0; i < topology->nodes.count; ++i)
 576     {
 577         if (topology->nodes.nodes[i]->id == id)
 578         {
 579             *node = topology->nodes.nodes[i];
 580             return S_OK;
 581         }
 582     }
 583
 584     return MF_E_NOT_FOUND;
 585 }
 586
 587 static HRESULT topology_add_node(struct topology *topology, struct topology_node *node)
 588 {
 589     struct topology_node *match;
 590
 591     if (!node)
 592         return E_POINTER;
 593
 594     if (SUCCEEDED(topology_get_node_by_id(topology, node->id, &match)))
 595         return E_INVALIDARG;
 596
 597     if (!mf_array_reserve((void **)&topology->nodes.nodes, &topology->nodes.size, topology->nodes.count + 1,
 598             sizeof(*topology->nodes.nodes)))
 599     {
 600         return E_OUTOFMEMORY;
 601     }
 602
 603     topology->nodes.nodes[topology->nodes.count++] = node;
 604     IMFTopologyNode_AddRef(&node->IMFTopologyNode_iface);
 605
 606     return S_OK;
 607 }
 608
 609 static HRESULT WINAPI topology_AddNode(IMFTopology *iface, IMFTopologyNode *node_iface)
 610 {
 611     struct topology *topology = impl_from_IMFTopology(iface);
 612     struct topology_node *node = unsafe_impl_from_IMFTopologyNode(node_iface);
 613
 614     TRACE("%p, %p.\n", iface, node_iface);
 615
 616     return topology_add_node(topology, node);
 617 }
 618
 619 static HRESULT WINAPI topology_RemoveNode(IMFTopology *iface, IMFTopologyNode *node)
 620 {
 621     struct topology *topology = impl_from_IMFTopology(iface);
 622     size_t i, count;
 623
 624     TRACE("%p, %p.\n", iface, node);
 625
 626     for (i = 0; i < topology->nodes.count; ++i)
 627     {
 628         if (&topology->nodes.nodes[i]->IMFTopologyNode_iface == node)
 629         {
 630             topology_node_disconnect(topology->nodes.nodes[i]);
 631             IMFTopologyNode_Release(&topology->nodes.nodes[i]->IMFTopologyNode_iface);
 632             count = topology->nodes.count - i - 1;
 633             if (count)
 634             {
 635                 memmove(&topology->nodes.nodes[i], &topology->nodes.nodes[i + 1],
 636                         count * sizeof(*topology->nodes.nodes));
 637             }
 638             topology->nodes.count--;
 639             return S_OK;
 640         }
 641     }
 642
 643     return E_INVALIDARG;
 644 }
 645
 646 static HRESULT WINAPI topology_GetNodeCount(IMFTopology *iface, WORD *count)
 647 {
 648     struct topology *topology = impl_from_IMFTopology(iface);
 649
 650     TRACE("%p, %p.\n", iface, count);
 651
 652     if (!count)
 653         return E_POINTER;
 654
 655     *count = topology->nodes.count;
 656
 657     return S_OK;
 658 }
 659
 660 static HRESULT WINAPI topology_GetNode(IMFTopology *iface, WORD index, IMFTopologyNode **node)
 661 {
 662     struct topology *topology = impl_from_IMFTopology(iface);
 663
 664     TRACE("%p, %u, %p.\n", iface, index, node);
 665
 666     if (!node)
 667         return E_POINTER;
 668
 669     if (index >= topology->nodes.count)
 670         return MF_E_INVALIDINDEX;
 671
 672     *node = &topology->nodes.nodes[index]->IMFTopologyNode_iface;
 673     IMFTopologyNode_AddRef(*node);
 674
 675     return S_OK;
 676 }
 677
 678 static HRESULT WINAPI topology_Clear(IMFTopology *iface)
 679 {
 680     struct topology *topology = impl_from_IMFTopology(iface);
 681
 682     TRACE("%p.\n", iface);
 683
 684     topology_clear(topology);
 685     return S_OK;
 686 }
 687
 688 static HRESULT WINAPI topology_CloneFrom(IMFTopology *iface, IMFTopology *src)
 689 {
 690     struct topology *topology = impl_from_IMFTopology(iface);
 691     struct topology *src_topology = unsafe_impl_from_IMFTopology(src);
 692     struct topology_node *node;
 693     size_t i, j;
 694     HRESULT hr;
 695
 696     TRACE("%p, %p.\n", iface, src);
 697
 698     topology_clear(topology);
 699
 700     /* Clone nodes. */
 701     for (i = 0; i < src_topology->nodes.count; ++i)
 702     {
 703         if (FAILED(hr = create_topology_node(src_topology->nodes.nodes[i]->node_type, &node)))
 704         {
 705             WARN("Failed to create a node, hr %#x.\n", hr);
 706             break;
 707         }
 708
 709         if (SUCCEEDED(hr = IMFTopologyNode_CloneFrom(&node->IMFTopologyNode_iface,
 710                 &src_topology->nodes.nodes[i]->IMFTopologyNode_iface)))
 711         {
 712             topology_add_node(topology, node);
 713         }
 714
 715         IMFTopologyNode_Release(&node->IMFTopologyNode_iface);
 716     }
 717
 718     /* Clone connections. */
 719     for (i = 0; i < src_topology->nodes.count; ++i)
 720     {
 721         const struct node_streams *outputs = &src_topology->nodes.nodes[i]->outputs;
 722
 723         for (j = 0; j < outputs->count; ++j)
 724         {
 725             DWORD input_index = outputs->streams[j].connection_stream;
 726             TOPOID id = outputs->streams[j].connection->id;
 727
 728             /* Skip node lookup in destination topology, assuming same node order. */
 729             if (SUCCEEDED(hr = topology_get_node_by_id(topology, id, &node)))
 730                 topology_node_connect_output(topology->nodes.nodes[i], j, node, input_index);
 731         }
 732     }
 733
 734     /* Copy attributes and id. */
 735     hr = IMFTopology_CopyAllItems(src, (IMFAttributes *)&topology->IMFTopology_iface);
 736     if (SUCCEEDED(hr))
 737         topology->id = src_topology->id;
 738
 739     return S_OK;
 740 }
 741
 742 static HRESULT WINAPI topology_GetNodeByID(IMFTopology *iface, TOPOID id, IMFTopologyNode **ret)
 743 {
 744     struct topology *topology = impl_from_IMFTopology(iface);
 745     struct topology_node *node;
 746     HRESULT hr;
 747
 748     TRACE("%p, %p.\n", iface, ret);
 749
 750     if (SUCCEEDED(hr = topology_get_node_by_id(topology, id, &node)))
 751     {
 752         *ret = &node->IMFTopologyNode_iface;
 753         IMFTopologyNode_AddRef(*ret);
 754     }
 755     else
 756         *ret = NULL;
 757
 758     return hr;
 759 }
 760
 761 static HRESULT topology_get_node_collection(const struct topology *topology, MF_TOPOLOGY_TYPE node_type,
 762         IMFCollection **collection)
 763 {
 764     HRESULT hr;
 765     size_t i;
 766
 767     if (!collection)
 768         return E_POINTER;
 769
 770     if (FAILED(hr = MFCreateCollection(collection)))
 771         return hr;
 772
 773     for (i = 0; i < topology->nodes.count; ++i)
 774     {
 775         if (topology->nodes.nodes[i]->node_type == node_type)
 776         {
 777             if (FAILED(hr = IMFCollection_AddElement(*collection,
 778                     (IUnknown *)&topology->nodes.nodes[i]->IMFTopologyNode_iface)))
 779             {
 780                 IMFCollection_Release(*collection);
 781                 *collection = NULL;
 782                 break;
 783             }
 784         }
 785     }
 786
 787     return hr;
 788 }
 789
 790 static HRESULT WINAPI topology_GetSourceNodeCollection(IMFTopology *iface, IMFCollection **collection)
 791 {
 792     struct topology *topology = impl_from_IMFTopology(iface);
 793
 794     TRACE("%p, %p.\n", iface, collection);
 795
 796     return topology_get_node_collection(topology, MF_TOPOLOGY_SOURCESTREAM_NODE, collection);
 797 }
 798
 799 static HRESULT WINAPI topology_GetOutputNodeCollection(IMFTopology *iface, IMFCollection **collection)
 800 {
 801     struct topology *topology = impl_from_IMFTopology(iface);
 802
 803     TRACE("%p, %p.\n", iface, collection);
 804
 805     return topology_get_node_collection(topology, MF_TOPOLOGY_OUTPUT_NODE, collection);
 806 }
 807
 808 static const IMFTopologyVtbl topologyvtbl =
 809 {
 810     topology_QueryInterface,
 811     topology_AddRef,
 812     topology_Release,
 813     topology_GetItem,
 814     topology_GetItemType,
 815     topology_CompareItem,
 816     topology_Compare,
 817     topology_GetUINT32,
 818     topology_GetUINT64,
 819     topology_GetDouble,
 820     topology_GetGUID,
 821     topology_GetStringLength,
 822     topology_GetString,
 823     topology_GetAllocatedString,
 824     topology_GetBlobSize,
 825     topology_GetBlob,
 826     topology_GetAllocatedBlob,
 827     topology_GetUnknown,
 828     topology_SetItem,
 829     topology_DeleteItem,
 830     topology_DeleteAllItems,
 831     topology_SetUINT32,
 832     topology_SetUINT64,
 833     topology_SetDouble,
 834     topology_SetGUID,
 835     topology_SetString,
 836     topology_SetBlob,
 837     topology_SetUnknown,
 838     topology_LockStore,
 839     topology_UnlockStore,
 840     topology_GetCount,
 841     topology_GetItemByIndex,
 842     topology_CopyAllItems,
 843     topology_GetTopologyID,
 844     topology_AddNode,
 845     topology_RemoveNode,
 846     topology_GetNodeCount,
 847     topology_GetNode,
 848     topology_Clear,
 849     topology_CloneFrom,
 850     topology_GetNodeByID,
 851     topology_GetSourceNodeCollection,
 852     topology_GetOutputNodeCollection,
 853 };
 854
 855 static struct topology *unsafe_impl_from_IMFTopology(IMFTopology *iface)
 856 {
 857     if (!iface || iface->lpVtbl != &topologyvtbl)
 858         return NULL;
 859     return impl_from_IMFTopology(iface);
 860 }
 861
 862 static TOPOID topology_generate_id(void)
 863 {
 864     TOPOID old;
 865
 866     do
 867     {
 868         old = next_topology_id;
 869     }
 870     while (InterlockedCompareExchange64((LONG64 *)&next_topology_id, old + 1, old) != old);
 871
 872     return next_topology_id;
 873 }
 874
 875 /***********************************************************************
 876  *      MFCreateTopology (mf.@)
 877  */
 878 HRESULT WINAPI MFCreateTopology(IMFTopology **topology)
 879 {
 880     struct topology *object;
 881     HRESULT hr;
 882
 883     TRACE("%p.\n", topology);
 884
 885     if (!topology)
 886         return E_POINTER;
 887
 888     object = heap_alloc_zero(sizeof(*object));
 889     if (!object)
 890         return E_OUTOFMEMORY;
 891
 892     object->IMFTopology_iface.lpVtbl = &topologyvtbl;
 893     object->refcount = 1;
 894
 895     hr = MFCreateAttributes(&object->attributes, 0);
 896     if (FAILED(hr))
 897     {
 898         IMFTopology_Release(&object->IMFTopology_iface);
 899         return hr;
 900     }
 901
 902     object->id = topology_generate_id();
 903
 904     *topology = &object->IMFTopology_iface;
 905
 906     return S_OK;
 907 }
 908
 909 static HRESULT WINAPI topology_node_QueryInterface(IMFTopologyNode *iface, REFIID riid, void **out)
 910 {
 911     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 912
 913     TRACE("%p, %s, %p.\n", iface, debugstr_guid(riid), out);
 914
 915     if (IsEqualIID(riid, &IID_IMFTopologyNode) ||
 916             IsEqualIID(riid, &IID_IMFAttributes) ||
 917             IsEqualIID(riid, &IID_IUnknown))
 918     {
 919         *out = &node->IMFTopologyNode_iface;
 920         IMFTopologyNode_AddRef(iface);
 921         return S_OK;
 922     }
 923
 924     WARN("Unsupported interface %s.\n", debugstr_guid(riid));
 925     *out = NULL;
 926
 927     return E_NOINTERFACE;
 928 }
 929
 930 static ULONG WINAPI topology_node_AddRef(IMFTopologyNode *iface)
 931 {
 932     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 933     ULONG refcount = InterlockedIncrement(&node->refcount);
 934
 935     TRACE("%p, refcount %u.\n", iface, refcount);
 936
 937     return refcount;
 938 }
 939
 940 static ULONG WINAPI topology_node_Release(IMFTopologyNode *iface)
 941 {
 942     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 943     ULONG refcount = InterlockedDecrement(&node->refcount);
 944     unsigned int i;
 945
 946     TRACE("%p, refcount %u.\n", iface, refcount);
 947
 948     if (!refcount)
 949     {
 950         if (node->object)
 951             IUnknown_Release(node->object);
 952         if (node->input_type)
 953             IMFMediaType_Release(node->input_type);
 954         for (i = 0; i < node->inputs.count; ++i)
 955         {
 956             if (node->inputs.streams[i].preferred_type)
 957                 IMFMediaType_Release(node->inputs.streams[i].preferred_type);
 958         }
 959         for (i = 0; i < node->outputs.count; ++i)
 960         {
 961             if (node->outputs.streams[i].preferred_type)
 962                 IMFMediaType_Release(node->outputs.streams[i].preferred_type);
 963         }
 964         heap_free(node->inputs.streams);
 965         heap_free(node->outputs.streams);
 966         IMFAttributes_Release(node->attributes);
 967         DeleteCriticalSection(&node->cs);
 968         heap_free(node);
 969     }
 970
 971     return refcount;
 972 }
 973
 974 static HRESULT WINAPI topology_node_GetItem(IMFTopologyNode *iface, REFGUID key, PROPVARIANT *value)
 975 {
 976     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 977
 978     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
 979
 980     return IMFAttributes_GetItem(node->attributes, key, value);
 981 }
 982
 983 static HRESULT WINAPI topology_node_GetItemType(IMFTopologyNode *iface, REFGUID key, MF_ATTRIBUTE_TYPE *type)
 984 {
 985     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 986
 987     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), type);
 988
 989     return IMFAttributes_GetItemType(node->attributes, key, type);
 990 }
 991
 992 static HRESULT WINAPI topology_node_CompareItem(IMFTopologyNode *iface, REFGUID key, REFPROPVARIANT value, BOOL *result)
 993 {
 994     struct topology_node *node = impl_from_IMFTopologyNode(iface);
 995
 996     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), value, result);
 997
 998     return IMFAttributes_CompareItem(node->attributes, key, value, result);
 999 }
1000
1001 static HRESULT WINAPI topology_node_Compare(IMFTopologyNode *iface, IMFAttributes *theirs,
1002         MF_ATTRIBUTES_MATCH_TYPE type, BOOL *result)
1003 {
1004     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1005
1006     TRACE("%p, %p, %d, %p.\n", iface, theirs, type, result);
1007
1008     return IMFAttributes_Compare(node->attributes, theirs, type, result);
1009 }
1010
1011 static HRESULT WINAPI topology_node_GetUINT32(IMFTopologyNode *iface, REFGUID key, UINT32 *value)
1012 {
1013     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1014
1015     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
1016
1017     return IMFAttributes_GetUINT32(node->attributes, key, value);
1018 }
1019
1020 static HRESULT WINAPI topology_node_GetUINT64(IMFTopologyNode *iface, REFGUID key, UINT64 *value)
1021 {
1022     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1023
1024     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
1025
1026     return IMFAttributes_GetUINT64(node->attributes, key, value);
1027 }
1028
1029 static HRESULT WINAPI topology_node_GetDouble(IMFTopologyNode *iface, REFGUID key, double *value)
1030 {
1031     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1032
1033     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
1034
1035     return IMFAttributes_GetDouble(node->attributes, key, value);
1036 }
1037
1038 static HRESULT WINAPI topology_node_GetGUID(IMFTopologyNode *iface, REFGUID key, GUID *value)
1039 {
1040     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1041
1042     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
1043
1044     return IMFAttributes_GetGUID(node->attributes, key, value);
1045 }
1046
1047 static HRESULT WINAPI topology_node_GetStringLength(IMFTopologyNode *iface, REFGUID key, UINT32 *length)
1048 {
1049     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1050
1051     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), length);
1052
1053     return IMFAttributes_GetStringLength(node->attributes, key, length);
1054 }
1055
1056 static HRESULT WINAPI topology_node_GetString(IMFTopologyNode *iface, REFGUID key, WCHAR *value,
1057         UINT32 size, UINT32 *length)
1058 {
1059     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1060
1061     TRACE("%p, %s, %p, %d, %p.\n", iface, debugstr_guid(key), value, size, length);
1062
1063     return IMFAttributes_GetString(node->attributes, key, value, size, length);
1064 }
1065
1066 static HRESULT WINAPI topology_node_GetAllocatedString(IMFTopologyNode *iface, REFGUID key,
1067         WCHAR **value, UINT32 *length)
1068 {
1069     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1070
1071     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), value, length);
1072
1073     return IMFAttributes_GetAllocatedString(node->attributes, key, value, length);
1074 }
1075
1076 static HRESULT WINAPI topology_node_GetBlobSize(IMFTopologyNode *iface, REFGUID key, UINT32 *size)
1077 {
1078     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1079
1080     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), size);
1081
1082     return IMFAttributes_GetBlobSize(node->attributes, key, size);
1083 }
1084
1085 static HRESULT WINAPI topology_node_GetBlob(IMFTopologyNode *iface, REFGUID key, UINT8 *buf,
1086         UINT32 bufsize, UINT32 *blobsize)
1087 {
1088     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1089
1090     TRACE("%p, %s, %p, %d, %p.\n", iface, debugstr_guid(key), buf, bufsize, blobsize);
1091
1092     return IMFAttributes_GetBlob(node->attributes, key, buf, bufsize, blobsize);
1093 }
1094
1095 static HRESULT WINAPI topology_node_GetAllocatedBlob(IMFTopologyNode *iface, REFGUID key, UINT8 **buf, UINT32 *size)
1096 {
1097     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1098
1099     TRACE("%p, %s, %p, %p.\n", iface, debugstr_guid(key), buf, size);
1100
1101     return IMFAttributes_GetAllocatedBlob(node->attributes, key, buf, size);
1102 }
1103
1104 static HRESULT WINAPI topology_node_GetUnknown(IMFTopologyNode *iface, REFGUID key, REFIID riid, void **ppv)
1105 {
1106     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1107
1108     TRACE("%p, %s, %s, %p.\n", iface, debugstr_guid(key), debugstr_guid(riid), ppv);
1109
1110     return IMFAttributes_GetUnknown(node->attributes, key, riid, ppv);
1111 }
1112
1113 static HRESULT WINAPI topology_node_SetItem(IMFTopologyNode *iface, REFGUID key, REFPROPVARIANT value)
1114 {
1115     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1116
1117     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), value);
1118
1119     return IMFAttributes_SetItem(node->attributes, key, value);
1120 }
1121
1122 static HRESULT WINAPI topology_node_DeleteItem(IMFTopologyNode *iface, REFGUID key)
1123 {
1124     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1125
1126     TRACE("%p, %s.\n", iface, debugstr_guid(key));
1127
1128     return IMFAttributes_DeleteItem(node->attributes, key);
1129 }
1130
1131 static HRESULT WINAPI topology_node_DeleteAllItems(IMFTopologyNode *iface)
1132 {
1133     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1134
1135     TRACE("%p.\n", iface);
1136
1137     return IMFAttributes_DeleteAllItems(node->attributes);
1138 }
1139
1140 static HRESULT WINAPI topology_node_SetUINT32(IMFTopologyNode *iface, REFGUID key, UINT32 value)
1141 {
1142     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1143
1144     TRACE("%p, %s, %d.\n", iface, debugstr_guid(key), value);
1145
1146     return IMFAttributes_SetUINT32(node->attributes, key, value);
1147 }
1148
1149 static HRESULT WINAPI topology_node_SetUINT64(IMFTopologyNode *iface, REFGUID key, UINT64 value)
1150 {
1151     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1152
1153     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), wine_dbgstr_longlong(value));
1154
1155     return IMFAttributes_SetUINT64(node->attributes, key, value);
1156 }
1157
1158 static HRESULT WINAPI topology_node_SetDouble(IMFTopologyNode *iface, REFGUID key, double value)
1159 {
1160     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1161
1162     TRACE("%p, %s, %f.\n", iface, debugstr_guid(key), value);
1163
1164     return IMFAttributes_SetDouble(node->attributes, key, value);
1165 }
1166
1167 static HRESULT WINAPI topology_node_SetGUID(IMFTopologyNode *iface, REFGUID key, REFGUID value)
1168 {
1169     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1170
1171     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), debugstr_guid(value));
1172
1173     return IMFAttributes_SetGUID(node->attributes, key, value);
1174 }
1175
1176 static HRESULT WINAPI topology_node_SetString(IMFTopologyNode *iface, REFGUID key, const WCHAR *value)
1177 {
1178     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1179
1180     TRACE("%p, %s, %s.\n", iface, debugstr_guid(key), debugstr_w(value));
1181
1182     return IMFAttributes_SetString(node->attributes, key, value);
1183 }
1184
1185 static HRESULT WINAPI topology_node_SetBlob(IMFTopologyNode *iface, REFGUID key, const UINT8 *buf, UINT32 size)
1186 {
1187     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1188
1189     TRACE("%p, %s, %p, %d.\n", iface, debugstr_guid(key), buf, size);
1190
1191     return IMFAttributes_SetBlob(node->attributes, key, buf, size);
1192 }
1193
1194 static HRESULT WINAPI topology_node_SetUnknown(IMFTopologyNode *iface, REFGUID key, IUnknown *unknown)
1195 {
1196     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1197
1198     TRACE("%p, %s, %p.\n", iface, debugstr_guid(key), unknown);
1199
1200     return IMFAttributes_SetUnknown(node->attributes, key, unknown);
1201 }
1202
1203 static HRESULT WINAPI topology_node_LockStore(IMFTopologyNode *iface)
1204 {
1205     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1206
1207     TRACE("%p.\n", iface);
1208
1209     return IMFAttributes_LockStore(node->attributes);
1210 }
1211
1212 static HRESULT WINAPI topology_node_UnlockStore(IMFTopologyNode *iface)
1213 {
1214     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1215
1216     TRACE("%p.\n", iface);
1217
1218     return IMFAttributes_UnlockStore(node->attributes);
1219 }
1220
1221 static HRESULT WINAPI topology_node_GetCount(IMFTopologyNode *iface, UINT32 *count)
1222 {
1223     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1224
1225     TRACE("%p, %p.\n", iface, count);
1226
1227     return IMFAttributes_GetCount(node->attributes, count);
1228 }
1229
1230 static HRESULT WINAPI topology_node_GetItemByIndex(IMFTopologyNode *iface, UINT32 index, GUID *key, PROPVARIANT *value)
1231 {
1232     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1233
1234     TRACE("%p, %u, %p, %p.\n", iface, index, key, value);
1235
1236     return IMFAttributes_GetItemByIndex(node->attributes, index, key, value);
1237 }
1238
1239 static HRESULT WINAPI topology_node_CopyAllItems(IMFTopologyNode *iface, IMFAttributes *dest)
1240 {
1241     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1242
1243     TRACE("%p, %p.\n", iface, dest);
1244
1245     return IMFAttributes_CopyAllItems(node->attributes, dest);
1246 }
1247
1248 static HRESULT topology_node_set_object(struct topology_node *node, IUnknown *object)
1249 {
1250     static const GUID *iids[3] = { &IID_IPersist, &IID_IPersistStorage, &IID_IPersistPropertyBag };
1251     IPersist *persist = NULL;
1252     BOOL has_object_id;
1253     GUID object_id;
1254     unsigned int i;
1255     HRESULT hr;
1256
1257     has_object_id = IMFAttributes_GetGUID(node->attributes, &MF_TOPONODE_TRANSFORM_OBJECTID, &object_id) == S_OK;
1258
1259     if (object && !has_object_id)
1260     {
1261         for (i = 0; i < ARRAY_SIZE(iids); ++i)
1262         {
1263             persist = NULL;
1264             if (SUCCEEDED(hr = IUnknown_QueryInterface(object, iids[i], (void **)&persist)))
1265                 break;
1266         }
1267
1268         if (persist)
1269         {
1270             if (FAILED(hr = IPersist_GetClassID(persist, &object_id)))
1271             {
1272                 IPersist_Release(persist);
1273                 persist = NULL;
1274             }
1275         }
1276     }
1277
1278     EnterCriticalSection(&node->cs);
1279
1280     if (node->object)
1281         IUnknown_Release(node->object);
1282     node->object = object;
1283     if (node->object)
1284         IUnknown_AddRef(node->object);
1285
1286     if (persist)
1287         IMFAttributes_SetGUID(node->attributes, &MF_TOPONODE_TRANSFORM_OBJECTID, &object_id);
1288
1289     LeaveCriticalSection(&node->cs);
1290
1291     if (persist)
1292         IPersist_Release(persist);
1293
1294     return S_OK;
1295 }
1296
1297 static HRESULT WINAPI topology_node_SetObject(IMFTopologyNode *iface, IUnknown *object)
1298 {
1299     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1300
1301     TRACE("%p, %p.\n", iface, object);
1302
1303     return topology_node_set_object(node, object);
1304 }
1305
1306 static HRESULT WINAPI topology_node_GetObject(IMFTopologyNode *iface, IUnknown **object)
1307 {
1308     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1309
1310     TRACE("%p, %p.\n", iface, object);
1311
1312     if (!object)
1313         return E_POINTER;
1314
1315     EnterCriticalSection(&node->cs);
1316
1317     *object = node->object;
1318     if (*object)
1319         IUnknown_AddRef(*object);
1320
1321     LeaveCriticalSection(&node->cs);
1322
1323     return *object ? S_OK : E_FAIL;
1324 }
1325
1326 static HRESULT WINAPI topology_node_GetNodeType(IMFTopologyNode *iface, MF_TOPOLOGY_TYPE *node_type)
1327 {
1328     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1329
1330     TRACE("%p, %p.\n", iface, node_type);
1331
1332     *node_type = node->node_type;
1333
1334     return S_OK;
1335 }
1336
1337 static HRESULT WINAPI topology_node_GetTopoNodeID(IMFTopologyNode *iface, TOPOID *id)
1338 {
1339     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1340
1341     TRACE("%p, %p.\n", iface, id);
1342
1343     *id = node->id;
1344
1345     return S_OK;
1346 }
1347
1348 static HRESULT WINAPI topology_node_SetTopoNodeID(IMFTopologyNode *iface, TOPOID id)
1349 {
1350     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1351
1352     TRACE("%p, %s.\n", iface, wine_dbgstr_longlong(id));
1353
1354     node->id = id;
1355
1356     return S_OK;
1357 }
1358
1359 static HRESULT WINAPI topology_node_GetInputCount(IMFTopologyNode *iface, DWORD *count)
1360 {
1361     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1362
1363     TRACE("%p, %p.\n", iface, count);
1364
1365     *count = node->inputs.count;
1366
1367     return S_OK;
1368 }
1369
1370 static HRESULT WINAPI topology_node_GetOutputCount(IMFTopologyNode *iface, DWORD *count)
1371 {
1372     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1373
1374     TRACE("%p, %p.\n", iface, count);
1375
1376     *count = node->outputs.count;
1377
1378     return S_OK;
1379 }
1380
1381 static void topology_node_set_stream_type(struct node_stream *stream, IMFMediaType *mediatype)
1382 {
1383     if (stream->preferred_type)
1384         IMFMediaType_Release(stream->preferred_type);
1385     stream->preferred_type = mediatype;
1386     if (stream->preferred_type)
1387         IMFMediaType_AddRef(stream->preferred_type);
1388 }
1389
1390 static HRESULT topology_node_connect_output(struct topology_node *node, DWORD output_index,
1391         struct topology_node *connection, DWORD input_index)
1392 {
1393     struct node_stream *stream;
1394     HRESULT hr;
1395
1396     if (node->node_type == MF_TOPOLOGY_OUTPUT_NODE || connection->node_type == MF_TOPOLOGY_SOURCESTREAM_NODE)
1397          return E_FAIL;
1398
1399     EnterCriticalSection(&node->cs);
1400     EnterCriticalSection(&connection->cs);
1401
1402     topology_node_disconnect_output(node, output_index);
1403     if (input_index < connection->inputs.count)
1404     {
1405         stream = &connection->inputs.streams[input_index];
1406         if (stream->connection)
1407             topology_node_disconnect_output(stream->connection, stream->connection_stream);
1408     }
1409
1410     hr = topology_node_reserve_streams(&node->outputs, output_index);
1411     if (SUCCEEDED(hr))
1412     {
1413         size_t old_count = connection->inputs.count;
1414         hr = topology_node_reserve_streams(&connection->inputs, input_index);
1415         if (SUCCEEDED(hr) && !old_count && connection->input_type)
1416         {
1417             topology_node_set_stream_type(connection->inputs.streams, connection->input_type);
1418             IMFMediaType_Release(connection->input_type);
1419             connection->input_type = NULL;
1420         }
1421     }
1422
1423     if (SUCCEEDED(hr))
1424     {
1425         node->outputs.streams[output_index].connection = connection;
1426         IMFTopologyNode_AddRef(&node->outputs.streams[output_index].connection->IMFTopologyNode_iface);
1427         node->outputs.streams[output_index].connection_stream = input_index;
1428         connection->inputs.streams[input_index].connection = node;
1429         IMFTopologyNode_AddRef(&connection->inputs.streams[input_index].connection->IMFTopologyNode_iface);
1430         connection->inputs.streams[input_index].connection_stream = output_index;
1431     }
1432
1433     LeaveCriticalSection(&connection->cs);
1434     LeaveCriticalSection(&node->cs);
1435
1436     return hr;
1437 }
1438
1439 static HRESULT WINAPI topology_node_ConnectOutput(IMFTopologyNode *iface, DWORD output_index,
1440         IMFTopologyNode *peer, DWORD input_index)
1441 {
1442     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1443     struct topology_node *connection = unsafe_impl_from_IMFTopologyNode(peer);
1444
1445     TRACE("%p, %u, %p, %u.\n", iface, output_index, peer, input_index);
1446
1447     if (!connection)
1448     {
1449         WARN("External node implementations are not supported.\n");
1450         return E_UNEXPECTED;
1451     }
1452
1453     return topology_node_connect_output(node, output_index, connection, input_index);
1454 }
1455
1456 static HRESULT WINAPI topology_node_DisconnectOutput(IMFTopologyNode *iface, DWORD output_index)
1457 {
1458     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1459
1460     TRACE("%p, %u.\n", iface, output_index);
1461
1462     return topology_node_disconnect_output(node, output_index);
1463 }
1464
1465 static HRESULT WINAPI topology_node_GetInput(IMFTopologyNode *iface, DWORD input_index, IMFTopologyNode **ret,
1466         DWORD *output_index)
1467 {
1468     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1469     HRESULT hr = S_OK;
1470
1471     TRACE("%p, %u, %p, %p.\n", iface, input_index, ret, output_index);
1472
1473     EnterCriticalSection(&node->cs);
1474
1475     if (input_index < node->inputs.count)
1476     {
1477         const struct node_stream *stream = &node->inputs.streams[input_index];
1478
1479         if (stream->connection)
1480         {
1481             *ret = &stream->connection->IMFTopologyNode_iface;
1482             IMFTopologyNode_AddRef(*ret);
1483             *output_index = stream->connection_stream;
1484         }
1485         else
1486             hr = MF_E_NOT_FOUND;
1487     }
1488     else
1489         hr = E_INVALIDARG;
1490
1491     LeaveCriticalSection(&node->cs);
1492
1493     return hr;
1494 }
1495
1496 static HRESULT WINAPI topology_node_GetOutput(IMFTopologyNode *iface, DWORD output_index, IMFTopologyNode **ret,
1497         DWORD *input_index)
1498 {
1499     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1500     HRESULT hr = S_OK;
1501
1502     TRACE("%p, %u, %p, %p.\n", iface, output_index, ret, input_index);
1503
1504     EnterCriticalSection(&node->cs);
1505
1506     if (output_index < node->outputs.count)
1507     {
1508         const struct node_stream *stream = &node->outputs.streams[output_index];
1509
1510         if (stream->connection)
1511         {
1512             *ret = &stream->connection->IMFTopologyNode_iface;
1513             IMFTopologyNode_AddRef(*ret);
1514             *input_index = stream->connection_stream;
1515         }
1516         else
1517             hr = MF_E_NOT_FOUND;
1518     }
1519     else
1520         hr = E_INVALIDARG;
1521
1522     LeaveCriticalSection(&node->cs);
1523
1524     return hr;
1525 }
1526
1527 static HRESULT WINAPI topology_node_SetOutputPrefType(IMFTopologyNode *iface, DWORD index, IMFMediaType *mediatype)
1528 {
1529     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1530     HRESULT hr = S_OK;
1531
1532     TRACE("%p, %u, %p.\n", iface, index, mediatype);
1533
1534     EnterCriticalSection(&node->cs);
1535
1536     if (node->node_type != MF_TOPOLOGY_OUTPUT_NODE)
1537     {
1538         if (SUCCEEDED(hr = topology_node_reserve_streams(&node->outputs, index)))
1539             topology_node_set_stream_type(&node->outputs.streams[index], mediatype);
1540     }
1541     else
1542         hr = E_NOTIMPL;
1543
1544     LeaveCriticalSection(&node->cs);
1545
1546     return hr;
1547 }
1548
1549 static HRESULT topology_node_get_pref_type(struct node_streams *streams, unsigned int index, IMFMediaType **mediatype)
1550 {
1551     *mediatype = streams->streams[index].preferred_type;
1552     if (*mediatype)
1553     {
1554         IMFMediaType_AddRef(*mediatype);
1555         return S_OK;
1556     }
1557
1558     return E_FAIL;
1559 }
1560
1561 static HRESULT WINAPI topology_node_GetOutputPrefType(IMFTopologyNode *iface, DWORD index, IMFMediaType **mediatype)
1562 {
1563     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1564     HRESULT hr = S_OK;
1565
1566     TRACE("%p, %u, %p.\n", iface, index, mediatype);
1567
1568     EnterCriticalSection(&node->cs);
1569
1570     if (index < node->outputs.count)
1571         hr = topology_node_get_pref_type(&node->outputs, index, mediatype);
1572     else
1573         hr = E_INVALIDARG;
1574
1575     LeaveCriticalSection(&node->cs);
1576
1577     return hr;
1578 }
1579
1580 static HRESULT WINAPI topology_node_SetInputPrefType(IMFTopologyNode *iface, DWORD index, IMFMediaType *mediatype)
1581 {
1582     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1583     HRESULT hr = S_OK;
1584
1585     TRACE("%p, %u, %p.\n", iface, index, mediatype);
1586
1587     EnterCriticalSection(&node->cs);
1588
1589     switch (node->node_type)
1590     {
1591         case MF_TOPOLOGY_TEE_NODE:
1592             if (index)
1593             {
1594                 hr = MF_E_INVALIDTYPE;
1595                 break;
1596             }
1597             if (node->inputs.count)
1598                 topology_node_set_stream_type(&node->inputs.streams[index], mediatype);
1599             else
1600             {
1601                 if (node->input_type)
1602                     IMFMediaType_Release(node->input_type);
1603                 node->input_type = mediatype;
1604                 if (node->input_type)
1605                     IMFMediaType_AddRef(node->input_type);
1606             }
1607             break;
1608         case MF_TOPOLOGY_SOURCESTREAM_NODE:
1609             hr = E_NOTIMPL;
1610             break;
1611         default:
1612             if (SUCCEEDED(hr = topology_node_reserve_streams(&node->inputs, index)))
1613                 topology_node_set_stream_type(&node->inputs.streams[index], mediatype);
1614     }
1615
1616     LeaveCriticalSection(&node->cs);
1617
1618     return hr;
1619 }
1620
1621 static HRESULT WINAPI topology_node_GetInputPrefType(IMFTopologyNode *iface, DWORD index, IMFMediaType **mediatype)
1622 {
1623     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1624     HRESULT hr = S_OK;
1625
1626     TRACE("%p, %u, %p.\n", iface, index, mediatype);
1627
1628     EnterCriticalSection(&node->cs);
1629
1630     if (index < node->inputs.count)
1631     {
1632         hr = topology_node_get_pref_type(&node->inputs, index, mediatype);
1633     }
1634     else if (node->node_type == MF_TOPOLOGY_TEE_NODE && node->input_type)
1635     {
1636         *mediatype = node->input_type;
1637         IMFMediaType_AddRef(*mediatype);
1638     }
1639     else
1640         hr = E_INVALIDARG;
1641
1642     LeaveCriticalSection(&node->cs);
1643
1644     return hr;
1645 }
1646
1647 static HRESULT WINAPI topology_node_CloneFrom(IMFTopologyNode *iface, IMFTopologyNode *src_node)
1648 {
1649     struct topology_node *node = impl_from_IMFTopologyNode(iface);
1650     MF_TOPOLOGY_TYPE node_type;
1651     IMFMediaType *mediatype;
1652     IUnknown *object;
1653     DWORD count, i;
1654     TOPOID topoid;
1655     HRESULT hr;
1656
1657     TRACE("%p, %p.\n", iface, src_node);
1658
1659     if (FAILED(hr = IMFTopologyNode_GetNodeType(src_node, &node_type)))
1660         return hr;
1661
1662     if (node->node_type != node_type)
1663         return MF_E_INVALIDREQUEST;
1664
1665     if (FAILED(hr = IMFTopologyNode_GetTopoNodeID(src_node, &topoid)))
1666         return hr;
1667
1668     object = NULL;
1669     IMFTopologyNode_GetObject(src_node, &object);
1670
1671     EnterCriticalSection(&node->cs);
1672
1673     hr = IMFTopologyNode_CopyAllItems(src_node, node->attributes);
1674
1675     if (SUCCEEDED(hr))
1676         hr = topology_node_set_object(node, object);
1677
1678     if (SUCCEEDED(hr))
1679         node->id = topoid;
1680
1681     if (SUCCEEDED(IMFTopologyNode_GetInputCount(src_node, &count)))
1682     {
1683         for (i = 0; i < count; ++i)
1684         {
1685             if (SUCCEEDED(IMFTopologyNode_GetInputPrefType(src_node, i, &mediatype)))
1686             {
1687                 IMFTopologyNode_SetInputPrefType(iface, i, mediatype);
1688                 IMFMediaType_Release(mediatype);
1689             }
1690         }
1691     }
1692
1693     if (SUCCEEDED(IMFTopologyNode_GetOutputCount(src_node, &count)))
1694     {
1695         for (i = 0; i < count; ++i)
1696         {
1697             if (SUCCEEDED(IMFTopologyNode_GetOutputPrefType(src_node, i, &mediatype)))
1698             {
1699                 IMFTopologyNode_SetOutputPrefType(iface, i, mediatype);
1700                 IMFMediaType_Release(mediatype);
1701             }
1702         }
1703     }
1704
1705     LeaveCriticalSection(&node->cs);
1706
1707     if (object)
1708         IUnknown_Release(object);
1709
1710     return hr;
1711 }
1712
1713 static const IMFTopologyNodeVtbl topologynodevtbl =
1714 {
1715     topology_node_QueryInterface,
1716     topology_node_AddRef,
1717     topology_node_Release,
1718     topology_node_GetItem,
1719     topology_node_GetItemType,
1720     topology_node_CompareItem,
1721     topology_node_Compare,
1722     topology_node_GetUINT32,
1723     topology_node_GetUINT64,
1724     topology_node_GetDouble,
1725     topology_node_GetGUID,
1726     topology_node_GetStringLength,
1727     topology_node_GetString,
1728     topology_node_GetAllocatedString,
1729     topology_node_GetBlobSize,
1730     topology_node_GetBlob,
1731     topology_node_GetAllocatedBlob,
1732     topology_node_GetUnknown,
1733     topology_node_SetItem,
1734     topology_node_DeleteItem,
1735     topology_node_DeleteAllItems,
1736     topology_node_SetUINT32,
1737     topology_node_SetUINT64,
1738     topology_node_SetDouble,
1739     topology_node_SetGUID,
1740     topology_node_SetString,
1741     topology_node_SetBlob,
1742     topology_node_SetUnknown,
1743     topology_node_LockStore,
1744     topology_node_UnlockStore,
1745     topology_node_GetCount,
1746     topology_node_GetItemByIndex,
1747     topology_node_CopyAllItems,
1748     topology_node_SetObject,
1749     topology_node_GetObject,
1750     topology_node_GetNodeType,
1751     topology_node_GetTopoNodeID,
1752     topology_node_SetTopoNodeID,
1753     topology_node_GetInputCount,
1754     topology_node_GetOutputCount,
1755     topology_node_ConnectOutput,
1756     topology_node_DisconnectOutput,
1757     topology_node_GetInput,
1758     topology_node_GetOutput,
1759     topology_node_SetOutputPrefType,
1760     topology_node_GetOutputPrefType,
1761     topology_node_SetInputPrefType,
1762     topology_node_GetInputPrefType,
1763     topology_node_CloneFrom,
1764 };
1765
1766 static HRESULT create_topology_node(MF_TOPOLOGY_TYPE node_type, struct topology_node **node)
1767 {
1768     HRESULT hr;
1769
1770     *node = heap_alloc_zero(sizeof(**node));
1771     if (!*node)
1772         return E_OUTOFMEMORY;
1773
1774     (*node)->IMFTopologyNode_iface.lpVtbl = &topologynodevtbl;
1775     (*node)->refcount = 1;
1776     (*node)->node_type = node_type;
1777     hr = MFCreateAttributes(&(*node)->attributes, 0);
1778     if (FAILED(hr))
1779     {
1780         heap_free(*node);
1781         return hr;
1782     }
1783     (*node)->id = ((TOPOID)GetCurrentProcessId() << 32) | InterlockedIncrement(&next_node_id);
1784     InitializeCriticalSection(&(*node)->cs);
1785
1786     return S_OK;
1787 }
1788
1789 /***********************************************************************
1790  *      MFCreateTopologyNode (mf.@)
1791  */
1792 HRESULT WINAPI MFCreateTopologyNode(MF_TOPOLOGY_TYPE node_type, IMFTopologyNode **node)
1793 {
1794     struct topology_node *object;
1795     HRESULT hr;
1796
1797     TRACE("%d, %p.\n", node_type, node);
1798
1799     if (!node)
1800         return E_POINTER;
1801
1802     hr = create_topology_node(node_type, &object);
1803     if (SUCCEEDED(hr))
1804         *node = &object->IMFTopologyNode_iface;
1805
1806     return hr;
1807 }
1808
1809 /***********************************************************************
1810  *      MFGetTopoNodeCurrentType (mf.@)
1811  */
1812 HRESULT WINAPI MFGetTopoNodeCurrentType(IMFTopologyNode *node, DWORD stream, BOOL output, IMFMediaType **type)
1813 {
1814     IMFMediaTypeHandler *type_handler;
1815     MF_TOPOLOGY_TYPE node_type;
1816     IMFStreamSink *stream_sink;
1817     IMFStreamDescriptor *sd;
1818     IMFTransform *transform;
1819     UINT32 primary_output;
1820     IUnknown *object;
1821     HRESULT hr;
1822
1823     TRACE("%p, %u, %d, %p.\n", node, stream, output, type);
1824
1825     if (FAILED(hr = IMFTopologyNode_GetNodeType(node, &node_type)))
1826         return hr;
1827
1828     switch (node_type)
1829     {
1830         case MF_TOPOLOGY_OUTPUT_NODE:
1831             if (FAILED(hr = IMFTopologyNode_GetObject(node, &object)))
1832                 return hr;
1833
1834             hr = IUnknown_QueryInterface(object, &IID_IMFStreamSink, (void **)&stream_sink);
1835             IUnknown_Release(object);
1836             if (SUCCEEDED(hr))
1837             {
1838                 hr = IMFStreamSink_GetMediaTypeHandler(stream_sink, &type_handler);
1839                 IMFStreamSink_Release(stream_sink);
1840
1841                 if (SUCCEEDED(hr))
1842                 {
1843                     hr = IMFMediaTypeHandler_GetCurrentMediaType(type_handler, type);
1844                     IMFMediaTypeHandler_Release(type_handler);
1845                 }
1846             }
1847             break;
1848         case MF_TOPOLOGY_SOURCESTREAM_NODE:
1849             if (FAILED(hr = IMFTopologyNode_GetUnknown(node, &MF_TOPONODE_STREAM_DESCRIPTOR, &IID_IMFStreamDescriptor,
1850                     (void **)&sd)))
1851             {
1852                 return hr;
1853             }
1854
1855             hr = IMFStreamDescriptor_GetMediaTypeHandler(sd, &type_handler);
1856             IMFStreamDescriptor_Release(sd);
1857             if (SUCCEEDED(hr))
1858             {
1859                 hr = IMFMediaTypeHandler_GetCurrentMediaType(type_handler, type);
1860                 IMFMediaTypeHandler_Release(type_handler);
1861             }
1862             break;
1863         case MF_TOPOLOGY_TRANSFORM_NODE:
1864             if (FAILED(hr = IMFTopologyNode_GetObject(node, &object)))
1865                 return hr;
1866
1867             hr = IUnknown_QueryInterface(object, &IID_IMFTransform, (void **)&transform);
1868             IUnknown_Release(object);
1869             if (SUCCEEDED(hr))
1870             {
1871                 if (output)
1872                     hr = IMFTransform_GetOutputCurrentType(transform, stream, type);
1873                 else
1874                     hr = IMFTransform_GetInputCurrentType(transform, stream, type);
1875                 IMFTransform_Release(transform);
1876             }
1877             break;
1878         case MF_TOPOLOGY_TEE_NODE:
1879             if (SUCCEEDED(hr = IMFTopologyNode_GetInputPrefType(node, 0, type)))
1880                 break;
1881
1882             if (FAILED(IMFTopologyNode_GetUINT32(node, &MF_TOPONODE_PRIMARYOUTPUT, &primary_output)))
1883                 primary_output = 0;
1884
1885             hr = IMFTopologyNode_GetOutputPrefType(node, primary_output, type);
1886             break;
1887         default:
1888             ;
1889     }
1890
1891     return hr;
1892 }
1893
1894 static HRESULT WINAPI topology_loader_QueryInterface(IMFTopoLoader *iface, REFIID riid, void **out)
1895 {
1896     TRACE("%p, %s, %p.\n", iface, debugstr_guid(riid), out);
1897
1898     if (IsEqualIID(riid, &IID_IMFTopoLoader) ||
1899             IsEqualIID(riid, &IID_IUnknown))
1900     {
1901         *out = iface;
1902         IMFTopoLoader_AddRef(iface);
1903         return S_OK;
1904     }
1905
1906     WARN("Unsupported %s.\n", debugstr_guid(riid));
1907     *out = NULL;
1908     return E_NOINTERFACE;
1909 }
1910
1911 static ULONG WINAPI topology_loader_AddRef(IMFTopoLoader *iface)
1912 {
1913     struct topology_loader *loader = impl_from_IMFTopoLoader(iface);
1914     ULONG refcount = InterlockedIncrement(&loader->refcount);
1915
1916     TRACE("%p, refcount %u.\n", iface, refcount);
1917
1918     return refcount;
1919 }
1920
1921 static ULONG WINAPI topology_loader_Release(IMFTopoLoader *iface)
1922 {
1923     struct topology_loader *loader = impl_from_IMFTopoLoader(iface);
1924     ULONG refcount = InterlockedDecrement(&loader->refcount);
1925
1926     TRACE("%p, refcount %u.\n", iface, refcount);
1927
1928     if (!refcount)
1929     {
1930         heap_free(loader);
1931     }
1932
1933     return refcount;
1934 }
1935
1936 struct topoloader_context
1937 {
1938     IMFTopology *input_topology;
1939     IMFTopology *output_topology;
1940     unsigned int marker;
1941     GUID key;
1942 };
1943
1944 static IMFTopologyNode *topology_loader_get_node_for_marker(struct topoloader_context *context, TOPOID *id)
1945 {
1946     IMFTopologyNode *node;
1947     unsigned short i = 0;
1948     unsigned int value;
1949
1950     while (SUCCEEDED(IMFTopology_GetNode(context->output_topology, i++, &node)))
1951     {
1952         if (SUCCEEDED(IMFTopologyNode_GetUINT32(node, &context->key, &value)) && value == context->marker)
1953         {
1954             IMFTopologyNode_GetTopoNodeID(node, id);
1955             return node;
1956         }
1957         IMFTopologyNode_Release(node);
1958     }
1959
1960     *id = 0;
1961     return NULL;
1962 }
1963
1964 static HRESULT topology_loader_clone_node(struct topoloader_context *context, IMFTopologyNode *node,
1965         IMFTopologyNode **ret, unsigned int marker)
1966 {
1967     IMFTopologyNode *cloned_node;
1968     MF_TOPOLOGY_TYPE node_type;
1969     HRESULT hr;
1970
1971     if (ret) *ret = NULL;
1972
1973     IMFTopologyNode_GetNodeType(node, &node_type);
1974
1975     if (FAILED(hr = MFCreateTopologyNode(node_type, &cloned_node)))
1976         return hr;
1977
1978     if (SUCCEEDED(hr = IMFTopologyNode_CloneFrom(cloned_node, node)))
1979         hr = IMFTopologyNode_SetUINT32(cloned_node, &context->key, marker);
1980
1981     if (SUCCEEDED(hr))
1982         hr = IMFTopology_AddNode(context->output_topology, cloned_node);
1983
1984     if (SUCCEEDED(hr) && ret)
1985     {
1986         *ret = cloned_node;
1987         IMFTopologyNode_AddRef(*ret);
1988     }
1989
1990     IMFTopologyNode_Release(cloned_node);
1991
1992     return hr;
1993 }
1994
1995 typedef HRESULT (*p_topology_loader_connect_func)(struct topoloader_context *context, IMFTopologyNode *upstream_node,
1996         unsigned int output_index, IMFTopologyNode *downstream_node, unsigned int input_index);
1997
1998 static HRESULT topology_loader_connect_source_node(struct topoloader_context *context, IMFTopologyNode *upstream_node,
1999         unsigned int output_index, IMFTopologyNode *downstream_node, unsigned int input_index)
2000 {
2001     FIXME("Unimplemented.\n");
2002
2003     return E_NOTIMPL;
2004 }
2005
2006 static HRESULT topology_loader_resolve_branch(struct topoloader_context *context, IMFTopologyNode *upstream_node,
2007         unsigned int output_index, IMFTopologyNode *downstream_node, unsigned input_index)
2008 {
2009     static const p_topology_loader_connect_func connectors[MF_TOPOLOGY_TEE_NODE+1][MF_TOPOLOGY_TEE_NODE+1] =
2010     {
2011           /* OUTPUT */ { NULL },
2012     /* SOURCESTREAM */ { topology_loader_connect_source_node, NULL, NULL, NULL },
2013        /* TRANSFORM */ { NULL },
2014              /* TEE */ { NULL },
2015     };
2016     MF_TOPOLOGY_TYPE u_type, d_type;
2017     IMFTopologyNode *node;
2018     TOPOID id;
2019
2020     /* Downstream node might have already been cloned. */
2021     IMFTopologyNode_GetTopoNodeID(downstream_node, &id);
2022     if (FAILED(IMFTopology_GetNodeByID(context->output_topology, id, &node)))
2023         topology_loader_clone_node(context, downstream_node, &node, context->marker + 1);
2024
2025     IMFTopologyNode_ConnectOutput(upstream_node, output_index, node, input_index);
2026
2027     IMFTopologyNode_GetNodeType(upstream_node, &u_type);
2028     IMFTopologyNode_GetNodeType(downstream_node, &d_type);
2029
2030     if (!connectors[u_type][d_type])
2031     {
2032         WARN("Unsupported branch kind %d -> %d.\n", u_type, d_type);
2033         return E_FAIL;
2034     }
2035
2036     return connectors[u_type][d_type](context, upstream_node, output_index, downstream_node, input_index);
2037 }
2038
2039 static HRESULT topology_loader_resolve_nodes(struct topoloader_context *context, unsigned int *layer_size)
2040 {
2041     IMFTopologyNode *downstream_node, *node, *orig_node;
2042     unsigned int input_index, size = 0;
2043     MF_TOPOLOGY_TYPE node_type;
2044     HRESULT hr = S_OK;
2045     TOPOID id;
2046
2047     while ((node = topology_loader_get_node_for_marker(context, &id)))
2048     {
2049         ++size;
2050
2051         IMFTopology_GetNodeByID(context->input_topology, id, &orig_node);
2052
2053         IMFTopologyNode_GetNodeType(node, &node_type);
2054         switch (node_type)
2055         {
2056             case MF_TOPOLOGY_SOURCESTREAM_NODE:
2057                 if (FAILED(IMFTopologyNode_GetOutput(orig_node, 0, &downstream_node, &input_index)))
2058                 {
2059                     IMFTopology_RemoveNode(context->output_topology, node);
2060                     continue;
2061                 }
2062
2063                 hr = topology_loader_resolve_branch(context, node, 0, downstream_node, input_index);
2064                 break;
2065             case MF_TOPOLOGY_TRANSFORM_NODE:
2066             case MF_TOPOLOGY_TEE_NODE:
2067                 FIXME("Unsupported node type %d.\n", node_type);
2068                 break;
2069             default:
2070                 WARN("Unexpected node type %d.\n", node_type);
2071         }
2072
2073         IMFTopologyNode_DeleteItem(node, &context->key);
2074
2075         if (FAILED(hr))
2076             break;
2077     }
2078
2079     *layer_size = size;
2080
2081     return hr;
2082 }
2083
2084 static HRESULT WINAPI topology_loader_Load(IMFTopoLoader *iface, IMFTopology *input_topology,
2085         IMFTopology **ret_topology, IMFTopology *current_topology)
2086 {
2087     struct topoloader_context context = { 0 };
2088     IMFTopology *output_topology;
2089     MF_TOPOLOGY_TYPE node_type;
2090     unsigned int layer_size;
2091     IMFTopologyNode *node;
2092     unsigned short i = 0;
2093     IMFStreamSink *sink;
2094     IUnknown *object;
2095     HRESULT hr = E_FAIL;
2096
2097     FIXME("%p, %p, %p, %p.\n", iface, input_topology, ret_topology, current_topology);
2098
2099     if (current_topology)
2100         FIXME("Current topology instance is ignored.\n");
2101
2102     /* Basic sanity checks for input topology:
2103
2104        - source nodes must have stream descriptor set;
2105        - sink nodes must be resolved to stream sink objects;
2106     */
2107     while (SUCCEEDED(IMFTopology_GetNode(input_topology, i++, &node)))
2108     {
2109         IMFTopologyNode_GetNodeType(node, &node_type);
2110
2111         switch (node_type)
2112         {
2113             case MF_TOPOLOGY_OUTPUT_NODE:
2114                 if (SUCCEEDED(hr = IMFTopologyNode_GetObject(node, &object)))
2115                 {
2116                     /* Sinks must be bound beforehand. */
2117                     if (FAILED(IUnknown_QueryInterface(object, &IID_IMFStreamSink, (void **)&sink)))
2118                         hr = MF_E_TOPO_SINK_ACTIVATES_UNSUPPORTED;
2119                     else if (sink)
2120                         IMFStreamSink_Release(sink);
2121                     IUnknown_Release(object);
2122                 }
2123                 break;
2124             case MF_TOPOLOGY_SOURCESTREAM_NODE:
2125                 hr = IMFTopologyNode_GetItem(node, &MF_TOPONODE_STREAM_DESCRIPTOR, NULL);
2126                 break;
2127             default:
2128                 ;
2129         }
2130
2131         IMFTopologyNode_Release(node);
2132         if (FAILED(hr))
2133             return hr;
2134     }
2135
2136     if (FAILED(hr = MFCreateTopology(&output_topology)))
2137         return hr;
2138
2139     context.input_topology = input_topology;
2140     context.output_topology = output_topology;
2141     memset(&context.key, 0xff, sizeof(context.key));
2142
2143     /* Clone source nodes, use initial marker value. */
2144     i = 0;
2145     while (SUCCEEDED(IMFTopology_GetNode(input_topology, i++, &node)))
2146     {
2147         IMFTopologyNode_GetNodeType(node, &node_type);
2148
2149         if (node_type == MF_TOPOLOGY_SOURCESTREAM_NODE)
2150         {
2151             if (FAILED(hr = topology_loader_clone_node(&context, node, NULL, 0)))
2152                 WARN("Failed to clone source node, hr %#x.\n", hr);
2153         }
2154
2155         IMFTopologyNode_Release(node);
2156     }
2157
2158     for (context.marker = 0;; ++context.marker)
2159     {
2160         if (FAILED(hr = topology_loader_resolve_nodes(&context, &layer_size)))
2161         {
2162             WARN("Failed to resolve for marker %u, hr %#x.\n", context.marker, hr);
2163             break;
2164         }
2165
2166         /* Reached last marker value. */
2167         if (!layer_size)
2168             break;
2169     }
2170
2171     /* For now return original topology. */
2172
2173     *ret_topology = output_topology;
2174
2175     return IMFTopology_CloneFrom(output_topology, input_topology);
2176 }
2177
2178 static const IMFTopoLoaderVtbl topologyloadervtbl =
2179 {
2180     topology_loader_QueryInterface,
2181     topology_loader_AddRef,
2182     topology_loader_Release,
2183     topology_loader_Load,
2184 };
2185
2186 /***********************************************************************
2187  *      MFCreateTopoLoader (mf.@)
2188  */
2189 HRESULT WINAPI MFCreateTopoLoader(IMFTopoLoader **loader)
2190 {
2191     struct topology_loader *object;
2192
2193     TRACE("%p.\n", loader);
2194
2195     if (!loader)
2196         return E_POINTER;
2197
2198     object = heap_alloc(sizeof(*object));
2199     if (!object)
2200         return E_OUTOFMEMORY;
2201
2202     object->IMFTopoLoader_iface.lpVtbl = &topologyloadervtbl;
2203     object->refcount = 1;
2204
2205     *loader = &object->IMFTopoLoader_iface;
2206
2207     return S_OK;
2208 }
2209
2210 static HRESULT WINAPI seq_source_QueryInterface(IMFSequencerSource *iface, REFIID riid, void **out)
2211 {
2212     struct seq_source *seq_source = impl_from_IMFSequencerSource(iface);
2213
2214     TRACE("%p, %s, %p.\n", iface, debugstr_guid(riid), out);
2215
2216     *out = NULL;
2217
2218     if (IsEqualIID(riid, &IID_IMFSequencerSource) ||
2219             IsEqualIID(riid, &IID_IUnknown))
2220     {
2221         *out = &seq_source->IMFSequencerSource_iface;
2222     }
2223     else if (IsEqualIID(riid, &IID_IMFMediaSourceTopologyProvider))
2224     {
2225         *out = &seq_source->IMFMediaSourceTopologyProvider_iface;
2226     }
2227     else
2228     {
2229         WARN("Unimplemented %s.\n", debugstr_guid(riid));
2230         return E_NOINTERFACE;
2231     }
2232
2233     if (*out)
2234         IUnknown_AddRef((IUnknown *)*out);
2235
2236     return S_OK;
2237 }
2238
2239 static ULONG WINAPI seq_source_AddRef(IMFSequencerSource *iface)
2240 {
2241     struct seq_source *seq_source = impl_from_IMFSequencerSource(iface);
2242     ULONG refcount = InterlockedIncrement(&seq_source->refcount);
2243
2244     TRACE("%p, refcount %u.\n", iface, refcount);
2245
2246     return refcount;
2247 }
2248
2249 static ULONG WINAPI seq_source_Release(IMFSequencerSource *iface)
2250 {
2251     struct seq_source *seq_source = impl_from_IMFSequencerSource(iface);
2252     ULONG refcount = InterlockedDecrement(&seq_source->refcount);
2253
2254     TRACE("%p, refcount %u.\n", iface, refcount);
2255
2256     if (!refcount)
2257     {
2258         heap_free(seq_source);
2259     }
2260
2261     return refcount;
2262 }
2263
2264 static HRESULT WINAPI seq_source_AppendTopology(IMFSequencerSource *iface, IMFTopology *topology,
2265         DWORD flags, MFSequencerElementId *id)
2266 {
2267     FIXME("%p, %p, %x, %p.\n", iface, topology, flags, id);
2268
2269     return E_NOTIMPL;
2270 }
2271
2272 static HRESULT WINAPI seq_source_DeleteTopology(IMFSequencerSource *iface, MFSequencerElementId id)
2273 {
2274     FIXME("%p, %#x.\n", iface, id);
2275
2276     return E_NOTIMPL;
2277 }
2278
2279 static HRESULT WINAPI seq_source_GetPresentationContext(IMFSequencerSource *iface,
2280         IMFPresentationDescriptor *descriptor, MFSequencerElementId *id, IMFTopology **topology)
2281 {
2282     FIXME("%p, %p, %p, %p.\n", iface, descriptor, id, topology);
2283
2284     return E_NOTIMPL;
2285 }
2286
2287 static HRESULT WINAPI seq_source_UpdateTopology(IMFSequencerSource *iface, MFSequencerElementId id,
2288         IMFTopology *topology)
2289 {
2290     FIXME("%p, %#x, %p.\n", iface, id, topology);
2291
2292     return E_NOTIMPL;
2293 }
2294
2295 static HRESULT WINAPI seq_source_UpdateTopologyFlags(IMFSequencerSource *iface, MFSequencerElementId id, DWORD flags)
2296 {
2297     FIXME("%p, %#x, %#x.\n", iface, id, flags);
2298
2299     return E_NOTIMPL;
2300 }
2301
2302 static HRESULT WINAPI seq_source_topology_provider_QueryInterface(IMFMediaSourceTopologyProvider *iface, REFIID riid,
2303         void **obj)
2304 {
2305     struct seq_source *seq_source = impl_from_IMFMediaSourceTopologyProvider(iface);
2306     return IMFSequencerSource_QueryInterface(&seq_source->IMFSequencerSource_iface, riid, obj);
2307 }
2308
2309 static ULONG WINAPI seq_source_topology_provider_AddRef(IMFMediaSourceTopologyProvider *iface)
2310 {
2311     struct seq_source *seq_source = impl_from_IMFMediaSourceTopologyProvider(iface);
2312     return IMFSequencerSource_AddRef(&seq_source->IMFSequencerSource_iface);
2313 }
2314
2315 static ULONG WINAPI seq_source_topology_provider_Release(IMFMediaSourceTopologyProvider *iface)
2316 {
2317     struct seq_source *seq_source = impl_from_IMFMediaSourceTopologyProvider(iface);
2318     return IMFSequencerSource_Release(&seq_source->IMFSequencerSource_iface);
2319 }
2320
2321 static HRESULT WINAPI seq_source_topology_provider_GetMediaSourceTopology(IMFMediaSourceTopologyProvider *iface,
2322         IMFPresentationDescriptor *pd, IMFTopology **topology)
2323 {
2324     FIXME("%p, %p, %p.\n", iface, pd, topology);
2325
2326     return E_NOTIMPL;
2327 }
2328
2329 static const IMFMediaSourceTopologyProviderVtbl seq_source_topology_provider_vtbl =
2330 {
2331     seq_source_topology_provider_QueryInterface,
2332     seq_source_topology_provider_AddRef,
2333     seq_source_topology_provider_Release,
2334     seq_source_topology_provider_GetMediaSourceTopology,
2335 };
2336
2337 static const IMFSequencerSourceVtbl seqsourcevtbl =
2338 {
2339     seq_source_QueryInterface,
2340     seq_source_AddRef,
2341     seq_source_Release,
2342     seq_source_AppendTopology,
2343     seq_source_DeleteTopology,
2344     seq_source_GetPresentationContext,
2345     seq_source_UpdateTopology,
2346     seq_source_UpdateTopologyFlags,
2347 };
2348
2349 /***********************************************************************
2350  *      MFCreateSequencerSource (mf.@)
2351  */
2352 HRESULT WINAPI MFCreateSequencerSource(IUnknown *reserved, IMFSequencerSource **seq_source)
2353 {
2354     struct seq_source *object;
2355
2356     TRACE("%p, %p.\n", reserved, seq_source);
2357
2358     if (!seq_source)
2359         return E_POINTER;
2360
2361     object = heap_alloc(sizeof(*object));
2362     if (!object)
2363         return E_OUTOFMEMORY;
2364
2365     object->IMFSequencerSource_iface.lpVtbl = &seqsourcevtbl;
2366     object->IMFMediaSourceTopologyProvider_iface.lpVtbl = &seq_source_topology_provider_vtbl;
2367     object->refcount = 1;
2368
2369     *seq_source = &object->IMFSequencerSource_iface;
2370
2371     return S_OK;
2372 }