hglobalstream.c File Reference

#include "objbase.h"
#include "wine/debug.h"

Include dependency graph for hglobalstream.c:

Go to the source code of this file.

Classes
struct	handle_wrapper
struct	hglobal_stream

Macros
#define	COBJMACROS

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (storage)
static void	handle_addref (struct handle_wrapper *handle)
static void	handle_release (struct handle_wrapper *handle)
static struct handle_wrapper *	handle_create (HGLOBAL hglobal, BOOL delete_on_release)
static struct hglobal_stream *	impl_from_IStream (IStream *iface)
static struct hglobal_stream *	hglobalstream_construct (void)
static HRESULT WINAPI	stream_QueryInterface (IStream *iface, REFIID riid, void **obj)
static ULONG WINAPI	stream_AddRef (IStream *iface)
static ULONG WINAPI	stream_Release (IStream *iface)
static HRESULT WINAPI	stream_Read (IStream *iface, void *pv, ULONG cb, ULONG *read_len)
static HRESULT WINAPI	stream_Write (IStream *iface, const void *pv, ULONG cb, ULONG *written)
static HRESULT WINAPI	stream_Seek (IStream *iface, LARGE_INTEGER move, DWORD origin, ULARGE_INTEGER *pos)
static HRESULT WINAPI	stream_SetSize (IStream *iface, ULARGE_INTEGER size)
static HRESULT WINAPI	stream_CopyTo (IStream *iface, IStream *dest, ULARGE_INTEGER cb, ULARGE_INTEGER *read_len, ULARGE_INTEGER *written)
static HRESULT WINAPI	stream_Commit (IStream *iface, DWORD flags)
static HRESULT WINAPI	stream_Revert (IStream *iface)
static HRESULT WINAPI	stream_LockRegion (IStream *iface, ULARGE_INTEGER offset, ULARGE_INTEGER len, DWORD lock_type)
static HRESULT WINAPI	stream_UnlockRegion (IStream *iface, ULARGE_INTEGER offset, ULARGE_INTEGER len, DWORD lock_type)
static HRESULT WINAPI	stream_Stat (IStream *iface, STATSTG *pstatstg, DWORD flags)
static HRESULT WINAPI	stream_Clone (IStream *iface, IStream **ppstm)
HRESULT WINAPI	CreateStreamOnHGlobal (HGLOBAL hGlobal, BOOL delete_on_release, IStream **stream)
HRESULT WINAPI	GetHGlobalFromStream (IStream *stream, HGLOBAL *phglobal)

Variables
static const IStreamVtbl	hglobalstreamvtbl

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 22 of file hglobalstream.c.

Function Documentation

CreateStreamOnHGlobal()

HRESULT WINAPI CreateStreamOnHGlobal	(	HGLOBAL	hGlobal,
		BOOL	delete_on_release,
		IStream **	stream
	)

Definition at line 413 of file hglobalstream.c.

{
    struct hglobal_stream *object;
 
    if (!stream)
        return E_INVALIDARG;
 
    object = hglobalstream_construct();
    if (!object) return E_OUTOFMEMORY;
 
    object->handle = handle_create(hGlobal, delete_on_release);
    if (!object->handle)
    {
        free(object);
        return E_OUTOFMEMORY;
    }
 
    *stream = &object->IStream_iface;
 
    return S_OK;
}

