开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > ActiveX/DCOM/ATL > 查看源码
GenericObserver.cpp
资源名称：rnso.zip　[点击查看]
上传用户：lianquan
上传日期：2007-01-02
资源大小：197k
文件大小：4k
源码类别：

ActiveX/DCOM/ATL

开发平台：

Visual C++

GenericObserver.cpp：源码内容
  1. // GenericObserver.cpp : Implementation of CGenericObserver
  2. #include "stdafx.h"
  3. #include "RNSO.h"
  4. #include "GenericObserver.h"
  5. #include "Manager.h"
  7. /////////////////////////////////////////////////////////////////////////////
  8. // CGenericObserver
  12. STDMETHODIMP_(HRESULT) CGenericObserver::Subscribe(DWORD dwSubjectID)
  13. {
  14. // TODO: Add your implementation code here
  15. if( GenericManager::AddSubscription(m_dwObserverID,dwSubjectID) )
  16. return S_OK;
  17. else
  18. return E_FAIL;
  19. }
  21. STDMETHODIMP_(HRESULT) CGenericObserver::Unsubscribe(DWORD dwSubjectID,BOOL bAllSubjects)
  22. {
  23. // TODO: Add your implementation code here
  24. GenericManager::RemoveSubscription(m_dwObserverID,dwSubjectID,bAllSubjects);
  26. return S_OK;
  27. }
  29. void CGenericObserver::FinalRelease( )
  30. {
  31. GenericManager::RemoveObject(this);
  32. }
  35. void CGenericObserver::OnNotify(DWORD dwSubjectSender,LONG nSize,byte * pBytes)
  36. {
  37. IUnknown ** ppUnk = m_vec.begin();
  38. if( ppUnk != NULL )
  39. {
  40. //while( *ppUnk )
  41. {
  42. IGenericObserverNotification * pINotif = (IGenericObserverNotification *)*ppUnk;
  43. HRESULT hr = pINotif->OnNotify(dwSubjectSender,nSize,pBytes);
  44. if( hr == 0x800706BA )
  45. {
  46. // error 
  47. }
  48. //ppUnk++;
  49. }
  50. }
  51. }
  53. void CGenericObserver::OnNotifySubjectBroken(DWORD dwSubject)
  54. {
  55. IUnknown ** ppUnk = m_vec.begin();
  56. if( ppUnk != NULL )
  57. {
  58. IGenericObserverNotification * pINotif = (IGenericObserverNotification *)*ppUnk;
  59. pINotif->OnNotifySubjectBroken(dwSubject);
  60. }
  61. }
  63. HRESULT CGenericObserver::FinalConstruct( )
  64. {
  65. BOOL bOk = FALSE;
  66. m_dwObserverID = GenericManager::GenerateObjectID(bOk,this);
  67. char sTmp[64];
  68. sprintf(sTmp,"%d",m_dwObserverID);
  69. m_sname=CComBSTR(sTmp);
  70. if( bOk )
  71. return S_OK;
  72. else
  73. return E_FAIL;
  74. }
  76. STDMETHODIMP_(HRESULT) CGenericObserver::IsSubscribed(DWORD dwSubjectID)
  77. {
  78. // TODO: Add your implementation code here
  79. if( GenericManager::IsObserverSubscribedToSubject(m_dwObserverID,dwSubjectID) )
  80. return S_OK;
  81. else
  82. return S_FALSE ;
  83. }
  85. STDMETHODIMP_(HRESULT) CGenericObserver::GetCountSubscriptions(long * lCount)
  86. {
  87. // TODO: Add your implementation code here
  89. *lCount = m_lCountSubjects;
  90. return S_OK;
  91. }
  93. STDMETHODIMP_(HRESULT) CGenericObserver::GetCountSubscribers(long * lCount)
  94. {
  95. // TODO: Add your implementation code here
  97. *lCount = m_lCountObservers;
  98. return S_OK;
  99. }
  102. STDMETHODIMP_(HRESULT) CGenericObserver::Notify(long nSizeNotification, byte * pNotification)
  103. {
  104. // TODO: Add your implementation code here
  105. if( GenericManager::AddNotification( new ObserverNotification(m_dwObserverID,pNotification,nSizeNotification)) )
  106. return S_OK;
  107. else
  108. return E_FAIL;
  109. }
  112. STDMETHODIMP_(HRESULT) CGenericObserver::FindObjectID(BSTR strname,DWORD * dwObjectID)
  113. {
  114. if( GenericManager::FindObjectID(strname,dwObjectID) )
  115. return S_OK;
  116. return E_FAIL;
  117. }
  120. void CGenericObserver::IncObs()
  121. {
  122. InterlockedIncrement(&m_lCountObservers);
  123. }
  125. void CGenericObserver::SubObs()
  126. {
  127. InterlockedDecrement(&m_lCountObservers);
  128. }
  131. void CGenericObserver::IncSub()
  132. {
  133. InterlockedIncrement(&m_lCountSubjects);
  134. }
  135. void CGenericObserver::SubSub()
  136. {
  137. InterlockedDecrement(&m_lCountSubjects);
  138. }
  140. STDMETHODIMP CGenericObserver::GetObjectID(DWORD * dwID)
  141. {
  142. // TODO: Add your implementation code here
  143. *dwID = m_dwObserverID;
  144. return S_OK;
  145. }
  147. STDMETHODIMP_(HRESULT) CGenericObserver::GetName(BSTR *strName)
  148. {
  149. *strName=m_sname.Copy();
  150. return S_OK;
  151. }
  153. STDMETHODIMP_(HRESULT) CGenericObserver::SetName(BSTR strName)
  154. {
  155. CComBSTR strLastname = m_sname;
  156. CComBSTR str(strName);
  157. m_sname = str;
  158. if( GenericManager::FindName(m_sname) == 1 )
  159. return S_OK;
  160. return E_FAIL;
  161. }