hxovmgr.cpp
上传用户:zhongxx05
上传日期:2007-06-06
资源大小:33641k
文件大小:12k
- /* ***** BEGIN LICENSE BLOCK *****
- * Version: RCSL 1.0/RPSL 1.0
- *
- * Portions Copyright (c) 1995-2002 RealNetworks, Inc. All Rights Reserved.
- *
- * The contents of this file, and the files included with this file, are
- * subject to the current version of the RealNetworks Public Source License
- * Version 1.0 (the "RPSL") available at
- * http://www.helixcommunity.org/content/rpsl unless you have licensed
- * the file under the RealNetworks Community Source License Version 1.0
- * (the "RCSL") available at http://www.helixcommunity.org/content/rcsl,
- * in which case the RCSL will apply. You may also obtain the license terms
- * directly from RealNetworks. You may not use this file except in
- * compliance with the RPSL or, if you have a valid RCSL with RealNetworks
- * applicable to this file, the RCSL. Please see the applicable RPSL or
- * RCSL for the rights, obligations and limitations governing use of the
- * contents of the file.
- *
- * This file is part of the Helix DNA Technology. RealNetworks is the
- * developer of the Original Code and owns the copyrights in the portions
- * it created.
- *
- * This file, and the files included with this file, is distributed and made
- * available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
- * EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS ALL SUCH WARRANTIES,
- * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS
- * FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
- *
- * Technology Compatibility Kit Test Suite(s) Location:
- * http://www.helixcommunity.org/content/tck
- *
- * Contributor(s):
- *
- * ***** END LICENSE BLOCK ***** */
- #include "hxtypes.h"
- #include "hxcom.h"
- #include "hxresult.h"
- #include "hxstrutl.h"
- #include "hxstring.h"
- #include "hxcomm.h"
- #include "ihxpckts.h"
- #include "hxfiles.h"
- #include "hxcore.h"
- #include "hxmon.h"
- #include "hxprefs.h"
- #include "hxwin.h"
- #include "hxslist.h"
- #include "hxthread.h"
- #include "hxovmgr.h"
- #include "hxtick.h"
- #define DEFAULT_THERMOSTAT_FACTOR 2.0
- //#define _DEBUG_LOG
- HXOverlayManager::HXOverlayManager(IUnknown* pContext)
- : m_lRefCount(0)
- , m_pContext(pContext)
- , m_pCurrentOverlayOwner(NULL)
- , m_CallbackHandle(NULL)
- , m_pScheduler(NULL)
- , m_pOldOverlaySite(NULL)
- , m_pNewOverlaySite(NULL)
- , m_fThemoStatFactor(DEFAULT_THERMOSTAT_FACTOR)
- , m_bChangingOwner(FALSE)
- {
- m_pContext->AddRef();
- #if defined(THREADS_SUPPORTED) || defined(_UNIX_THREADS_SUPPORTED)
- HXMutex::MakeMutex(m_pMutex);
- #else
- HXMutex::MakeStubMutex(m_pMutex);
- #endif
- }
- HXOverlayManager::~HXOverlayManager()
- {
- Close();
- }
- void HXOverlayManager::Initialize()
- {
- m_pContext->QueryInterface(IID_IHXScheduler, (void**)&m_pScheduler);
- IHXPreferences* pPreferences = NULL;
- IHXBuffer* pBuffer = NULL;
- if (HXR_OK == m_pContext->QueryInterface(IID_IHXPreferences,(void**)&pPreferences))
- {
- if (pPreferences->ReadPref("ThermoStatFactor", pBuffer) == HXR_OK)
- {
- m_fThemoStatFactor = atof((char*)pBuffer->GetBuffer()); /* is this ANSI? if not use the next line */
- //sscanf((char*)pBuffer->GetBuffer(), "%f", &m_fThemoStatFactor);
- }
- HX_RELEASE(pBuffer);
- }
- HX_RELEASE(pPreferences);
- }
- void
- HXOverlayManager::Close()
- {
- CSiteStats* pStats;
- CStatPoint* pPoint;
- while (m_ListOfSiteStats.GetCount())
- {
- pStats = (CSiteStats*) m_ListOfSiteStats.RemoveHead();
- while(pStats->samples.GetCount())
- {
- pPoint = (CStatPoint*) pStats->samples.RemoveHead();
- HX_DELETE(pPoint);
- }
- HX_DELETE(pStats);
- }
- if (m_CallbackHandle)
- {
- m_pScheduler->Remove(m_CallbackHandle);
- m_CallbackHandle = 0;
- }
- HX_RELEASE(m_pContext);
- HX_RELEASE(m_pScheduler);
- HX_DELETE(m_pMutex);
- }
- /*
- * IUnknown methods
- */
- /////////////////////////////////////////////////////////////////////////
- // Method:
- // IUnknown::QueryInterface
- // Purpose:
- // Implement this to export the interfaces supported by your
- // object.
- //
- STDMETHODIMP HXOverlayManager::QueryInterface(REFIID riid, void** ppvObj)
- {
- QInterfaceList qiList[] =
- {
- { GET_IIDHANDLE(IID_IHXOverlayManager), (IHXOverlayManager*)this },
- { GET_IIDHANDLE(IID_IHXCallback), (IHXCallback*)this },
- { GET_IIDHANDLE(IID_IUnknown), (IUnknown*)(IHXOverlayManager*)this },
- };
-
- return ::QIFind(qiList, QILISTSIZE(qiList), riid, ppvObj);
- }
- /////////////////////////////////////////////////////////////////////////
- // Method:
- // IUnknown::AddRef
- // Purpose:
- // Everyone usually implements this the same... feel free to use
- // this implementation.
- //
- STDMETHODIMP_(ULONG32) HXOverlayManager::AddRef()
- {
- return InterlockedIncrement(&m_lRefCount);
- }
- /////////////////////////////////////////////////////////////////////////
- // Method:
- // IUnknown::Release
- // Purpose:
- // Everyone usually implements this the same... feel free to use
- // this implementation.
- //
- STDMETHODIMP_(ULONG32) HXOverlayManager::Release()
- {
- if (InterlockedDecrement(&m_lRefCount) > 0)
- {
- return m_lRefCount;
- }
- delete this;
- return 0;
- }
- STDMETHODIMP HXOverlayManager::HasOverlay(THIS_
- IHXOverlayResponse* pResp
- )
- {
- m_pMutex->Lock();
- HX_RESULT res = HXR_FAIL;
- if (!m_pCurrentOverlayOwner)
- {
- m_pCurrentOverlayOwner = pResp;
- res = HXR_OK;
- }
- m_pMutex->Unlock();
- return res;
- }
- STDMETHODIMP HXOverlayManager::AddStats(THIS_
- IHXOverlayResponse* pResp,
- UINT32 ulNumPixels)
- {
- if (m_bChangingOwner)
- return HXR_OK;
- m_pMutex->Lock();
- CSiteStats* pStats;
- CStatPoint* pPoint;
- UINT32 time = HX_GET_TICKCOUNT();
- BOOL bExisted = FALSE;
- CHXSimpleList::Iterator i;
- for (i = m_ListOfSiteStats.Begin(); i != m_ListOfSiteStats.End(); ++i)
- {
- pStats = (CSiteStats*)*i;
- if (pStats->pResp == pResp)
- {
- #ifdef _DEBUG_LOG
- FILE* f = fopen("c:\overlay.txt", "a+");
- if (f)
- {
- fprintf(f, "Owner: %p Pixels: %dn", pResp, ulNumPixels);
- fclose(f);
- }
- #endif
- AddStatPoint(pStats, ulNumPixels, time);
- bExisted = TRUE;
- }
- while(pStats->samples.GetCount())
- {
- pPoint = (CStatPoint*) pStats->samples.GetHead();
- if (pPoint->ulTime + 1000 > time)
- {
- break;
- }
- pStats->ulNumPixelsPerSecond -= pPoint->ulPixels;
- pStats->samples.RemoveHead();
- HX_DELETE(pPoint);
- }
- #ifdef _DEBUG_LOG
- FILE* f = fopen("c:\overlay.txt", "a+");
- if (f)
- {
- fprintf(f, "*Owner: %p Pixels: %d Count: %dn", pStats->pResp, pStats->ulNumPixelsPerSecond, pStats->samples.GetCount());
- fclose(f);
- }
- #endif
- }
- if (!bExisted)
- {
- pStats = new CSiteStats;
- pStats->ulFirstTime = time;
- pStats->ulNumPixelsPerSecond = 0;
- pStats->pResp = pResp;
- m_ListOfSiteStats.AddTail(pStats);
- AddStatPoint(pStats, ulNumPixels, time);
- }
- ValidateCurrentOwner();
- m_pMutex->Unlock();
- return HXR_OK;
- }
- void HXOverlayManager::AddStatPoint(CSiteStats* pStats, UINT32 ulNumPixels, UINT32 ulTime)
- {
- CStatPoint* pPoint;
- pPoint = new CStatPoint;
- pPoint->ulTime = ulTime;
- pPoint->ulPixels = ulNumPixels;
- pStats->ulNumPixelsPerSecond += pPoint->ulPixels;
- pStats->samples.AddTail(pPoint);
- }
- void HXOverlayManager::ValidateCurrentOwner()
- {
- if (!m_pCurrentOverlayOwner)
- {
- return;
- }
- IHXOverlayResponse* pMaxResp = NULL;
- UINT32 ulMaxNumPixelsPerSecond = 0;
- UINT32 ulCurrentNumPixelsPerSecond = 0;
- CSiteStats* pStats = NULL;
- CHXSimpleList::Iterator i;
- for (i = m_ListOfSiteStats.Begin(); i != m_ListOfSiteStats.End(); ++i)
- {
- pStats = (CSiteStats*)*i;
- if (pStats->pResp == m_pCurrentOverlayOwner)
- {
- ulCurrentNumPixelsPerSecond = pStats->ulNumPixelsPerSecond;
- }
- if (ulMaxNumPixelsPerSecond < pStats->ulNumPixelsPerSecond)
- {
- ulMaxNumPixelsPerSecond = pStats->ulNumPixelsPerSecond;
- pMaxResp = pStats->pResp;
- }
- }
- #ifdef _DEBUG_LOG
- FILE* f = fopen("c:\overlay.txt", "a+");
- fprintf(f, "CurrentOvOwner = %p Pels: %d ttt Max: %p Pels: %dn", m_pCurrentOverlayOwner, ulCurrentNumPixelsPerSecond, pMaxResp, ulMaxNumPixelsPerSecond);
- fclose(f);
- #endif
- UINT32 ulTempMaxNumPixelsPerSecond = 0;
- if ((double)ulMaxNumPixelsPerSecond > (double)ulCurrentNumPixelsPerSecond * 2)
- {
- #ifdef _DEBUG_LOG
- FILE* f = fopen("c:\overlay.txt", "a+");
- if (f)
- {
- CHXSimpleList::Iterator i;
- for (i = m_ListOfSiteStats.Begin(); i != m_ListOfSiteStats.End(); ++i)
- {
- pStats = (CSiteStats*)*i;
- fprintf(f, "Owner: %p Pixels: %d NumSamples: %d n", pStats->pResp , pStats->ulNumPixelsPerSecond, pStats->samples.GetCount());
- if (pStats->pResp == m_pCurrentOverlayOwner)
- {
- fprintf(f, "** Current Owner: %p Current Num: %dn", pStats->pResp , pStats->ulNumPixelsPerSecond);
- }
- if (ulTempMaxNumPixelsPerSecond < pStats->ulNumPixelsPerSecond)
- {
- fprintf(f, "** Current Max Owner: %p Current Num: %dn", pStats->pResp , pStats->ulNumPixelsPerSecond);
- ulTempMaxNumPixelsPerSecond = pStats->ulNumPixelsPerSecond;
- }
- }
- fclose(f);
- }
- #endif
- ScheduleCallback(m_pCurrentOverlayOwner, pMaxResp);
- }
- }
- void HXOverlayManager::ScheduleCallback(IHXOverlayResponse* pOld, IHXOverlayResponse* pNew)
- {
- if (m_pScheduler && !m_CallbackHandle)
- {
- m_CallbackHandle = m_pScheduler->RelativeEnter(this, 0);
- m_pOldOverlaySite = pOld;
- m_pNewOverlaySite = pNew;
- }
- }
- /************************************************************************
- * Method:
- * IHXCallback::Func
- */
- STDMETHODIMP HXOverlayManager::Func(void)
- {
- m_bChangingOwner = TRUE;
- m_pMutex->Lock();
- AddRef();
- if (m_pOldOverlaySite && m_pNewOverlaySite)
- {
- if (HXR_OK == m_pOldOverlaySite->OverlayRevoked())
- {
- m_pCurrentOverlayOwner = NULL;
- if (HXR_OK == m_pNewOverlaySite->OverlayGranted())
- {
- m_pCurrentOverlayOwner = m_pNewOverlaySite;
- }
- }
- }
- m_pNewOverlaySite = NULL;
- m_pOldOverlaySite = NULL;
- m_CallbackHandle = 0;
- Release();
-
- m_pMutex->Unlock();
- m_bChangingOwner = FALSE;
- return HXR_OK;
- }
- STDMETHODIMP HXOverlayManager::RemoveOverlayRequest(THIS_ IHXOverlayResponse* pResp )
- {
- m_pMutex->Lock();
-
- HX_RESULT res = HXR_FAIL;
- if (pResp == m_pNewOverlaySite && m_CallbackHandle)
- {
- m_pScheduler->Remove(m_CallbackHandle);
- m_CallbackHandle = 0;
- m_pNewOverlaySite = NULL;
- m_pOldOverlaySite = NULL;
- }
- if (m_pCurrentOverlayOwner == pResp)
- {
- m_pCurrentOverlayOwner = NULL;
- }
- CSiteStats* pStats;
- CStatPoint* pPoint;
- LISTPOSITION pos = NULL;
-
- pos = m_ListOfSiteStats.GetHeadPosition();
- while (pos)
- {
- pStats = (CSiteStats*)m_ListOfSiteStats.GetAt(pos);
- if (pStats->pResp == pResp)
- {
- res = HXR_OK;
- while(pStats->samples.GetCount())
- {
- pPoint = (CStatPoint*) pStats->samples.RemoveHead();
- HX_DELETE(pPoint);
- }
- HX_DELETE(pStats);
- m_ListOfSiteStats.RemoveAt(pos);
- break;
- }
- m_ListOfSiteStats.GetNext(pos);
- }
- m_pMutex->Unlock();
- return res;
- }