Referenced by apartment_get_local_server_stream(), apartment_hostobject_in_hostapt(), BindStatusCallback_OnStartBinding(), bsc_OnStartBinding(), clipbrd_create(), CoMarshalInterThreadInterfaceInStream(), crash_couninitialize_proc(), create_antimoniker(), create_decoder(), create_doc_with_string(), create_stream(), create_stream_from_map(), create_stream_from_string(), create_stream_on_data(), create_stream_on_file(), create_stream_on_mip_ro(), create_test_stream(), D3DXSaveSurfaceToFileInMemory(), DataObjectImpl_CreateComplex(), decode_base64(), decode_qp(), doc_load_string(), domdoc_load_from_stream(), get_current_dataobject(), get_data_from_stream(), get_stgmed_for_stream(), get_travellog_stream(), HlinkClone(), init_memstream(), CTravelEntry::Invoke(), load_image(), load_string(), LoadImageFromFileHandle(), LresultFromObject(), marshal_object_in_agile_reference(), marshal_stgmed(), marshal_WdtpInterfacePointer(), METAFILE_CreateCompressedImageStream(), MimeOleCreateVirtualStream(), BrowserNavigator::navigated(), ObjectFromLresult(), RECORD_StreamFromFile(), RegisterDragDrop(), rpc_get_local_class_object(), RunningObjectTableImpl_Register(), StdGlobalInterfaceTable_RegisterInterfaceInGlobal(), test_anti_moniker(), test_apm(), test_bad_marshal_stream(), test_bom(), test_bsc_marshaling(), test_bufferrawformat(), test_call_from_message(), test_channel_hook(), test_class_moniker(), test_client_security(), test_CoGetStandardMarshal(), test_CoMarshalInterface(), test_componentinfo(), test_copyto(), test_CoRegisterPSClsid(), test_CoUnmarshalInterface(), test_CoWaitForMultipleHandles_thread(), test_createfromstream(), test_createProcessingInstruction(), test_data_cache_save(), test_decode(), test_decode_1bpp(), test_decode_24bpp(), test_decode_4bpp(), test_decode_adobe_cmyk(), test_decode_bitfields(), test_decode_rle4(), test_decode_rle8(), test_DfMarshal_custom_marshaling(), test_disconnect_stub(), test_empty_image(), test_empty_image_2(), test_encoder_formats(), test_enhmetafile(), test_external_connection(), test_file_moniker(), test_freed_hglobal(), test_freethreadedmarshaler(), test_GdipLoadImageFromStream(), test_generic_composite_moniker(), test_getdatahere(), test_GetDataHere_Proxy(), test_handler_marshaling(), test_hresult_marshaling(), test_implicit_mta(), test_InternetSecurityMarshalling(), test_interthread_marshal_and_unmarshal(), test_Invoke(), test_IPersistStream(), test_IStream_Clone(), test_item_moniker(), test_load_save_bmp(), test_load_save_emf(), test_load_save_empty_picture(), test_load_save_icon(), test_loadwmf(), test_lock_object_external(), test_marshal(), test_marshal_and_unmarshal_invalid(), test_marshal_channel_buffer(), test_marshal_dispinterface(), test_marshal_proxy_apartment_shutdown(), test_marshal_proxy_mta_apartment_shutdown(), test_marshal_stub_apartment_shutdown(), test_message_filter(), test_metadata_writer(), test_metafile(), test_moniker(), test_mta_creation_thread_change_apartment(), test_multi_encoder_impl(), test_multiframegif(), test_mxwriter_encoding(), test_mxwriter_flush(), test_mxwriter_stream(), test_no_couninitialize_client(), test_no_couninitialize_server(), test_no_marshaler(), test_normal_marshal_and_release(), test_normal_marshal_and_unmarshal(), test_normal_marshal_and_unmarshal_twice(), test_objref_moniker(), test_OleDoAutoConvert(), test_persist_save_data(), test_persiststreaminit(), test_pic(), test_pointer_moniker(), test_proxy_interfaces(), test_proxy_marshal_and_unmarshal(), test_proxy_marshal_and_unmarshal2(), test_proxy_marshal_and_unmarshal_strong(), test_proxy_marshal_and_unmarshal_weak(), test_proxy_used_in_wrong_thread(), test_ReadClassStm(), test_readerinput(), test_same_apartment_unmarshal_failure(), test_save(), test_save_history(), test_save_load_filemoniker(), test_StdMarshal_custom_marshaling(), test_streamonhglobal(), test_StreamOnIStream(), test_StreamOnStreamRange(), test_supported_encoders(), test_tablestrong_marshal_and_unmarshal_twice(), test_tableweak_and_normal_marshal_and_releasedata(), test_tableweak_and_normal_marshal_and_unmarshal(), test_tableweak_marshal_and_unmarshal_twice(), test_tableweak_marshal_releasedata1(), test_tableweak_marshal_releasedata2(), test_two_tableweak_marshal_and_releasedata(), test_typelibmarshal(), test_writeroutput(), test_writesource_palette(), test_writestartdocument(), test_xsltemplate(), union_tests(), unmarshal_stgmed(), CTravelEntry::Update(), WdtpInterfacePointer_UserMarshal(), WdtpInterfacePointer_UserUnmarshal(), window_proc(), writer_set_output(), xmldoc_IPersistStreamInit_Load(), XMLView_PersistMoniker_Load(), and xslprocessor_transform().

GetHGlobalFromStream()

HRESULT WINAPI GetHGlobalFromStream	(	IStream *	stream,
		HGLOBAL *	phglobal
	)

Definition at line 438 of file hglobalstream.c.

