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
);