2 * ITSS Storage implementation
4 * Copyright 2004 Mike McCormack
6 * see http://bonedaddy.net/pabs3/hhm/#chmspec
8 * This library is free software; you can redistribute it and/or
9 * modify it under the terms of the GNU Lesser General Public
10 * License as published by the Free Software Foundation; either
11 * version 2.1 of the License, or (at your option) any later version.
13 * This library is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 * Lesser General Public License for more details.
18 * You should have received a copy of the GNU Lesser General Public
19 * License along with this library; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
38 #include "wine/itss.h"
39 #include "wine/unicode.h"
40 #include "wine/debug.h"
42 WINE_DEFAULT_DEBUG_CHANNEL(itss);
44 /************************************************************************/
46 typedef struct _ITSS_IStorageImpl
48 const IStorageVtbl *vtbl_IStorage;
50 struct chmFile *chmfile;
56 struct enum_info *next, *prev;
57 struct chmUnitInfo ui;
60 typedef struct _IEnumSTATSTG_Impl
62 const IEnumSTATSTGVtbl *vtbl_IEnumSTATSTG;
64 struct enum_info *first, *last, *current;
67 typedef struct _IStream_Impl
69 const IStreamVtbl *vtbl_IStream;
71 ITSS_IStorageImpl *stg;
73 struct chmUnitInfo ui;
76 static HRESULT ITSS_create_chm_storage(
77 struct chmFile *chmfile, const WCHAR *dir, IStorage** ppstgOpen );
78 static IStream_Impl* ITSS_create_stream(
79 ITSS_IStorageImpl *stg, struct chmUnitInfo *ui );
81 /************************************************************************/
83 static HRESULT WINAPI ITSS_IEnumSTATSTG_QueryInterface(
88 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
90 if (IsEqualGUID(riid, &IID_IUnknown)
91 || IsEqualGUID(riid, &IID_IEnumSTATSTG))
93 IEnumSTATSTG_AddRef(iface);
98 WARN("(%p)->(%s,%p),not found\n",This,debugstr_guid(riid),ppvObject);
102 static ULONG WINAPI ITSS_IEnumSTATSTG_AddRef(
105 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
106 return InterlockedIncrement(&This->ref);
109 static ULONG WINAPI ITSS_IEnumSTATSTG_Release(
112 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
114 ULONG ref = InterlockedDecrement(&This->ref);
120 struct enum_info *t = This->first->next;
121 HeapFree( GetProcessHeap(), 0, This->first );
124 HeapFree(GetProcessHeap(), 0, This);
131 static HRESULT WINAPI ITSS_IEnumSTATSTG_Next(
137 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
139 struct enum_info *cur;
141 TRACE("%p %u %p %p\n", This, celt, rgelt, pceltFetched );
145 while( (n<celt) && cur)
149 memset( rgelt, 0, sizeof *rgelt );
155 len = strlenW( str ) + 1;
156 rgelt->pwcsName = CoTaskMemAlloc( len*sizeof(WCHAR) );
157 strcpyW( rgelt->pwcsName, str );
159 /* determine the type */
160 if( rgelt->pwcsName[len-2] == '/' )
162 rgelt->pwcsName[len-2] = 0;
163 rgelt->type = STGTY_STORAGE;
166 rgelt->type = STGTY_STREAM;
169 rgelt->cbSize.QuadPart = cur->ui.length;
171 /* advance to the next item if it exists */
185 static HRESULT WINAPI ITSS_IEnumSTATSTG_Skip(
189 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
191 struct enum_info *cur;
193 TRACE("%p %u\n", This, celt );
197 while( (n<celt) && cur)
210 static HRESULT WINAPI ITSS_IEnumSTATSTG_Reset(
213 IEnumSTATSTG_Impl *This = (IEnumSTATSTG_Impl *)iface;
215 TRACE("%p\n", This );
217 This->current = This->first;
222 static HRESULT WINAPI ITSS_IEnumSTATSTG_Clone(
224 IEnumSTATSTG** ppenum)
230 static const IEnumSTATSTGVtbl IEnumSTATSTG_vtbl =
232 ITSS_IEnumSTATSTG_QueryInterface,
233 ITSS_IEnumSTATSTG_AddRef,
234 ITSS_IEnumSTATSTG_Release,
235 ITSS_IEnumSTATSTG_Next,
236 ITSS_IEnumSTATSTG_Skip,
237 ITSS_IEnumSTATSTG_Reset,
238 ITSS_IEnumSTATSTG_Clone
241 static IEnumSTATSTG_Impl *ITSS_create_enum( void )
243 IEnumSTATSTG_Impl *stgenum;
245 stgenum = HeapAlloc( GetProcessHeap(), 0, sizeof (IEnumSTATSTG_Impl) );
246 stgenum->vtbl_IEnumSTATSTG = &IEnumSTATSTG_vtbl;
248 stgenum->first = NULL;
249 stgenum->last = NULL;
250 stgenum->current = NULL;
253 TRACE(" -> %p\n", stgenum );
258 /************************************************************************/
260 static HRESULT WINAPI ITSS_IStorageImpl_QueryInterface(
265 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
267 if (IsEqualGUID(riid, &IID_IUnknown)
268 || IsEqualGUID(riid, &IID_IStorage))
270 IStorage_AddRef(iface);
275 WARN("(%p)->(%s,%p),not found\n",This,debugstr_guid(riid),ppvObject);
276 return E_NOINTERFACE;
279 static ULONG WINAPI ITSS_IStorageImpl_AddRef(
282 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
283 return InterlockedIncrement(&This->ref);
286 static ULONG WINAPI ITSS_IStorageImpl_Release(
289 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
291 ULONG ref = InterlockedDecrement(&This->ref);
295 chm_close(This->chmfile);
296 HeapFree(GetProcessHeap(), 0, This);
303 static HRESULT WINAPI ITSS_IStorageImpl_CreateStream(
315 static HRESULT WINAPI ITSS_IStorageImpl_OpenStream(
323 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
326 struct chmUnitInfo ui;
330 TRACE("%p %s %p %u %u %p\n", This, debugstr_w(pwcsName),
331 reserved1, grfMode, reserved2, ppstm );
333 len = strlenW( This->dir ) + strlenW( pwcsName ) + 1;
334 path = HeapAlloc( GetProcessHeap(), 0, len*sizeof(WCHAR) );
335 strcpyW( path, This->dir );
337 if( pwcsName[0] == '/' || pwcsName[0] == '\\' )
339 p = &path[strlenW( path ) - 1];
340 while( ( path <= p ) && ( *p == '/' ) )
343 strcatW( path, pwcsName );
345 for(p=path; *p; p++) {
353 TRACE("Resolving %s\n", debugstr_w(path));
355 r = chm_resolve_object(This->chmfile, path, &ui);
356 HeapFree( GetProcessHeap(), 0, path );
358 if( r != CHM_RESOLVE_SUCCESS ) {
359 WARN("Could not resolve object\n");
360 return STG_E_FILENOTFOUND;
363 stm = ITSS_create_stream( This, &ui );
367 *ppstm = (IStream*) stm;
372 static HRESULT WINAPI ITSS_IStorageImpl_CreateStorage(
384 static HRESULT WINAPI ITSS_IStorageImpl_OpenStorage(
387 IStorage* pstgPriority,
393 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
395 FIXME("%p %s %p %u %p %u %p\n", This, debugstr_w(pwcsName),
396 pstgPriority, grfMode, snbExclude, reserved, ppstg);
400 static HRESULT WINAPI ITSS_IStorageImpl_CopyTo(
403 const IID* rgiidExclude,
411 static HRESULT WINAPI ITSS_IStorageImpl_MoveElementTo(
415 LPCOLESTR pwcsNewName,
422 static HRESULT WINAPI ITSS_IStorageImpl_Commit(
424 DWORD grfCommitFlags)
430 static HRESULT WINAPI ITSS_IStorageImpl_Revert(
437 static int ITSS_chm_enumerator(
439 struct chmUnitInfo *ui,
442 struct enum_info *info;
443 IEnumSTATSTG_Impl* stgenum = context;
445 TRACE("adding %s to enumeration\n", debugstr_w(ui->path) );
447 info = HeapAlloc( GetProcessHeap(), 0, sizeof (struct enum_info) );
448 memcpy( &info->ui, ui, sizeof info->ui );
451 info->prev = stgenum->last;
453 stgenum->last->next = info;
455 stgenum->first = info;
456 stgenum->last = info;
458 return CHM_ENUMERATOR_CONTINUE;
461 static HRESULT WINAPI ITSS_IStorageImpl_EnumElements(
466 IEnumSTATSTG** ppenum)
468 ITSS_IStorageImpl *This = (ITSS_IStorageImpl *)iface;
469 IEnumSTATSTG_Impl* stgenum;
471 TRACE("%p %d %p %d %p\n", This, reserved1, reserved2, reserved3, ppenum );
473 stgenum = ITSS_create_enum();
477 chm_enumerate_dir(This->chmfile,
483 stgenum->current = stgenum->first;
485 *ppenum = (IEnumSTATSTG*) stgenum;
490 static HRESULT WINAPI ITSS_IStorageImpl_DestroyElement(
498 static HRESULT WINAPI ITSS_IStorageImpl_RenameElement(
500 LPCOLESTR pwcsOldName,
501 LPCOLESTR pwcsNewName)
507 static HRESULT WINAPI ITSS_IStorageImpl_SetElementTimes(
510 const FILETIME* pctime,
511 const FILETIME* patime,
512 const FILETIME* pmtime)
518 static HRESULT WINAPI ITSS_IStorageImpl_SetClass(
526 static HRESULT WINAPI ITSS_IStorageImpl_SetStateBits(
535 static HRESULT WINAPI ITSS_IStorageImpl_Stat(
544 static const IStorageVtbl ITSS_IStorageImpl_Vtbl =
546 ITSS_IStorageImpl_QueryInterface,
547 ITSS_IStorageImpl_AddRef,
548 ITSS_IStorageImpl_Release,
549 ITSS_IStorageImpl_CreateStream,
550 ITSS_IStorageImpl_OpenStream,
551 ITSS_IStorageImpl_CreateStorage,
552 ITSS_IStorageImpl_OpenStorage,
553 ITSS_IStorageImpl_CopyTo,
554 ITSS_IStorageImpl_MoveElementTo,
555 ITSS_IStorageImpl_Commit,
556 ITSS_IStorageImpl_Revert,
557 ITSS_IStorageImpl_EnumElements,
558 ITSS_IStorageImpl_DestroyElement,
559 ITSS_IStorageImpl_RenameElement,
560 ITSS_IStorageImpl_SetElementTimes,
561 ITSS_IStorageImpl_SetClass,
562 ITSS_IStorageImpl_SetStateBits,
563 ITSS_IStorageImpl_Stat,
566 static HRESULT ITSS_create_chm_storage(
567 struct chmFile *chmfile, const WCHAR *dir, IStorage** ppstgOpen )
569 ITSS_IStorageImpl *stg;
572 TRACE("%p %s\n", chmfile, debugstr_w( dir ) );
574 len = strlenW( dir ) + 1;
575 stg = HeapAlloc( GetProcessHeap(), 0,
576 sizeof (ITSS_IStorageImpl) + len*sizeof(WCHAR) );
577 stg->vtbl_IStorage = &ITSS_IStorageImpl_Vtbl;
579 stg->chmfile = chmfile;
580 strcpyW( stg->dir, dir );
582 *ppstgOpen = (IStorage*) stg;
588 HRESULT ITSS_StgOpenStorage(
589 const WCHAR* pwcsName,
590 IStorage* pstgPriority,
594 IStorage** ppstgOpen)
596 struct chmFile *chmfile;
597 static const WCHAR szRoot[] = { '/', 0 };
599 TRACE("%s\n", debugstr_w(pwcsName) );
601 chmfile = chm_openW( pwcsName );
605 return ITSS_create_chm_storage( chmfile, szRoot, ppstgOpen );
608 /************************************************************************/
610 static HRESULT WINAPI ITSS_IStream_QueryInterface(
615 IStream_Impl *This = (IStream_Impl *)iface;
617 if (IsEqualGUID(riid, &IID_IUnknown)
618 || IsEqualGUID(riid, &IID_ISequentialStream)
619 || IsEqualGUID(riid, &IID_IStream))
621 IStream_AddRef(iface);
626 WARN("(%p)->(%s,%p),not found\n",This,debugstr_guid(riid),ppvObject);
627 return E_NOINTERFACE;
630 static ULONG WINAPI ITSS_IStream_AddRef(
633 IStream_Impl *This = (IStream_Impl *)iface;
634 return InterlockedIncrement(&This->ref);
637 static ULONG WINAPI ITSS_IStream_Release(
640 IStream_Impl *This = (IStream_Impl *)iface;
642 ULONG ref = InterlockedDecrement(&This->ref);
646 IStorage_Release( (IStorage*) This->stg );
647 HeapFree(GetProcessHeap(), 0, This);
654 static HRESULT WINAPI ITSS_IStream_Read(
660 IStream_Impl *This = (IStream_Impl *)iface;
663 TRACE("%p %p %u %p\n", This, pv, cb, pcbRead);
665 count = chm_retrieve_object(This->stg->chmfile,
666 &This->ui, pv, This->addr, cb);
671 return count ? S_OK : S_FALSE;
674 static HRESULT WINAPI ITSS_IStream_Write(
684 static HRESULT WINAPI ITSS_IStream_Seek(
686 LARGE_INTEGER dlibMove,
688 ULARGE_INTEGER* plibNewPosition)
690 IStream_Impl *This = (IStream_Impl *)iface;
693 TRACE("%p %s %u %p\n", This,
694 wine_dbgstr_longlong( dlibMove.QuadPart ), dwOrigin, plibNewPosition );
699 case STREAM_SEEK_CUR:
700 newpos = This->addr + dlibMove.QuadPart;
702 case STREAM_SEEK_SET:
703 newpos = dlibMove.QuadPart;
705 case STREAM_SEEK_END:
706 newpos = This->ui.length + dlibMove.QuadPart;
710 if( ( newpos < 0 ) || ( newpos > This->ui.length ) )
711 return STG_E_INVALIDPOINTER;
714 if( plibNewPosition )
715 plibNewPosition->QuadPart = This->addr;
720 static HRESULT WINAPI ITSS_IStream_SetSize(
722 ULARGE_INTEGER libNewSize)
728 static HRESULT WINAPI ITSS_IStream_CopyTo(
732 ULARGE_INTEGER* pcbRead,
733 ULARGE_INTEGER* pcbWritten)
739 static HRESULT WINAPI ITSS_IStream_Commit(
741 DWORD grfCommitFlags)
747 static HRESULT WINAPI ITSS_IStream_Revert(
754 static HRESULT WINAPI ITSS_IStream_LockRegion(
756 ULARGE_INTEGER libOffset,
764 static HRESULT WINAPI ITSS_IStream_UnlockRegion(
766 ULARGE_INTEGER libOffset,
774 static HRESULT WINAPI ITSS_IStream_Stat(
779 IStream_Impl *This = (IStream_Impl *)iface;
781 TRACE("%p %p %d\n", This, pstatstg, grfStatFlag);
783 memset( pstatstg, 0, sizeof *pstatstg );
784 if( !( grfStatFlag & STATFLAG_NONAME ) )
786 FIXME("copy the name\n");
788 pstatstg->type = STGTY_STREAM;
789 pstatstg->cbSize.QuadPart = This->ui.length;
790 pstatstg->grfMode = STGM_READ;
791 memcpy( &pstatstg->clsid, &CLSID_ITStorage, sizeof (CLSID) );
796 static HRESULT WINAPI ITSS_IStream_Clone(
804 static const IStreamVtbl ITSS_IStream_vtbl =
806 ITSS_IStream_QueryInterface,
808 ITSS_IStream_Release,
812 ITSS_IStream_SetSize,
816 ITSS_IStream_LockRegion,
817 ITSS_IStream_UnlockRegion,
822 static IStream_Impl *ITSS_create_stream(
823 ITSS_IStorageImpl *stg, struct chmUnitInfo *ui )
827 stm = HeapAlloc( GetProcessHeap(), 0, sizeof (IStream_Impl) );
828 stm->vtbl_IStream = &ITSS_IStream_vtbl;
831 memcpy( &stm->ui, ui, sizeof stm->ui );
833 IStorage_AddRef( (IStorage*) stg );
837 TRACE(" -> %p\n", stm );