videoutils_plat/videoconnutility_api/tsrc/VCXTestCommon/src/VCXTestMessageWait.cpp
equal
deleted
inserted
replaced
203 User::LeaveIfError( iError ); |
203 User::LeaveIfError( iError ); |
204 } |
204 } |
205 } |
205 } |
206 else |
206 else |
207 { |
207 { |
208 iWaitStarted = EFalse; |
|
209 |
|
210 // Nothing to wait for. |
208 // Nothing to wait for. |
211 iTimeoutTimer->CancelTimer(); |
209 iTimeoutTimer->CancelTimer(); |
212 |
210 |
213 // Not blocking, inform client with callback. |
211 // Not blocking, inform client with callback. |
214 if( !aDoBlock ) |
212 if( !aDoBlock ) |
245 // CVCXTestMessageWait::ReceiveMessage |
243 // CVCXTestMessageWait::ReceiveMessage |
246 // ----------------------------------------------------------------------------- |
244 // ----------------------------------------------------------------------------- |
247 // |
245 // |
248 EXPORT_C void CVCXTestMessageWait::ReceiveMessage( TInt32 aMsg, TInt aError ) |
246 EXPORT_C void CVCXTestMessageWait::ReceiveMessage( TInt32 aMsg, TInt aError ) |
249 { |
247 { |
250 if( !iWaitStarted ) |
|
251 { |
|
252 VCXLOGLO1("CVCXTestMessageWait::ReceiveMessage: Wait not active."); |
|
253 return; |
|
254 } |
|
255 |
|
256 VCXLOGLO1(">>>CVCXTestMessageWait::ReceiveMessage"); |
248 VCXLOGLO1(">>>CVCXTestMessageWait::ReceiveMessage"); |
257 |
249 |
258 if( aError != KErrNone ) |
250 if( aError != KErrNone ) |
259 { |
251 { |
260 iWaitStarted = EFalse; |
|
261 if( iActiveWaitBlocking->IsWaiting() ) |
252 if( iActiveWaitBlocking->IsWaiting() ) |
262 { |
253 { |
263 iError = aError; |
254 iError = aError; |
264 iActiveWaitBlocking->Stop(); |
255 iActiveWaitBlocking->Stop(); |
265 } |
256 } |
298 } |
289 } |
299 } |
290 } |
300 |
291 |
301 if( iWaitedMessages.Count() <= 0 ) |
292 if( iWaitedMessages.Count() <= 0 ) |
302 { |
293 { |
303 iWaitStarted = EFalse; |
|
304 // Stop wait. |
294 // Stop wait. |
305 if( iActiveWaitBlocking->IsWaiting() ) |
295 if( iActiveWaitBlocking->IsWaiting() ) |
306 { |
296 { |
307 iError = KErrNone; |
297 iError = KErrNone; |
308 iActiveWaitBlocking->Stop(); |
298 iActiveWaitBlocking->Stop(); |
335 iCoolingDown = EFalse; |
325 iCoolingDown = EFalse; |
336 } |
326 } |
337 else |
327 else |
338 if( iWaitedMessages.Count() > 0 ) |
328 if( iWaitedMessages.Count() > 0 ) |
339 { |
329 { |
340 iWaitStarted = EFalse; |
|
341 VCXLOGLO2("CVCXTestMessageWait:: Timeout. Messages left: %d", iWaitedMessages.Count()); |
330 VCXLOGLO2("CVCXTestMessageWait:: Timeout. Messages left: %d", iWaitedMessages.Count()); |
342 if( iActiveWaitBlocking->IsWaiting() ) |
331 if( iActiveWaitBlocking->IsWaiting() ) |
343 { |
332 { |
344 iActiveWaitBlocking->Stop(); |
333 iActiveWaitBlocking->Stop(); |
345 iError = KErrTimedOut; |
334 iError = KErrTimedOut; |