1952 lines
50 KiB
C++
1952 lines
50 KiB
C++
//+---------------------------------------------------------------------------
|
|
//
|
|
// Microsoft Windows
|
|
// Copyright (C) Microsoft Corporation, 1992 - 1995.
|
|
//
|
|
// File: stgwrap.cxx
|
|
//
|
|
// Contents: IStorage/IStream wrappers for async docfile
|
|
//
|
|
// Classes:
|
|
//
|
|
// Functions:
|
|
//
|
|
// History: 19-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
#include "astghead.cxx"
|
|
#pragma hdrstop
|
|
|
|
#include "stgwrap.hxx"
|
|
#include "asyncerr.hxx"
|
|
#define UNTERMINATED 0
|
|
#define TERMINATED_NORMAL 1
|
|
#define TERMINATED_ABNORMAL 2
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::Notify, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 14-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
SCODE CAsyncStorage::Notify(void)
|
|
{
|
|
SCODE sc = S_OK;
|
|
ULONG ulWaterMark;
|
|
ULONG ulFailurePoint;
|
|
|
|
HANDLE hNotifyEvent;
|
|
CSinkList *pslTemp;
|
|
|
|
_pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
pslTemp =_cpoint.GetHead();
|
|
|
|
while ((pslTemp == NULL) ||
|
|
(sc = pslTemp->GetProgressNotify()->OnProgress(ulWaterMark, ulFailurePoint, FALSE)) ==S_OK)
|
|
{
|
|
DWORD dwFlags;
|
|
|
|
// wait for an event to signal
|
|
hNotifyEvent = _pflb->GetNotificationEvent();
|
|
WaitForSingleObject(hNotifyEvent, INFINITE);
|
|
|
|
_pflb->GetTerminationStatus(&dwFlags);
|
|
// client terminated call?
|
|
if (dwFlags == TERMINATED_ABNORMAL)
|
|
return STG_E_TERMINATED;
|
|
|
|
// download is complete
|
|
else if (dwFlags == TERMINATED_NORMAL)
|
|
break;
|
|
|
|
else
|
|
{ _pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
// all the data is available now
|
|
if (ulWaterMark >= ulFailurePoint)
|
|
break;
|
|
}
|
|
|
|
}
|
|
if (sc == S_FALSE)
|
|
return S_OK;
|
|
else return sc;
|
|
|
|
|
|
}
|
|
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Notify, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 14-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
SCODE CAsyncStream::Notify(void)
|
|
{
|
|
SCODE sc = S_OK;
|
|
ULONG ulWaterMark;
|
|
ULONG ulFailurePoint;
|
|
CSinkList *pslTemp;
|
|
HANDLE hNotifyEvent;
|
|
|
|
_pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
pslTemp =_cpoint.GetHead();
|
|
|
|
while ((pslTemp == NULL) ||
|
|
(sc = pslTemp->GetProgressNotify()->OnProgress(ulWaterMark, ulFailurePoint, FALSE)) ==S_OK)
|
|
{
|
|
DWORD dwFlags;
|
|
|
|
// wait for an event to signal
|
|
hNotifyEvent = _pflb->GetNotificationEvent();
|
|
WaitForSingleObject(hNotifyEvent, INFINITE);
|
|
|
|
_pflb->GetTerminationStatus(&dwFlags);
|
|
// client terminated call?
|
|
if (dwFlags == TERMINATED_ABNORMAL)
|
|
return STG_E_TERMINATED;
|
|
|
|
// download is complete
|
|
else if (dwFlags == TERMINATED_NORMAL)
|
|
break;
|
|
|
|
else
|
|
{ _pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
// all the data is available now
|
|
if (ulWaterMark >= ulFailurePoint)
|
|
break;
|
|
}
|
|
|
|
}
|
|
if (sc == S_FALSE)
|
|
return S_OK;
|
|
else return sc;
|
|
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Notify, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 14-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
SCODE CAsyncEnum::Notify(void)
|
|
{
|
|
SCODE sc = S_OK;
|
|
ULONG ulWaterMark;
|
|
ULONG ulFailurePoint;
|
|
CSinkList *pslTemp;
|
|
HANDLE hNotifyEvent;
|
|
|
|
_pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
pslTemp =_cpoint.GetHead();
|
|
|
|
while ((pslTemp == NULL) ||
|
|
(sc = pslTemp->GetProgressNotify()->OnProgress(ulWaterMark, ulFailurePoint, FALSE)) ==S_OK)
|
|
{
|
|
DWORD dwFlags;
|
|
|
|
// wait for an event to signal
|
|
hNotifyEvent = _pflb->GetNotificationEvent();
|
|
WaitForSingleObject(hNotifyEvent, INFINITE);
|
|
|
|
_pflb->GetTerminationStatus(&dwFlags);
|
|
// client terminated call?
|
|
if (dwFlags == TERMINATED_ABNORMAL)
|
|
return STG_E_TERMINATED;
|
|
|
|
// download is complete
|
|
else if (dwFlags == TERMINATED_NORMAL)
|
|
break;
|
|
|
|
else
|
|
{ _pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
|
|
// all the data is available now
|
|
if (ulWaterMark >= ulFailurePoint)
|
|
break;
|
|
}
|
|
|
|
}
|
|
if (sc == S_FALSE)
|
|
return S_OK;
|
|
else return sc;
|
|
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::QueryInterface, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::QueryInterface(REFIID iid, void **ppvObj)
|
|
{
|
|
SCODE sc = S_OK;
|
|
*ppvObj = NULL;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::QueryInterface:%p()\n", this));
|
|
|
|
if (IsEqualIID(iid, IID_IUnknown))
|
|
|
|
{
|
|
*ppvObj = (IStorage *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IStorage))
|
|
{
|
|
*ppvObj = (IStorage *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IConnectionPointContainer))
|
|
{
|
|
*ppvObj = (IConnectionPointContainer *)this;
|
|
}
|
|
else
|
|
{
|
|
sc = E_NOINTERFACE;
|
|
}
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
AddRef();
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::QueryInterface:%p()\n", this));
|
|
return sc;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::AddRef, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncStorage::AddRef(void)
|
|
{
|
|
ULONG ulRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::AddRef:%p()\n", this));
|
|
InterlockedIncrement(&_cReferences);
|
|
ulRet = _cReferences;
|
|
_pRealStg->AddRef();
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::AddRef\n"));
|
|
return ulRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::Release, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP_(ULONG) CAsyncStorage::Release(void)
|
|
{
|
|
LONG lRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::Release:%p()\n", this));
|
|
|
|
lRet = InterlockedDecrement(&_cReferences);
|
|
_pRealStg->Release();
|
|
if (lRet == 0)
|
|
{
|
|
delete this;
|
|
}
|
|
else if (lRet < 0)
|
|
lRet = 0;
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::Release\n"));
|
|
return (ULONG)lRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::CreateStream, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::CreateStream(OLECHAR const *pwcsName,
|
|
DWORD grfMode,
|
|
DWORD reserved1,
|
|
DWORD reserved2,
|
|
IStream **ppstm)
|
|
{
|
|
|
|
SCODE sc = S_OK,
|
|
sc2 = S_OK;
|
|
|
|
CAsyncStream *pwstm;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::CreateStream:%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->CreateStream(pwcsName,
|
|
grfMode,
|
|
reserved1,
|
|
reserved2,
|
|
ppstm);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncStream *pwstm = new CAsyncStream(*ppstm, _pflb);
|
|
*ppstm = (IStream *)pwstm;
|
|
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::CreateStream:%p()\n", this));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::OpenStream, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::OpenStream(OLECHAR const *pwcsName,
|
|
void *reserved1,
|
|
DWORD grfMode,
|
|
DWORD reserved2,
|
|
IStream **ppstm)
|
|
{
|
|
CAsyncStream *pwstm;
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::OpenStream:%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->OpenStream(pwcsName,
|
|
reserved1,
|
|
grfMode,
|
|
reserved2,
|
|
ppstm);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncStream *pwstm = new CAsyncStream(*ppstm, _pflb);
|
|
*ppstm = (IStream *)pwstm;
|
|
}
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::OpenStream:%p()\n", this));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::CreateStorage, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::CreateStorage(OLECHAR const *pwcsName,
|
|
DWORD grfMode,
|
|
DWORD reserved1,
|
|
LPSTGSECURITY reserved2,
|
|
IStorage **ppstg)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::CreateStorage:%p()\n", this));
|
|
|
|
do
|
|
{ sc = _pRealStg->CreateStorage( pwcsName,
|
|
grfMode,
|
|
reserved1,
|
|
reserved2,
|
|
ppstg);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncStorage *pwstg = new CAsyncStorage(*ppstg, _pflb);
|
|
*ppstg = (IStorage *) pwstg;
|
|
|
|
}
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::CreateStorage:%p()\n", this));
|
|
return ResultFromScode(sc);
|
|
|
|
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::OpenStorage, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::OpenStorage(OLECHAR const *pwcsName,
|
|
IStorage *pstgPriority,
|
|
DWORD grfMode,
|
|
SNB snbExclude,
|
|
DWORD reserved,
|
|
IStorage **ppstg)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::OpenStorage:%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStg->OpenStorage( pwcsName,
|
|
pstgPriority,
|
|
grfMode,
|
|
snbExclude,
|
|
reserved,
|
|
ppstg);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncStorage *pwstg = new CAsyncStorage(*ppstg, _pflb);
|
|
*ppstg = (IStorage *) pwstg;
|
|
}
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::OpenStorage:%p()\n", this));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::CopyTo, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::CopyTo(DWORD ciidExclude,
|
|
IID const *rgiidExclude,
|
|
SNB snbExclude,
|
|
IStorage *pstgDest)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::CopyTo%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->CopyTo( ciidExclude,
|
|
rgiidExclude,
|
|
snbExclude,
|
|
pstgDest);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::CopyTo\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::MoveElementTo, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::MoveElementTo(OLECHAR const *lpszName,
|
|
IStorage *pstgDest,
|
|
OLECHAR const *lpszNewName,
|
|
DWORD grfFlags)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::MoveElementTo%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
|
|
sc = _pRealStg->MoveElementTo(lpszName,
|
|
pstgDest,
|
|
lpszNewName,
|
|
grfFlags) ;
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
}
|
|
while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::MoveElementTo\n"));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::Commit, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::Commit(DWORD grfCommitFlags)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::Commit%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->Commit(grfCommitFlags);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::Commit\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::Revert, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::Revert(void)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::Revert%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->Revert();
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::Revert\n"));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::EnumElements, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::EnumElements(DWORD reserved1,
|
|
void *reserved2,
|
|
DWORD reserved3,
|
|
IEnumSTATSTG **ppenm)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::EnumElements%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->EnumElements(reserved1,
|
|
reserved2,
|
|
reserved3,
|
|
ppenm);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncEnum *pwenum = new CAsyncEnum(*ppenm, _pflb);
|
|
*ppenm = (IEnumSTATSTG *)pwenum;
|
|
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::EnumElements\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::DestroyElement, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::DestroyElement(OLECHAR const *pwcsName)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
ULONG ulWaterMark;
|
|
ULONG ulFailurePoint;
|
|
|
|
HANDLE hNotifyEvent;
|
|
CSinkList *pslTemp;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::DestroyElement%p()\n", this));
|
|
|
|
pslTemp =_cpoint.GetHead();
|
|
|
|
while (1)
|
|
{
|
|
DWORD dwFlags;
|
|
|
|
_pflb->GetTerminationStatus(&dwFlags);
|
|
// client terminated call?
|
|
if (dwFlags == TERMINATED_ABNORMAL)
|
|
return STG_E_TERMINATED;
|
|
|
|
// download is complete
|
|
else if (dwFlags == TERMINATED_NORMAL)
|
|
break;
|
|
// wait for an event to signal
|
|
hNotifyEvent = _pflb->GetNotificationEvent();
|
|
WaitForSingleObject(hNotifyEvent, INFINITE);
|
|
|
|
if (pslTemp != NULL)
|
|
{
|
|
_pflb->GetFailureInfo(&ulWaterMark,
|
|
&ulFailurePoint);
|
|
pslTemp->GetProgressNotify()->OnProgress(ulWaterMark, (ULONG) -1 , FALSE);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sc = _pRealStg->DestroyElement(pwcsName);
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::DestroyElement\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::RenameElement, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::RenameElement(OLECHAR const *pwcsOldName,
|
|
OLECHAR const *pwcsNewName)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::RenameElement%p()\n", this));
|
|
|
|
do
|
|
{
|
|
|
|
sc = _pRealStg->RenameElement(pwcsOldName,
|
|
pwcsNewName);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::RenameElement\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::SetElementTimes, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::SetElementTimes(const OLECHAR *lpszName,
|
|
FILETIME const *pctime,
|
|
FILETIME const *patime,
|
|
FILETIME const *pmtime)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::SetElementTimes%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->SetElementTimes(lpszName,
|
|
pctime,
|
|
patime,
|
|
pmtime);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::SetElementTimes\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::SetClass, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::SetClass(REFCLSID clsid)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::SetClass%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStg->SetClass(clsid);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::SetClass\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::SetStateBits, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::SetStateBits(DWORD grfStateBits, DWORD grfMask)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::SetStateBits%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStg->SetStateBits(grfStateBits, grfMask);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::SetStateBits\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::Stat, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStorage::Stat(STATSTG *pstatstg, DWORD grfStatFlag)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::Stat%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStg->Stat( pstatstg, grfStatFlag);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::Stat\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::EnumConnectionPoints, public
|
|
//
|
|
// Synopsis: Return enumerator on connection points
|
|
//
|
|
// Arguments: [ppEnum] -- Return pointer of enumerator
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::EnumConnectionPoints(
|
|
IEnumConnectionPoints **ppEnum)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncStorage::EnumConnectionPoints:%p()\n",
|
|
this));
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncStorage::EnumConnectionPoints\n"));
|
|
return E_NOTIMPL;
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStorage::FindConnectionPoint, public
|
|
//
|
|
// Synopsis: Return a connection point given an IID
|
|
//
|
|
// Arguments: [iid] -- IID to return connection point for
|
|
// [ppCP] -- Return location for pointer
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStorage::FindConnectionPoint(
|
|
REFIID iid,
|
|
IConnectionPoint **ppCP)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncStorage::FindConnectionPoint:%p()\n",
|
|
this));
|
|
|
|
CConnectionPoint *pcp;
|
|
|
|
if (IsEqualIID(iid, IID_IProgressNotify))
|
|
{
|
|
pcp = &_cpoint;
|
|
}
|
|
else
|
|
{
|
|
*ppCP = NULL;
|
|
return E_NOINTERFACE;
|
|
}
|
|
|
|
pcp->AddRef();
|
|
*ppCP = pcp;
|
|
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncStorage::FindConnectionPoint\n"));
|
|
return S_OK;
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncRootStorage::QueryInterface, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncRootStorage::QueryInterface(REFIID iid, void **ppvObj)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
*ppvObj = NULL;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncRootStorage::QueryInterface:%p()\n", this));
|
|
if (IsEqualIID(iid, IID_IUnknown))
|
|
|
|
{
|
|
*ppvObj = (IStorage *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IStorage))
|
|
{
|
|
*ppvObj = (IStorage *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IRootStorage))
|
|
{
|
|
*ppvObj = (IRootStorage *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IConnectionPointContainer))
|
|
{
|
|
*ppvObj = (IConnectionPointContainer *)this;
|
|
}
|
|
else
|
|
{
|
|
sc = E_NOINTERFACE;
|
|
}
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
AddRef();
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncRootStorage::QueryInterface:%p()\n", this));
|
|
return sc;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncRootStorage::AddRef, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncRootStorage::AddRef(void)
|
|
{
|
|
ULONG ulRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncRootStorage::AddRef:%p()\n", this));
|
|
InterlockedIncrement(&_cReferences);
|
|
ulRet = _cReferences;
|
|
_pRealStg->AddRef();
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncRootStorage::AddRef\n"));
|
|
return ulRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncRootStorage::Release, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP_(ULONG) CAsyncRootStorage::Release(void)
|
|
{
|
|
LONG lRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncRootStorage::Release:%p()\n", this));
|
|
|
|
lRet = InterlockedDecrement(&_cReferences);
|
|
_pRealStg->Release();
|
|
if (lRet == 0)
|
|
{
|
|
delete this;
|
|
}
|
|
else if (lRet < 0)
|
|
lRet = 0;
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncRootStorage::Release\n"));
|
|
return (ULONG)lRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncRootStorage::SwitchToFile, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncRootStorage::SwitchToFile(OLECHAR *ptcsFile)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
IRootStorage *prstg;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStorage::%p()\n", this));
|
|
|
|
|
|
if (!SUCCEEDED( _pRealStg->QueryInterface(IID_IRootStorage, (void **) &prstg)))
|
|
return E_NOINTERFACE;
|
|
|
|
do
|
|
{
|
|
sc = prstg->SwitchToFile(ptcsFile);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStorage::\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::QueryInterface, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
|
|
STDMETHODIMP CAsyncStream::QueryInterface(REFIID iid, void **ppvObj)
|
|
{
|
|
SCODE sc = S_OK;
|
|
*ppvObj = NULL;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::QueryInterface:%p()\n", this));
|
|
if (IsEqualIID(iid, IID_IUnknown))
|
|
|
|
{
|
|
*ppvObj = (IStream *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IStream))
|
|
{
|
|
*ppvObj = (IStream *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IConnectionPointContainer))
|
|
{
|
|
*ppvObj = (IConnectionPointContainer *)this;
|
|
}
|
|
else
|
|
{
|
|
sc = E_NOINTERFACE;
|
|
}
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
AddRef();
|
|
_pRealStm->AddRef();
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::QueryInterface:%p()\n", this));
|
|
return sc;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::AddRef, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncStream::AddRef(void)
|
|
{
|
|
ULONG ulRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::AddRef:%p()\n", this));
|
|
InterlockedIncrement(&_cReferences);
|
|
ulRet = _cReferences;
|
|
_pRealStm->AddRef();
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::AddRef\n"));
|
|
return ulRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Release, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncStream::Release(void)
|
|
{
|
|
LONG lRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Release:%p()\n", this));
|
|
|
|
lRet = InterlockedDecrement(&_cReferences);
|
|
_pRealStm->Release();
|
|
if (lRet == 0)
|
|
{
|
|
delete this;
|
|
}
|
|
else if (lRet < 0)
|
|
lRet = 0;
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Release\n"));
|
|
return (ULONG)lRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Read, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::Read(VOID HUGEP *pv,
|
|
ULONG cb,
|
|
ULONG *pcbRead)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Read:%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStm->Read(pv,cb,pcbRead);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Read\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Write, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::Write(VOID const HUGEP *pv,
|
|
ULONG cb,
|
|
ULONG *pcbWritten)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Write:%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStm->Write(pv,cb,pcbWritten);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Write\n"));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Seek, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::Seek(LARGE_INTEGER dlibMove,
|
|
DWORD dwOrigin,
|
|
ULARGE_INTEGER *plibNewPosition)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Seek:%p()\n", this));
|
|
|
|
|
|
do
|
|
{
|
|
sc = _pRealStm->Seek(dlibMove, dwOrigin,plibNewPosition);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Seek\n"));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::CopyTo, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::CopyTo(IStream *pstm,
|
|
ULARGE_INTEGER cb,
|
|
ULARGE_INTEGER *pcbRead,
|
|
ULARGE_INTEGER *pcbWritten)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::CopyTo:%p()\n", this));
|
|
|
|
do
|
|
{ sc = _pRealStm->CopyTo(pstm, cb,pcbRead, pcbWritten);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::CopyTo\n"));
|
|
return ResultFromScode(sc);
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::SetSize, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::SetSize(ULARGE_INTEGER cb)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::SetSize%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStm->SetSize(cb);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::SetSize\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Commit, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::Commit(DWORD grfCommitFlags)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Commit%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStm->Commit(grfCommitFlags);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Commit\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Revert, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::Revert(void)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Revert%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStm->Revert();
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Revert\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::LockRegion, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::LockRegion(ULARGE_INTEGER libOffset,
|
|
ULARGE_INTEGER cb,
|
|
DWORD dwLockType)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::LockRegion%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStm->LockRegion(libOffset,
|
|
cb,
|
|
dwLockType);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::LockRegion\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::UnlockRegion, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::UnlockRegion(ULARGE_INTEGER libOffset,
|
|
ULARGE_INTEGER cb,
|
|
DWORD dwLockType)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::UnlockRegion%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealStm->UnlockRegion(libOffset,
|
|
cb,
|
|
dwLockType);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::UnlockRegion\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Stat, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncStream::Stat(STATSTG *pstatstg, DWORD grfStatFlag)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Stat%p()\n", this));
|
|
|
|
|
|
do
|
|
{ sc = _pRealStm->Stat(pstatstg, grfStatFlag);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Stat\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
|
|
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::Clone, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::Clone(IStream **ppstm)
|
|
{
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncStream::Clone:%p()\n", this));
|
|
do
|
|
{
|
|
sc = _pRealStm->Clone(ppstm);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncStream *pwstm = new CAsyncStream(*ppstm, _pflb);
|
|
*ppstm = (IStream *) pwstm;
|
|
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncStream::Clone\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::EnumConnectionPoints, public
|
|
//
|
|
// Synopsis: Return enumerator on connection points
|
|
//
|
|
// Arguments: [ppEnum] -- Return pointer of enumerator
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::EnumConnectionPoints(
|
|
IEnumConnectionPoints **ppEnum)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncStream::EnumConnectionPoints:%p()\n",
|
|
this));
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncStream::EnumConnectionPoints\n"));
|
|
return E_NOTIMPL;
|
|
}
|
|
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncStream::FindConnectionPoint, public
|
|
//
|
|
// Synopsis: Return a connection point given an IID
|
|
//
|
|
// Arguments: [iid] -- IID to return connection point for
|
|
// [ppCP] -- Return location for pointer
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncStream::FindConnectionPoint(
|
|
REFIID iid,
|
|
IConnectionPoint **ppCP)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncStream::FindConnectionPoint:%p()\n",
|
|
this));
|
|
|
|
CConnectionPoint *pcp;
|
|
|
|
if (IsEqualIID(iid, IID_IProgressNotify))
|
|
{
|
|
pcp = &_cpoint;
|
|
}
|
|
else
|
|
{
|
|
*ppCP = NULL;
|
|
return E_NOINTERFACE;
|
|
}
|
|
|
|
pcp->AddRef();
|
|
*ppCP = pcp;
|
|
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncStream::FindConnectionPoint\n"));
|
|
return S_OK;
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::QueryInterface, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
|
|
STDMETHODIMP CAsyncEnum::QueryInterface(REFIID iid, void **ppvObj)
|
|
{
|
|
SCODE sc = S_OK;
|
|
*ppvObj = NULL;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::QueryInterface:%p()\n", this));
|
|
if (IsEqualIID(iid, IID_IUnknown))
|
|
|
|
{
|
|
*ppvObj = (IEnumSTATSTG *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IEnumSTATSTG))
|
|
{
|
|
*ppvObj = (IEnumSTATSTG *)this;
|
|
}
|
|
else if (IsEqualIID(iid, IID_IConnectionPointContainer))
|
|
{
|
|
*ppvObj = (IConnectionPointContainer *)this;
|
|
}
|
|
else
|
|
{
|
|
sc = E_NOINTERFACE;
|
|
}
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
AddRef();
|
|
_pRealEnum->AddRef();
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::QueryInterface:%p()\n", this));
|
|
return sc;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::AddRef, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncEnum::AddRef(void)
|
|
{
|
|
ULONG ulRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::AddRef:%p()\n", this));
|
|
InterlockedIncrement(&_cReferences);
|
|
ulRet = _cReferences;
|
|
_pRealEnum->AddRef();
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::AddRef\n"));
|
|
return ulRet;
|
|
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Release, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP_(ULONG) CAsyncEnum::Release(void)
|
|
{
|
|
LONG lRet;
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::Release:%p()\n", this));
|
|
|
|
lRet = InterlockedDecrement(&_cReferences);
|
|
_pRealEnum->Release();
|
|
if (lRet == 0)
|
|
{
|
|
delete this;
|
|
}
|
|
else if (lRet < 0)
|
|
lRet = 0;
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::Release\n"));
|
|
return (ULONG)lRet;
|
|
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::EnumConnectionPoints, public
|
|
//
|
|
// Synopsis: Return enumerator on connection points
|
|
//
|
|
// Arguments: [ppEnum] -- Return pointer of enumerator
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncEnum::EnumConnectionPoints(
|
|
IEnumConnectionPoints **ppEnum)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncEnum::EnumConnectionPoints:%p()\n",
|
|
this));
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncEnum::EnumConnectionPoints\n"));
|
|
return E_NOTIMPL;
|
|
}
|
|
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::FindConnectionPoint, public
|
|
//
|
|
// Synopsis: Return a connection point given an IID
|
|
//
|
|
// Arguments: [iid] -- IID to return connection point for
|
|
// [ppCP] -- Return location for pointer
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 28-Dec-95 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
STDMETHODIMP CAsyncEnum::FindConnectionPoint(
|
|
REFIID iid,
|
|
IConnectionPoint **ppCP)
|
|
{
|
|
astgDebugOut((DEB_ITRACE,
|
|
"In CAsyncEnum::FindConnectionPoint:%p()\n",
|
|
this));
|
|
|
|
CConnectionPoint *pcp;
|
|
|
|
if (IsEqualIID(iid, IID_IProgressNotify))
|
|
{
|
|
pcp = &_cpoint;
|
|
}
|
|
else
|
|
{
|
|
*ppCP = NULL;
|
|
return E_NOINTERFACE;
|
|
}
|
|
|
|
pcp->AddRef();
|
|
*ppCP = pcp;
|
|
|
|
astgDebugOut((DEB_ITRACE,
|
|
"Out CAsyncEnum::FindConnectionPoint\n"));
|
|
return S_OK;
|
|
}
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Next, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncEnum::Next(ULONG celt, STATSTG FAR *rgelt, ULONG *pceltFetched)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::Next:%p()\n", this));
|
|
do
|
|
{ sc = _pRealEnum->Next(celt, rgelt, pceltFetched);
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::Next\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Skip, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncEnum::Skip(ULONG celt)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::Skip:%p()\n", this));
|
|
sc = _pRealEnum->Skip(celt);
|
|
|
|
do
|
|
{
|
|
sc = _pRealEnum->Reset();
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::Skip\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Reset, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncEnum::Reset(void)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::Reset:%p()\n", this));
|
|
|
|
do
|
|
{
|
|
sc = _pRealEnum->Reset();
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::Reset\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CAsyncEnum::Clone, public
|
|
//
|
|
// Synopsis:
|
|
//
|
|
// Returns: Appropriate status code
|
|
//
|
|
// History: 01-Jan-96 SusiA Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
STDMETHODIMP CAsyncEnum::Clone(IEnumSTATSTG **ppenm)
|
|
{
|
|
|
|
SCODE sc = S_OK;
|
|
SCODE sc2 = S_OK;
|
|
|
|
astgDebugOut((DEB_ITRACE, "In CAsyncEnum::Clone:%p()\n", this));
|
|
|
|
do
|
|
{
|
|
|
|
sc = _pRealEnum->Clone(ppenm);
|
|
|
|
if (( STG_E_PENDING==sc) && ((sc2 = Notify())!= S_OK))
|
|
return ResultFromScode(sc2);
|
|
|
|
} while (sc == STG_E_PENDING );
|
|
|
|
|
|
if (SUCCEEDED(sc))
|
|
{
|
|
CAsyncEnum *pwenum = new CAsyncEnum(*ppenm, _pflb);
|
|
*ppenm = (IEnumSTATSTG *) pwenum;
|
|
|
|
}
|
|
astgDebugOut((DEB_ITRACE, "Out CAsyncEnum::Clone\n"));
|
|
return ResultFromScode(sc);
|
|
}
|
|
|
|
|