{
    struct hglobal_stream *object;
 
    if (!stream || !phglobal)
        return E_INVALIDARG;
 
    object = impl_from_IStream(stream);
 
    if (object->IStream_iface.lpVtbl == &hglobalstreamvtbl)
        *phglobal = object->handle->hglobal;
    else
    {
        *phglobal = 0;
        return E_INVALIDARG;
    }
 
    return S_OK;
}

Referenced by bsc_OnStopBinding(), check_iml_data(), check_output(), check_output_raw(), create_map_from_stream(), D3DXSaveSurfaceToFileInMemory(), domdoc_load_from_stream(), expose_marshalled_dataobject(), httprequest_get_responseBody(), httprequest_get_responseText(), rpc_register_local_server(), RunningObjectTableImpl_Register(), stream_info(), test_bom(), test_class_moniker(), test_createProcessingInstruction(), test_freethreadedmarshaldata(), test_IStream_Clone(), test_moniker(), test_mxwriter_encoding(), test_omitxmldeclaration(), test_persist_save_data(), test_save(), test_writeenddocument(), test_XMLHTTP(), CTravelEntry::Update(), xmldoc_IPersistStreamInit_Load(), and xslprocessor_transform().

handle_addref()

static void handle_addref ( struct handle_wrapper *  handle )

static

Definition at line 37 of file hglobalstream.c.

{
    InterlockedIncrement(&handle->ref);
}

Referenced by stream_Clone().

handle_create()

static struct handle_wrapper * handle_create ( HGLOBAL  hglobal, BOOL  delete_on_release  )

static

Definition at line 53 of file hglobalstream.c.

{
    struct handle_wrapper *handle;
 
    handle = malloc(sizeof(*handle));
    if (!handle) return NULL;
 
    /* allocate a handle if one is not supplied */
    if (!hglobal) hglobal = GlobalAlloc(GMEM_MOVEABLE | GMEM_NODISCARD | GMEM_SHARE, 0);
    if (!hglobal)
    {
        free(handle);
        return NULL;
    }
    handle->ref = 1;
    handle->hglobal = hglobal;
    handle->size = GlobalSize(hglobal);
    handle->delete_on_release = delete_on_release;
 
    return handle;
}

Referenced by CreateStreamOnHGlobal().

handle_release()

static void handle_release ( struct handle_wrapper *  handle )

static

Definition at line 42 of file hglobalstream.c.

{
    ULONG ref = InterlockedDecrement(&handle->ref);
 
    if (!ref)
    {
        if (handle->delete_on_release) GlobalFree(handle->hglobal);
        free(handle);
    }
}

Referenced by stream_Release().

hglobalstream_construct()

static struct hglobal_stream * hglobalstream_construct ( void  )

static

Definition at line 91 of file hglobalstream.c.

{
    struct hglobal_stream *object = calloc(1, sizeof(*object));
 
    if (object)
    {
        object->IStream_iface.lpVtbl = &hglobalstreamvtbl;
        object->ref = 1;
    }
    return object;
}

Referenced by CreateStreamOnHGlobal(), and stream_Clone().

impl_from_IStream()

static struct hglobal_stream * impl_from_IStream ( IStream *  iface )

inlinestatic

Definition at line 84 of file hglobalstream.c.

{
    return CONTAINING_RECORD(iface, struct hglobal_stream, IStream_iface);
}

Referenced by GetHGlobalFromStream(), StgStreamImpl_AddRef(), StgStreamImpl_Clone(), StgStreamImpl_Commit(), StgStreamImpl_CopyTo(), StgStreamImpl_LockRegion(), StgStreamImpl_QueryInterface(), StgStreamImpl_Read(), StgStreamImpl_Release(), StgStreamImpl_Seek(), StgStreamImpl_SetSize(), StgStreamImpl_Stat(), StgStreamImpl_UnlockRegion(), StgStreamImpl_Write(), stream_AddRef(), stream_Clone(), stream_Read(), stream_Release(), stream_Seek(), stream_SetSize(), stream_Stat(), and stream_Write().

stream_AddRef()

static ULONG WINAPI stream_AddRef ( IStream *  iface )

static

Definition at line 121 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    return InterlockedIncrement(&stream->ref);
}

stream_Clone()

static HRESULT WINAPI stream_Clone ( IStream *  iface, IStream **  ppstm  )

static

Definition at line 370 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface), *clone;
    ULARGE_INTEGER dummy;
    LARGE_INTEGER offset;
 
    TRACE("%p, %p\n", iface, ppstm);
 
    *ppstm = NULL;
 
    clone = hglobalstream_construct();
    if (!clone) return E_OUTOFMEMORY;
 
    *ppstm = &clone->IStream_iface;
    handle_addref(stream->handle);
    clone->handle = stream->handle;
 
    offset.QuadPart = (LONGLONG)stream->position.QuadPart;
    IStream_Seek(*ppstm, offset, STREAM_SEEK_SET, &dummy);
    return S_OK;
}

