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

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

ActiveX/DCOM/ATL

开发平台：

Visual C++

CGenericObserverNotifier.cpp：源码内容
  1. //
  2. // CGenericObserverNotifier.cpp
  3. //
  5. #include "StdAfx.h"
  6. #include "..ServerRNSO.H"
  7. #include "CGenericObserverNotifier.h"
  11. STDMETHODIMP CGenericObserverNotifier::OnNotify(DWORD dwSenderSubject,LONG nSize,byte * pBytes)
  12. {
  13. m_apNotifications.Lock();
  14. m_apNotifications.Add( new CNotificationFromManagerNOTIFY(dwSenderSubject,pBytes,nSize) );
  15. m_apNotifications.Unlock();
  16. m_evtNotification.SetEvent();
  17. return S_OK;
  18. }
  20. STDMETHODIMP CGenericObserverNotifier::OnNotifySubjectBroken(DWORD dwSubjectID)
  21. {
  22. m_apNotifications.Lock();
  23. m_apNotifications.Add( new CNotificationFromManagerNOTIFY_SUBJECTBROKEN(dwSubjectID) );
  24. m_apNotifications.Unlock();
  25. m_evtNotification.SetEvent();
  26. return S_OK;
  27. }
  29. void CGenericObserverNotifier::NotificationMessage(CNotificationFromManager * pNotification)
  30. {
  31. switch( pNotification->m_nType )
  32. {
  33. case CNotificationFromManager::NOTIFY :
  34. OnNotifyNOTIFY( ((CNotificationFromManagerNOTIFY*)pNotification)->m_pNotificationData );
  35. break;
  37. case CNotificationFromManager::NOTIFY_SUBJECTBROKEN :
  38. OnNotifyNOTIFY_SUBJECTBROKEN( ((CNotificationFromManagerNOTIFY_SUBJECTBROKEN*)pNotification)->m_dwSubjectID );
  39. break;
  40. default:
  41. ASSERT(FALSE); // You didnt update that method to be coherent with
  42. // other outgoing methods..
  43. break;
  44. }
  45. }
  47. void CGenericObserverNotifier::OnNotifyNOTIFY(ObserverNotification* pNotification)
  48. {
  49. if( m_pRouter )
  50. m_pRouter->OnNotifyNOTIFY(pNotification);
  51. #ifdef _DEBUG
  52. else
  53. {
  54. CString s;
  55. s.Format("GenericNotification from %dn",pNotification->m_dwSenderObject);
  56. TRACE(s);
  57. }
  58. #endif
  59. }
  60. void CGenericObserverNotifier::OnNotifyNOTIFY_SUBJECTBROKEN(DWORD dwSubjectID)
  61. {
  62. if( m_pRouter )
  63. m_pRouter->OnNotifyNOTIFY_SUBJECTBROKEN(dwSubjectID);
  64. #ifdef _DEBUG
  65. else
  66. {
  67. CString s;
  68. s.Format("Subject %d brokenn",dwSubjectID);
  69. TRACE(s);
  70. }
  71. #endif
  72. }
  74. void CGenericObserverNotifier::FinalRelease( )
  75. {
  76. m_bContinueToRun=FALSE;
  77. if( m_hThread != NULL )
  78. {
  79. m_evtStopThread.SetEvent();
  80. WaitForSingleObject(m_hThread,INFINITE);
  81. }
  82. }
  84. HRESULT CGenericObserverNotifier::FinalConstruct( )
  85. {
  86. DWORD dwThreadId;
  87. m_bContinueToRun=TRUE;
  88. HRESULT hRes=S_OK;
  90. m_hThread = ::CreateThread(NULL,0,ThreadStarter,this,
  91. 0, &dwThreadId );
  93. if( m_hThread == NULL )
  94. {
  95. hRes = E_FAIL;
  96. }
  97. else
  98. {
  99. if( WaitForSingleObject((HANDLE) m_evtStartStopThread,INFINITE) == WAIT_OBJECT_0 )
  100. {
  101. hRes = S_OK;
  102. }
  103. else
  104. {
  105. m_bContinueToRun=FALSE;
  106. hRes = E_FAIL;
  107. }
  108. }
  109. return hRes;
  110. }
  112. DWORD   _stdcall CGenericObserverNotifier::ThreadStarter( LPVOID lpParam ) 
  113. {
  114. return ((CGenericObserverNotifier*)lpParam)->ThreadProc();
  115. }
  117. DWORD CGenericObserverNotifier::ThreadProc()
  118. {
  119. #define NBHANDLES 2
  121. m_evtStartStopThread.SetEvent();
  123. HANDLE handles[NBHANDLES] = { (HANDLE) m_evtNotification,
  124. (HANDLE) m_evtStopThread
  125. };
  127. while( m_bContinueToRun )
  128. {
  129. // get an event from mailbox and from :
  130. // m_evtStartStopThread
  131. DWORD dwWait;
  132. if( m_apNotifications.GetSize() == 0 )
  133. {
  134. dwWait = WaitForMultipleObjects(NBHANDLES,handles,FALSE,INFINITE);
  135. if( dwWait==WAIT_OBJECT_0+1 )
  136. {
  137. break;
  138. }
  139. }
  140. if( m_apNotifications.GetSize() )
  141. {
  142. CNotificationFromManager * pNotification;
  143. m_apNotifications.Lock();
  144. pNotification = m_apNotifications.GetAt(0);
  145. m_apNotifications.RemoveAt(0);
  146. m_apNotifications.Unlock();
  148. NotificationMessage(pNotification);
  150. delete pNotification;
  151. }
  153. }
  155. return TRUE;
  156. }
  159. RnsoNotificationRout * CGenericObserverNotifier::SetNotificationRout(RnsoNotificationRout * pRout)
  160. {
  161. RnsoNotificationRout * pLastRout = m_pRouter;
  162. m_pRouter = pRout;
  163. return pLastRout;
  164. }