git.oblomov.eu Git - wine/blob - dlls/ole32/stg_stream.c

   1 /*
   2  * Compound Storage (32 bit version)
   3  * Stream implementation
   4  *
   5  * This file contains the implementation of the stream interface
   6  * for streams contained in a compound storage.
   7  *
   8  * Copyright 1999 Francis Beaudet
   9  * Copyright 1999 Thuy Nguyen
  10  *
  11  * This library is free software; you can redistribute it and/or
  12  * modify it under the terms of the GNU Lesser General Public
  13  * License as published by the Free Software Foundation; either
  14  * version 2.1 of the License, or (at your option) any later version.
  15  *
  16  * This library is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  19  * Lesser General Public License for more details.
  20  *
  21  * You should have received a copy of the GNU Lesser General Public
  22  * License along with this library; if not, write to the Free Software
  23  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  24  */
  25
  26 #include <assert.h>
  27 #include <stdlib.h>
  28 #include <stdarg.h>
  29 #include <stdio.h>
  30 #include <string.h>
  31
  32 #define COBJMACROS
  33 #define NONAMELESSUNION
  34 #define NONAMELESSSTRUCT
  35
  36 #include "windef.h"
  37 #include "winbase.h"
  38 #include "winerror.h"
  39 #include "winternl.h"
  40 #include "wine/debug.h"
  41
  42 #include "storage32.h"
  43
  44 WINE_DEFAULT_DEBUG_CHANNEL(storage);
  45
  46
  47 /***
  48  * This is the destructor of the StgStreamImpl class.
  49  *
  50  * This method will clean-up all the resources used-up by the given StgStreamImpl
  51  * class. The pointer passed-in to this function will be freed and will not
  52  * be valid anymore.
  53  */
  54 static void StgStreamImpl_Destroy(StgStreamImpl* This)
  55 {
  56   TRACE("(%p)\n", This);
  57
  58   /*
  59    * Release the reference we are holding on the parent storage.
  60    * IStorage_Release((IStorage*)This->parentStorage);
  61    *
  62    * No, don't do this. Some apps call IStorage_Release without
  63    * calling IStream_Release first. If we grab a reference the
  64    * file is not closed, and the app fails when it tries to
  65    * reopen the file (Easy-PC, for example). Just inform the
  66    * storage that we have closed the stream
  67    */
  68
  69   if(This->parentStorage) {
  70
  71     StorageBaseImpl_RemoveStream(This->parentStorage, This);
  72
  73   }
  74
  75   This->parentStorage = 0;
  76
  77   /*
  78    * Finally, free the memory used-up by the class.
  79    */
  80   HeapFree(GetProcessHeap(), 0, This);
  81 }
  82
  83 /***
  84  * This implements the IUnknown method QueryInterface for this
  85  * class
  86  */
  87 static HRESULT WINAPI StgStreamImpl_QueryInterface(
  88                   IStream*     iface,
  89                   REFIID         riid,        /* [in] */
  90                   void**         ppvObject)   /* [iid_is][out] */
  91 {
  92   StgStreamImpl* const This=(StgStreamImpl*)iface;
  93
  94   /*
  95    * Perform a sanity check on the parameters.
  96    */
  97   if (ppvObject==0)
  98     return E_INVALIDARG;
  99
 100   /*
 101    * Initialize the return parameter.
 102    */
 103   *ppvObject = 0;
 104
 105   /*
 106    * Compare the riid with the interface IDs implemented by this object.
 107    */
 108   if (IsEqualIID(&IID_IUnknown, riid) ||
 109       IsEqualIID(&IID_IPersist, riid) ||
 110       IsEqualIID(&IID_IPersistStream, riid) ||
 111       IsEqualIID(&IID_ISequentialStream, riid) ||
 112       IsEqualIID(&IID_IStream, riid))
 113   {
 114     *ppvObject = This;
 115   }
 116
 117   /*
 118    * Check that we obtained an interface.
 119    */
 120   if ((*ppvObject)==0)
 121     return E_NOINTERFACE;
 122
 123   /*
 124    * Query Interface always increases the reference count by one when it is
 125    * successful
 126    */
 127   IStream_AddRef(iface);
 128
 129   return S_OK;
 130 }
 131
 132 /***
 133  * This implements the IUnknown method AddRef for this
 134  * class
 135  */
 136 static ULONG WINAPI StgStreamImpl_AddRef(
 137                 IStream* iface)
 138 {
 139   StgStreamImpl* const This=(StgStreamImpl*)iface;
 140   return InterlockedIncrement(&This->ref);
 141 }
 142
 143 /***
 144  * This implements the IUnknown method Release for this
 145  * class
 146  */
 147 static ULONG WINAPI StgStreamImpl_Release(
 148                 IStream* iface)
 149 {
 150   StgStreamImpl* const This=(StgStreamImpl*)iface;
 151
 152   ULONG ref;
 153
 154   ref = InterlockedDecrement(&This->ref);
 155
 156   /*
 157    * If the reference count goes down to 0, perform suicide.
 158    */
 159   if (ref==0)
 160   {
 161     StgStreamImpl_Destroy(This);
 162   }
 163
 164   return ref;
 165 }
 166
 167 /***
 168  * This method is part of the ISequentialStream interface.
 169  *
 170  * It reads a block of information from the stream at the current
 171  * position. It then moves the current position at the end of the
 172  * read block
 173  *
 174  * See the documentation of ISequentialStream for more info.
 175  */
 176 static HRESULT WINAPI StgStreamImpl_Read(
 177                   IStream*     iface,
 178                   void*          pv,        /* [length_is][size_is][out] */
 179                   ULONG          cb,        /* [in] */
 180                   ULONG*         pcbRead)   /* [out] */
 181 {
 182   StgStreamImpl* const This=(StgStreamImpl*)iface;
 183
 184   ULONG bytesReadBuffer;
 185   HRESULT res;
 186
 187   TRACE("(%p, %p, %d, %p)\n",
 188         iface, pv, cb, pcbRead);
 189
 190   if (!This->parentStorage)
 191   {
 192     WARN("storage reverted\n");
 193     return STG_E_REVERTED;
 194   }
 195
 196   /*
 197    * If the caller is not interested in the number of bytes read,
 198    * we use another buffer to avoid "if" statements in the code.
 199    */
 200   if (pcbRead==0)
 201     pcbRead = &bytesReadBuffer;
 202
 203   res = StorageBaseImpl_StreamReadAt(This->parentStorage,
 204                                      This->dirEntry,
 205                                      This->currentPosition,
 206                                      cb,
 207                                      pv,
 208                                      pcbRead);
 209
 210   if (SUCCEEDED(res))
 211   {
 212     /*
 213      * Advance the pointer for the number of positions read.
 214      */
 215     This->currentPosition.u.LowPart += *pcbRead;
 216   }
 217
 218   TRACE("<-- %08x\n", res);
 219   return res;
 220 }
 221
 222 /***
 223  * This method is part of the ISequentialStream interface.
 224  *
 225  * It writes a block of information to the stream at the current
 226  * position. It then moves the current position at the end of the
 227  * written block. If the stream is too small to fit the block,
 228  * the stream is grown to fit.
 229  *
 230  * See the documentation of ISequentialStream for more info.
 231  */
 232 static HRESULT WINAPI StgStreamImpl_Write(
 233                   IStream*     iface,
 234                   const void*    pv,          /* [size_is][in] */
 235                   ULONG          cb,          /* [in] */
 236                   ULONG*         pcbWritten)  /* [out] */
 237 {
 238   StgStreamImpl* const This=(StgStreamImpl*)iface;
 239
 240   ULONG bytesWritten = 0;
 241   HRESULT res;
 242
 243   TRACE("(%p, %p, %d, %p)\n",
 244         iface, pv, cb, pcbWritten);
 245
 246   /*
 247    * Do we have permission to write to this stream?
 248    */
 249   switch(STGM_ACCESS_MODE(This->grfMode))
 250   {
 251   case STGM_WRITE:
 252   case STGM_READWRITE:
 253       break;
 254   default:
 255       WARN("access denied by flags: 0x%x\n", STGM_ACCESS_MODE(This->grfMode));
 256       return STG_E_ACCESSDENIED;
 257   }
 258
 259   if (!pv)
 260     return STG_E_INVALIDPOINTER;
 261
 262   if (!This->parentStorage)
 263   {
 264     WARN("storage reverted\n");
 265     return STG_E_REVERTED;
 266   }
 267
 268   /*
 269    * If the caller is not interested in the number of bytes written,
 270    * we use another buffer to avoid "if" statements in the code.
 271    */
 272   if (pcbWritten == 0)
 273     pcbWritten = &bytesWritten;
 274
 275   /*
 276    * Initialize the out parameter
 277    */
 278   *pcbWritten = 0;
 279
 280   if (cb == 0)
 281   {
 282     TRACE("<-- S_OK, written 0\n");
 283     return S_OK;
 284   }
 285
 286   res = StorageBaseImpl_StreamWriteAt(This->parentStorage,
 287                                       This->dirEntry,
 288                                       This->currentPosition,
 289                                       cb,
 290                                       pv,
 291                                       pcbWritten);
 292
 293   /*
 294    * Advance the position pointer for the number of positions written.
 295    */
 296   This->currentPosition.u.LowPart += *pcbWritten;
 297
 298   if (SUCCEEDED(res))
 299     res = StorageBaseImpl_Flush(This->parentStorage);
 300
 301   TRACE("<-- S_OK, written %u\n", *pcbWritten);
 302   return res;
 303 }
 304
 305 /***
 306  * This method is part of the IStream interface.
 307  *
 308  * It will move the current stream pointer according to the parameters
 309  * given.
 310  *
 311  * See the documentation of IStream for more info.
 312  */
 313 static HRESULT WINAPI StgStreamImpl_Seek(
 314                   IStream*      iface,
 315                   LARGE_INTEGER   dlibMove,         /* [in] */
 316                   DWORD           dwOrigin,         /* [in] */
 317                   ULARGE_INTEGER* plibNewPosition) /* [out] */
 318 {
 319   StgStreamImpl* const This=(StgStreamImpl*)iface;
 320
 321   ULARGE_INTEGER newPosition;
 322   DirEntry currentEntry;
 323   HRESULT hr;
 324
 325   TRACE("(%p, %d, %d, %p)\n",
 326         iface, dlibMove.u.LowPart, dwOrigin, plibNewPosition);
 327
 328   /*
 329    * fail if the stream has no parent (as does windows)
 330    */
 331
 332   if (!This->parentStorage)
 333   {
 334     WARN("storage reverted\n");
 335     return STG_E_REVERTED;
 336   }
 337
 338   /*
 339    * The caller is allowed to pass in NULL as the new position return value.
 340    * If it happens, we assign it to a dynamic variable to avoid special cases
 341    * in the code below.
 342    */
 343   if (plibNewPosition == 0)
 344   {
 345     plibNewPosition = &newPosition;
 346   }
 347
 348   /*
 349    * The file pointer is moved depending on the given "function"
 350    * parameter.
 351    */
 352   switch (dwOrigin)
 353   {
 354     case STREAM_SEEK_SET:
 355       plibNewPosition->u.HighPart = 0;
 356       plibNewPosition->u.LowPart  = 0;
 357       break;
 358     case STREAM_SEEK_CUR:
 359       *plibNewPosition = This->currentPosition;
 360       break;
 361     case STREAM_SEEK_END:
 362       hr = StorageBaseImpl_ReadDirEntry(This->parentStorage, This->dirEntry, &currentEntry);
 363       if (FAILED(hr)) return hr;
 364       *plibNewPosition = currentEntry.size;
 365       break;
 366     default:
 367       WARN("invalid dwOrigin %d\n", dwOrigin);
 368       return STG_E_INVALIDFUNCTION;
 369   }
 370
 371   plibNewPosition->QuadPart += dlibMove.QuadPart;
 372
 373   /*
 374    * tell the caller what we calculated
 375    */
 376   This->currentPosition = *plibNewPosition;
 377
 378   return S_OK;
 379 }
 380
 381 /***
 382  * This method is part of the IStream interface.
 383  *
 384  * It will change the size of a stream.
 385  *
 386  * See the documentation of IStream for more info.
 387  */
 388 static HRESULT WINAPI StgStreamImpl_SetSize(
 389                                      IStream*      iface,
 390                                      ULARGE_INTEGER  libNewSize)   /* [in] */
 391 {
 392   StgStreamImpl* const This=(StgStreamImpl*)iface;
 393
 394   HRESULT      hr;
 395
 396   TRACE("(%p, %d)\n", iface, libNewSize.u.LowPart);
 397
 398   if(!This->parentStorage)
 399   {
 400     WARN("storage reverted\n");
 401     return STG_E_REVERTED;
 402   }
 403
 404   /*
 405    * As documented.
 406    */
 407   if (libNewSize.u.HighPart != 0)
 408   {
 409     WARN("invalid value for libNewSize.u.HighPart %d\n", libNewSize.u.HighPart);
 410     return STG_E_INVALIDFUNCTION;
 411   }
 412
 413   /*
 414    * Do we have permission?
 415    */
 416   if (!(This->grfMode & (STGM_WRITE | STGM_READWRITE)))
 417   {
 418     WARN("access denied\n");
 419     return STG_E_ACCESSDENIED;
 420   }
 421
 422   hr = StorageBaseImpl_StreamSetSize(This->parentStorage, This->dirEntry, libNewSize);
 423
 424   if (SUCCEEDED(hr))
 425     hr = StorageBaseImpl_Flush(This->parentStorage);
 426
 427   return hr;
 428 }
 429
 430 /***
 431  * This method is part of the IStream interface.
 432  *
 433  * It will copy the 'cb' Bytes to 'pstm' IStream.
 434  *
 435  * See the documentation of IStream for more info.
 436  */
 437 static HRESULT WINAPI StgStreamImpl_CopyTo(
 438                                     IStream*      iface,
 439                                     IStream*      pstm,         /* [unique][in] */
 440                                     ULARGE_INTEGER  cb,           /* [in] */
 441                                     ULARGE_INTEGER* pcbRead,      /* [out] */
 442                                     ULARGE_INTEGER* pcbWritten)   /* [out] */
 443 {
 444   StgStreamImpl* const This=(StgStreamImpl*)iface;
 445   HRESULT        hr = S_OK;
 446   BYTE           tmpBuffer[128];
 447   ULONG          bytesRead, bytesWritten, copySize;
 448   ULARGE_INTEGER totalBytesRead;
 449   ULARGE_INTEGER totalBytesWritten;
 450
 451   TRACE("(%p, %p, %d, %p, %p)\n",
 452         iface, pstm, cb.u.LowPart, pcbRead, pcbWritten);
 453
 454   /*
 455    * Sanity check
 456    */
 457
 458   if (!This->parentStorage)
 459   {
 460     WARN("storage reverted\n");
 461     return STG_E_REVERTED;
 462   }
 463
 464   if ( pstm == 0 )
 465     return STG_E_INVALIDPOINTER;
 466
 467   totalBytesRead.QuadPart = 0;
 468   totalBytesWritten.QuadPart = 0;
 469
 470   while ( cb.QuadPart > 0 )
 471   {
 472     if ( cb.QuadPart >= sizeof(tmpBuffer) )
 473       copySize = sizeof(tmpBuffer);
 474     else
 475       copySize = cb.u.LowPart;
 476
 477     IStream_Read(iface, tmpBuffer, copySize, &bytesRead);
 478
 479     totalBytesRead.QuadPart += bytesRead;
 480
 481     IStream_Write(pstm, tmpBuffer, bytesRead, &bytesWritten);
 482
 483     totalBytesWritten.QuadPart += bytesWritten;
 484
 485     /*
 486      * Check that read & write operations were successful
 487      */
 488     if (bytesRead != bytesWritten)
 489     {
 490       hr = STG_E_MEDIUMFULL;
 491       WARN("medium full\n");
 492       break;
 493     }
 494
 495     if (bytesRead!=copySize)
 496       cb.QuadPart = 0;
 497     else
 498       cb.QuadPart -= bytesRead;
 499   }
 500
 501   if (pcbRead) pcbRead->QuadPart = totalBytesRead.QuadPart;
 502   if (pcbWritten) pcbWritten->QuadPart = totalBytesWritten.QuadPart;
 503
 504   return hr;
 505 }
 506
 507 /***
 508  * This method is part of the IStream interface.
 509  *
 510  * For streams contained in structured storages, this method
 511  * does nothing. This is what the documentation tells us.
 512  *
 513  * See the documentation of IStream for more info.
 514  */
 515 static HRESULT WINAPI StgStreamImpl_Commit(
 516                   IStream*      iface,
 517                   DWORD           grfCommitFlags)  /* [in] */
 518 {
 519   StgStreamImpl* const This=(StgStreamImpl*)iface;
 520
 521   if (!This->parentStorage)
 522   {
 523     WARN("storage reverted\n");
 524     return STG_E_REVERTED;
 525   }
 526
 527   return StorageBaseImpl_Flush(This->parentStorage);
 528 }
 529
 530 /***
 531  * This method is part of the IStream interface.
 532  *
 533  * For streams contained in structured storages, this method
 534  * does nothing. This is what the documentation tells us.
 535  *
 536  * See the documentation of IStream for more info.
 537  */
 538 static HRESULT WINAPI StgStreamImpl_Revert(
 539                   IStream* iface)
 540 {
 541   return S_OK;
 542 }
 543
 544 static HRESULT WINAPI StgStreamImpl_LockRegion(
 545                                         IStream*     iface,
 546                                         ULARGE_INTEGER libOffset,   /* [in] */
 547                                         ULARGE_INTEGER cb,          /* [in] */
 548                                         DWORD          dwLockType)  /* [in] */
 549 {
 550   StgStreamImpl* const This=(StgStreamImpl*)iface;
 551
 552   if (!This->parentStorage)
 553   {
 554     WARN("storage reverted\n");
 555     return STG_E_REVERTED;
 556   }
 557
 558   FIXME("not implemented!\n");
 559   return E_NOTIMPL;
 560 }
 561
 562 static HRESULT WINAPI StgStreamImpl_UnlockRegion(
 563                                           IStream*     iface,
 564                                           ULARGE_INTEGER libOffset,   /* [in] */
 565                                           ULARGE_INTEGER cb,          /* [in] */
 566                                           DWORD          dwLockType)  /* [in] */
 567 {
 568   StgStreamImpl* const This=(StgStreamImpl*)iface;
 569
 570   if (!This->parentStorage)
 571   {
 572     WARN("storage reverted\n");
 573     return STG_E_REVERTED;
 574   }
 575
 576   FIXME("not implemented!\n");
 577   return E_NOTIMPL;
 578 }
 579
 580 /***
 581  * This method is part of the IStream interface.
 582  *
 583  * This method returns information about the current
 584  * stream.
 585  *
 586  * See the documentation of IStream for more info.
 587  */
 588 static HRESULT WINAPI StgStreamImpl_Stat(
 589                   IStream*     iface,
 590                   STATSTG*       pstatstg,     /* [out] */
 591                   DWORD          grfStatFlag)  /* [in] */
 592 {
 593   StgStreamImpl* const This=(StgStreamImpl*)iface;
 594
 595   DirEntry     currentEntry;
 596   HRESULT      hr;
 597
 598   TRACE("%p %p %d\n", This, pstatstg, grfStatFlag);
 599
 600   /*
 601    * if stream has no parent, return STG_E_REVERTED
 602    */
 603
 604   if (!This->parentStorage)
 605   {
 606     WARN("storage reverted\n");
 607     return STG_E_REVERTED;
 608   }
 609
 610   /*
 611    * Read the information from the directory entry.
 612    */
 613   hr = StorageBaseImpl_ReadDirEntry(This->parentStorage,
 614                                              This->dirEntry,
 615                                              &currentEntry);
 616
 617   if (SUCCEEDED(hr))
 618   {
 619     StorageUtl_CopyDirEntryToSTATSTG(This->parentStorage,
 620                      pstatstg,
 621                                      &currentEntry,
 622                                      grfStatFlag);
 623
 624     pstatstg->grfMode = This->grfMode;
 625
 626     /* In simple create mode cbSize is the current pos */
 627     if((This->parentStorage->openFlags & STGM_SIMPLE) && This->parentStorage->create)
 628       pstatstg->cbSize = This->currentPosition;
 629
 630     return S_OK;
 631   }
 632
 633   WARN("failed to read entry\n");
 634   return hr;
 635 }
 636
 637 /***
 638  * This method is part of the IStream interface.
 639  *
 640  * This method returns a clone of the interface that allows for
 641  * another seek pointer
 642  *
 643  * See the documentation of IStream for more info.
 644  *
 645  * I am not totally sure what I am doing here but I presume that this
 646  * should be basically as simple as creating a new stream with the same
 647  * parent etc and positioning its seek cursor.
 648  */
 649 static HRESULT WINAPI StgStreamImpl_Clone(
 650                                    IStream*     iface,
 651                                    IStream**    ppstm) /* [out] */
 652 {
 653   StgStreamImpl* const This=(StgStreamImpl*)iface;
 654   HRESULT hres;
 655   StgStreamImpl* new_stream;
 656   LARGE_INTEGER seek_pos;
 657
 658   TRACE("%p %p\n", This, ppstm);
 659
 660   /*
 661    * Sanity check
 662    */
 663
 664   if (!This->parentStorage)
 665     return STG_E_REVERTED;
 666
 667   if ( ppstm == 0 )
 668     return STG_E_INVALIDPOINTER;
 669
 670   new_stream = StgStreamImpl_Construct (This->parentStorage, This->grfMode, This->dirEntry);
 671
 672   if (!new_stream)
 673     return STG_E_INSUFFICIENTMEMORY; /* Currently the only reason for new_stream=0 */
 674
 675   *ppstm = (IStream*) new_stream;
 676   IStream_AddRef(*ppstm);
 677
 678   seek_pos.QuadPart = This->currentPosition.QuadPart;
 679
 680   hres=StgStreamImpl_Seek (*ppstm, seek_pos, STREAM_SEEK_SET, NULL);
 681
 682   assert (SUCCEEDED(hres));
 683
 684   return S_OK;
 685 }
 686
 687 /*
 688  * Virtual function table for the StgStreamImpl class.
 689  */
 690 static const IStreamVtbl StgStreamImpl_Vtbl =
 691 {
 692     StgStreamImpl_QueryInterface,
 693     StgStreamImpl_AddRef,
 694     StgStreamImpl_Release,
 695     StgStreamImpl_Read,
 696     StgStreamImpl_Write,
 697     StgStreamImpl_Seek,
 698     StgStreamImpl_SetSize,
 699     StgStreamImpl_CopyTo,
 700     StgStreamImpl_Commit,
 701     StgStreamImpl_Revert,
 702     StgStreamImpl_LockRegion,
 703     StgStreamImpl_UnlockRegion,
 704     StgStreamImpl_Stat,
 705     StgStreamImpl_Clone
 706 };
 707
 708 /******************************************************************************
 709 ** StgStreamImpl implementation
 710 */
 711
 712 /***
 713  * This is the constructor for the StgStreamImpl class.
 714  *
 715  * Params:
 716  *    parentStorage - Pointer to the storage that contains the stream to open
 717  *    dirEntry      - Index of the directory entry that points to this stream.
 718  */
 719 StgStreamImpl* StgStreamImpl_Construct(
 720                 StorageBaseImpl* parentStorage,
 721     DWORD            grfMode,
 722     DirRef           dirEntry)
 723 {
 724   StgStreamImpl* newStream;
 725
 726   newStream = HeapAlloc(GetProcessHeap(), 0, sizeof(StgStreamImpl));
 727
 728   if (newStream!=0)
 729   {
 730     /*
 731      * Set-up the virtual function table and reference count.
 732      */
 733     newStream->lpVtbl    = &StgStreamImpl_Vtbl;
 734     newStream->ref       = 0;
 735
 736     newStream->parentStorage = parentStorage;
 737
 738     /*
 739      * We want to nail-down the reference to the storage in case the
 740      * stream out-lives the storage in the client application.
 741      *
 742      * -- IStorage_AddRef((IStorage*)newStream->parentStorage);
 743      *
 744      * No, don't do this. Some apps call IStorage_Release without
 745      * calling IStream_Release first. If we grab a reference the
 746      * file is not closed, and the app fails when it tries to
 747      * reopen the file (Easy-PC, for example)
 748      */
 749
 750     newStream->grfMode = grfMode;
 751     newStream->dirEntry = dirEntry;
 752
 753     /*
 754      * Start the stream at the beginning.
 755      */
 756     newStream->currentPosition.u.HighPart = 0;
 757     newStream->currentPosition.u.LowPart = 0;
 758
 759     /* add us to the storage's list of active streams */
 760     StorageBaseImpl_AddStream(parentStorage, newStream);
 761   }
 762
 763   return newStream;
 764 }