diff options
author | Tomáš Rylek <trylek@microsoft.com> | 2020-12-08 05:19:44 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-12-08 05:19:44 +0300 |
commit | 69e114c1abf91241a0eeecf1ecceab4711b8aa62 (patch) | |
tree | b81a0b35748f5e598412bcc504335cdbd322cd43 /src/coreclr/palrt/memorystream.cpp | |
parent | 0ec07945a9759a72a689edbb01e69b232e26e05a (diff) |
December infra rollout - remove duplicated 'src' from coreclr subrepo (src/coreclr/src becomes src/coreclr) (#44973)
* Move src/coreclr/src/Directory.Build.targets to src/coreclr
Merge src/coreclr/src/CMakeLists.txt into src/coreclr/CMakeLists.txt
* Mechanical move of src/coreclr/src to src/coreclr
* Scripts adjustments to reflect the changed paths
Diffstat (limited to 'src/coreclr/palrt/memorystream.cpp')
-rw-r--r-- | src/coreclr/palrt/memorystream.cpp | 316 |
1 files changed, 316 insertions, 0 deletions
diff --git a/src/coreclr/palrt/memorystream.cpp b/src/coreclr/palrt/memorystream.cpp new file mode 100644 index 00000000000..0ed06547f3b --- /dev/null +++ b/src/coreclr/palrt/memorystream.cpp @@ -0,0 +1,316 @@ +// Licensed to the .NET Foundation under one or more agreements. +// The .NET Foundation licenses this file to you under the MIT license. +// + +// +// =========================================================================== +// File: memorystream.cpp +// +// =========================================================================== +/*++ + +Abstract: + + in memory stream + + + + +Revision History: + +--*/ + +#include "common.h" + +#include "objidl.h" + +class MemoryStream : public IStream +{ + LONG m_cRef; // QI refcount + ULONG m_nPos; // the current position in the stream + ULONG m_nSize; // the current size of the stream + ULONG m_nData; // the size of the allocated data storage, can be < m_nSize + BYTE* m_pData; // the data storage + +private: + HRESULT Ensure(ULONG nNewData) + { + if (nNewData > m_nData) + { + // apply some heurestic for growing + ULONG n = m_nData; + + // grow 2x for smaller sizes, 1.25x for bigger sizes + n = min(2 * n, n + n / 4 + 0x100000); + + // don't allocate tiny chunks + n = max(n, 0x100); + + // compare with the hard limit + nNewData = max(n, nNewData); + } + else + if (nNewData > m_nData / 4) + { + // shrinking but it is not worth it + return S_OK; + } + + BYTE * pNewData = (BYTE*)realloc(m_pData, nNewData); + if (pNewData == NULL && nNewData != 0) + return E_OUTOFMEMORY; + + m_nData = nNewData; + m_pData = pNewData; + return S_OK; + } + +public: + MemoryStream() + { + m_cRef = 1; + m_nPos = 0; + m_nSize = 0; + m_nData = 0; + m_pData = NULL; + } + +#ifdef __GNUC__ + virtual +#endif + ~MemoryStream() + { + free(m_pData); + } + + HRESULT STDMETHODCALLTYPE QueryInterface( + REFIID riid, + void **ppvObject) + { + if (riid == IID_IStream || + riid == IID_ISequentialStream || + riid == IID_IUnknown) + { + InterlockedIncrement(&m_cRef); + *ppvObject = this; + return S_OK; + } + else + { + *ppvObject = NULL; + return E_NOINTERFACE; + } + } + + ULONG STDMETHODCALLTYPE AddRef() + { + return InterlockedIncrement(&m_cRef); + } + + ULONG STDMETHODCALLTYPE Release() + { + LONG cRef = InterlockedDecrement(&m_cRef); + if (cRef == 0) + delete this; + return cRef; + } + + HRESULT STDMETHODCALLTYPE Read( + void *pv, + ULONG cb, + ULONG *pcbRead) + { + ULONG nData; + ULONG nNewPos = m_nPos + cb; + + // check for overflow + if (nNewPos < cb) + return STG_E_INVALIDFUNCTION; + + // compare with the actual size + nNewPos = min(nNewPos, m_nSize); + + // compare with the data available + nData = min(nNewPos, m_nData); + + // copy the data over + if (nData > m_nPos) + memcpy(pv, m_pData + m_nPos, nData - m_nPos); + + // fill the rest with zeros + if (nNewPos > nData) + memset((BYTE*)pv + (nData - m_nPos), 0, nNewPos - nData); + + cb = nNewPos - m_nPos; + m_nPos = nNewPos; + + if (pcbRead) + *pcbRead = cb; + + return S_OK; + } + + HRESULT STDMETHODCALLTYPE Write( + const void *pv, + ULONG cb, + ULONG *pcbWritten) + { + ULONG nNewPos = m_nPos + cb; + + // check for overflow + if (nNewPos < cb) + return STG_E_INVALIDFUNCTION; + + // ensure the space + if (nNewPos > m_nData) + { + HRESULT hr = Ensure(nNewPos); + if (FAILED(hr)) return hr; + } + + // copy the data over + memcpy(m_pData + m_nPos, pv, cb); + + m_nPos = nNewPos; + if (m_nPos > m_nSize) + m_nSize = m_nPos; + + if (pcbWritten) + *pcbWritten = cb; + + return S_OK; + } + + HRESULT STDMETHODCALLTYPE Seek( + LARGE_INTEGER dlibMove, + DWORD dwOrigin, + ULARGE_INTEGER *plibNewPosition) + { + ULONG lStartPos; + LONGLONG lNewPos; + + switch (dwOrigin) + { + case STREAM_SEEK_SET: + lStartPos = 0; + break; + case STREAM_SEEK_CUR: + lStartPos = m_nPos; + break; + case STREAM_SEEK_END: + lStartPos = m_nSize; + break; + default: + return STG_E_INVALIDFUNCTION; + } + + lNewPos = lStartPos + dlibMove.QuadPart; + + // it is an error to seek before the beginning of the stream + if (lNewPos < 0) + return STG_E_INVALIDFUNCTION; + + // It is not, however, an error to seek past the end of the stream + if (lNewPos > m_nSize) + { + ULARGE_INTEGER NewSize; + NewSize.QuadPart = lNewPos; + + HRESULT hr = SetSize(NewSize); + if (FAILED(hr)) return hr; + } + + m_nPos = (ULONG)lNewPos; + + if (plibNewPosition != NULL) + plibNewPosition->QuadPart = m_nPos; + + return S_OK; + } + + HRESULT STDMETHODCALLTYPE SetSize( + ULARGE_INTEGER libNewSize) + { + if (libNewSize.u.HighPart != 0) + return STG_E_INVALIDFUNCTION; + + m_nSize = libNewSize.u.LowPart; + + // free the space if we are shrinking + if (m_nSize < m_nData) + Ensure(m_nSize); + + return S_OK; + } + + HRESULT STDMETHODCALLTYPE CopyTo( + IStream *pstm, + ULARGE_INTEGER cb, + ULARGE_INTEGER *pcbRead, + ULARGE_INTEGER *pcbWritten) + { + _ASSERTE(false); + return E_NOTIMPL; + } + + HRESULT STDMETHODCALLTYPE Commit( + DWORD grfCommitFlags) + { + _ASSERTE(false); + return E_NOTIMPL; + } + + HRESULT STDMETHODCALLTYPE Revert() + { + _ASSERTE(false); + return E_NOTIMPL; + } + + HRESULT STDMETHODCALLTYPE LockRegion( + ULARGE_INTEGER libOffset, + ULARGE_INTEGER cb, + DWORD dwLockType) + { + _ASSERTE(false); + return E_NOTIMPL; + } + + HRESULT STDMETHODCALLTYPE UnlockRegion( + ULARGE_INTEGER libOffset, + ULARGE_INTEGER cb, + DWORD dwLockType) + { + _ASSERTE(false); + return E_NOTIMPL; + } + + HRESULT STDMETHODCALLTYPE Stat( + STATSTG *pstatstg, + DWORD grfStatFlag) + { + memset(pstatstg, 0, sizeof(STATSTG)); + pstatstg->cbSize.QuadPart = m_nSize; + return S_OK; + } + + HRESULT STDMETHODCALLTYPE Clone( + IStream **ppstm) + { + _ASSERTE(false); + return E_NOTIMPL; + } +}; + +STDAPI CreateStreamOnHGlobal(PVOID hGlobal, BOOL fDeleteOnRelease, IStream** ppstm) +{ + MemoryStream* pStream; + + if (hGlobal != NULL) return E_NOTIMPL; + _ASSERTE(fDeleteOnRelease == TRUE); + + pStream = new MemoryStream; + if (pStream == NULL) return E_OUTOFMEMORY; + + *ppstm = pStream; + return S_OK; +} |