stream_Commit()

static HRESULT WINAPI stream_Commit ( IStream *  iface, DWORD  flags  )

static

Definition at line 335 of file hglobalstream.c.

{
    return S_OK;
}

stream_CopyTo()

static HRESULT WINAPI stream_CopyTo ( IStream *  iface, IStream *  dest, ULARGE_INTEGER  cb, ULARGE_INTEGER *  read_len, ULARGE_INTEGER *  written  )

static

Definition at line 286 of file hglobalstream.c.

{
    ULARGE_INTEGER total_read, total_written;
    HRESULT hr = S_OK;
    BYTE buffer[128];
 
    TRACE("%p, %p, %ld, %p, %p\n", iface, dest, cb.LowPart, read_len, written);
 
    if (!dest)
        return STG_E_INVALIDPOINTER;
 
    total_read.QuadPart = 0;
    total_written.QuadPart = 0;
 
    while (cb.QuadPart > 0)
    {
        ULONG chunk_size = cb.QuadPart >= sizeof(buffer) ? sizeof(buffer) : cb.LowPart;
        ULONG chunk_read, chunk_written;
 
        hr = IStream_Read(iface, buffer, chunk_size, &chunk_read);
        if (FAILED(hr))
            break;
 
        total_read.QuadPart += chunk_read;
 
        if (chunk_read)
        {
            hr = IStream_Write(dest, buffer, chunk_read, &chunk_written);
            if (FAILED(hr))
                break;
 
            total_written.QuadPart += chunk_written;
        }
 
        if (chunk_read != chunk_size)
            cb.QuadPart = 0;
        else
            cb.QuadPart -= chunk_read;
    }
 
    if (read_len)
        read_len->QuadPart = total_read.QuadPart;
    if (written)
        written->QuadPart = total_written.QuadPart;
 
    return hr;
}

stream_LockRegion()

static HRESULT WINAPI stream_LockRegion ( IStream *  iface, ULARGE_INTEGER  offset, ULARGE_INTEGER  len, DWORD  lock_type  )

static

Definition at line 345 of file hglobalstream.c.

{
    return STG_E_INVALIDFUNCTION;
}

stream_QueryInterface()

static HRESULT WINAPI stream_QueryInterface ( IStream *  iface, REFIID  riid, void **  obj  )

static

Definition at line 103 of file hglobalstream.c.

{
    if (!obj)
        return E_INVALIDARG;
 
    if (IsEqualIID(&IID_IUnknown, riid) ||
        IsEqualIID(&IID_ISequentialStream, riid) ||
        IsEqualIID(&IID_IStream, riid))
    {
        *obj = iface;
        IStream_AddRef(iface);
        return S_OK;
    }
 
    *obj = NULL;
    return E_NOINTERFACE;
}

stream_Read()

static HRESULT WINAPI stream_Read ( IStream *  iface, void *  pv, ULONG  cb, ULONG *  read_len  )

static

Definition at line 141 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    ULONG dummy, len;
    char *buffer;
 
    TRACE("%p, %p, %ld, %p\n", iface, pv, cb, read_len);
 
    if (!read_len)
        read_len = &dummy;
 
    if (stream->handle->size >= stream->position.LowPart)
        len = min(stream->handle->size - stream->position.LowPart, cb);
    else
        len = 0;
 
    buffer = GlobalLock(stream->handle->hglobal);
    if (!buffer)
    {
        WARN("Failed to lock hglobal %p\n", stream->handle->hglobal);
        *read_len = 0;
        return S_OK;
    }
 
    memcpy(pv, buffer + stream->position.LowPart, len);
    stream->position.LowPart += len;
 
    *read_len = len;
 
    GlobalUnlock(stream->handle->hglobal);
 
    return S_OK;
}

stream_Release()

static ULONG WINAPI stream_Release ( IStream *  iface )

static

Definition at line 127 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    ULONG ref = InterlockedDecrement(&stream->ref);
 
    if (!ref)
    {
        handle_release(stream->handle);
        free(stream);
    }
 
    return ref;
}

stream_Revert()

static HRESULT WINAPI stream_Revert ( IStream *  iface )

static

Definition at line 340 of file hglobalstream.c.

{
    return S_OK;
}

stream_Seek()

