archive
/
windows-server-2003
mirror of https://github.com/selfrender/Windows-Server-2003
2
0
Fork 0
Code Issues Projects Releases Wiki Activity
Leaked source code of windows server 2003
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
4 Commits
1 Branch
0 Tags
1.5 GiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
windows-server-2003/inetcore/urlmon/astg/stgwrap.cxx

1951 lines
50 KiB
Raw Permalink Blame History

//+---------------------------------------------------------------------------
//
// 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);
}