equal
deleted
inserted
replaced
60 // Destructor. |
60 // Destructor. |
61 // ---------------------------------------------------------------------------- |
61 // ---------------------------------------------------------------------------- |
62 // |
62 // |
63 CQueueHandlerSrv::CQueueHandlerSrv(RMsgQueue<TVoIPMsgBuf>* aMsgQueue) : |
63 CQueueHandlerSrv::CQueueHandlerSrv(RMsgQueue<TVoIPMsgBuf>* aMsgQueue) : |
64 CActive(CActive::EPriorityStandard), |
64 CActive(CActive::EPriorityStandard), |
65 // CActive(CActive::EPriorityHigh), |
|
66 iMsgQueue(aMsgQueue) |
65 iMsgQueue(aMsgQueue) |
67 { |
66 { |
68 CActiveScheduler::Add(this); |
67 CActiveScheduler::Add(this); |
69 } |
68 } |
70 |
69 |
75 // |
74 // |
76 void CQueueHandlerSrv::Start() |
75 void CQueueHandlerSrv::Start() |
77 { |
76 { |
78 if (!IsActive()) |
77 if (!IsActive()) |
79 { |
78 { |
|
79 iStatus = KRequestPending; |
80 iMsgQueue->NotifyDataAvailable(iStatus); |
80 iMsgQueue->NotifyDataAvailable(iStatus); |
81 SetActive(); |
81 SetActive(); |
82 } |
82 } |
83 } |
83 } |
84 |
84 |
116 // ---------------------------------------------------------------------------- |
116 // ---------------------------------------------------------------------------- |
117 // |
117 // |
118 TInt CQueueHandlerSrv::RunError(TInt aError) |
118 TInt CQueueHandlerSrv::RunError(TInt aError) |
119 { |
119 { |
120 // RunL can actually leave if any iObserver->Event leave is not trapped |
120 // RunL can actually leave if any iObserver->Event leave is not trapped |
121 // iObserver->Event(ECmdGeneralError, aError); |
121 // iObserver->Event(ECmdGeneralError, aError); |
122 return aError; |
122 return aError; |
123 } |
123 } |
124 |
124 |
125 // ---------------------------------------------------------------------------- |
125 // ---------------------------------------------------------------------------- |
126 // CQueueHandlerSrv::Status |
126 // CQueueHandlerSrv::Status |