static HRESULT WINAPI stream_Seek ( IStream *  iface, LARGE_INTEGER  move, DWORD  origin, ULARGE_INTEGER *  pos  )

static

Definition at line 224 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    ULARGE_INTEGER position = stream->position;
    HRESULT hr = S_OK;
 
    TRACE("%p, %s, %ld, %p\n", iface, wine_dbgstr_longlong(move.QuadPart), origin, pos);
 
    switch (origin)
    {
        case STREAM_SEEK_SET:
            position.QuadPart = 0;
            break;
        case STREAM_SEEK_CUR:
            break;
        case STREAM_SEEK_END:
            position.QuadPart = stream->handle->size;
            break;
        default:
            hr = STG_E_SEEKERROR;
            goto end;
    }
 
    position.HighPart = 0;
    position.LowPart += move.QuadPart;
 
    if (move.LowPart >= 0x80000000 && position.LowPart >= move.LowPart)
    {
        /* We tried to seek backwards and went past the start. */
        hr = STG_E_SEEKERROR;
        goto end;
    }
 
    stream->position = position;
 
end:
    if (pos) *pos = stream->position;
 
    return hr;
}

stream_SetSize()

static HRESULT WINAPI stream_SetSize ( IStream *  iface, ULARGE_INTEGER  size  )

static

Definition at line 266 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    HGLOBAL hglobal;
 
    TRACE("%p, %s\n", iface, wine_dbgstr_longlong(size.QuadPart));
 
    if (stream->handle->size == size.LowPart)
        return S_OK;
 
    hglobal = GlobalReAlloc(stream->handle->hglobal, size.LowPart, GMEM_MOVEABLE);
    if (!hglobal)
        return E_OUTOFMEMORY;
 
    stream->handle->hglobal = hglobal;
    stream->handle->size = size.LowPart;
 
    return S_OK;
}

stream_Stat()

static HRESULT WINAPI stream_Stat ( IStream *  iface, STATSTG *  pstatstg, DWORD  flags  )

static

Definition at line 357 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
 
    memset(pstatstg, 0, sizeof(STATSTG));
 
    pstatstg->pwcsName = NULL;
    pstatstg->type = STGTY_STREAM;
    pstatstg->cbSize.QuadPart = stream->handle->size;
 
    return S_OK;
}

stream_UnlockRegion()

static HRESULT WINAPI stream_UnlockRegion ( IStream *  iface, ULARGE_INTEGER  offset, ULARGE_INTEGER  len, DWORD  lock_type  )

static

Definition at line 351 of file hglobalstream.c.

{
    return S_OK;
}

stream_Write()

static HRESULT WINAPI stream_Write ( IStream *  iface, const void *  pv, ULONG  cb, ULONG *  written  )

static

Definition at line 175 of file hglobalstream.c.

{
    struct hglobal_stream *stream = impl_from_IStream(iface);
    ULARGE_INTEGER size;
    ULONG dummy = 0;
    char *buffer;
 
    TRACE("%p, %p, %ld, %p\n", iface, pv, cb, written);
 
    if (!written)
        written = &dummy;
 
    if (!cb)
        goto out;
 
    *written = 0;
 
    size.HighPart = 0;
    size.LowPart = stream->position.LowPart + cb;
 
    if (size.LowPart > stream->handle->size)
    {
        /* grow stream */
        HRESULT hr = IStream_SetSize(iface, size);
        if (FAILED(hr))
        {
            ERR("IStream_SetSize failed with error %#lx\n", hr);
            return hr;
        }
    }
 
    buffer = GlobalLock(stream->handle->hglobal);
    if (!buffer)
    {
        WARN("write to invalid hglobal %p\n", stream->handle->hglobal);
        return S_OK;
    }
 
    memcpy(buffer + stream->position.LowPart, pv, cb);
    stream->position.LowPart += cb;
 
    GlobalUnlock(stream->handle->hglobal);
 
out:
    *written = cb;
 
    return S_OK;
}

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

storage

)

Variable Documentation

hglobalstreamvtbl

static const IStreamVtbl hglobalstreamvtbl

static

Initial value:

=
{
    stream_QueryInterface,
    stream_AddRef,
    stream_Release,
    stream_Read,
    stream_Write,
    stream_Seek,
    stream_SetSize,
    stream_CopyTo,
    stream_Commit,
    stream_Revert,
    stream_LockRegion,
    stream_UnlockRegion,
    stream_Stat,
    stream_Clone
}

Definition at line 89 of file hglobalstream.c.

Referenced by GetHGlobalFromStream(), and hglobalstream_construct().