equal
deleted
inserted
replaced
239 msgNeedsToBeCompleted = EFalse; |
239 msgNeedsToBeCompleted = EFalse; |
240 // check fetching still needed or not if needed pack and send again |
240 // check fetching still needed or not if needed pack and send again |
241 if( iPacketsArray.Count() ) |
241 if( iPacketsArray.Count() ) |
242 { |
242 { |
243 CIMCacheBufferArray* packet = iPacketsArray[ 0 ] ; |
243 CIMCacheBufferArray* packet = iPacketsArray[ 0 ] ; |
244 iObserverMessage.Complete( packet->OperationCode() ); |
244 if( packet->OperationCode() == EIMOperationFetchAll ) |
|
245 { |
|
246 iObserverMessage.Complete( EIMOperationDataAvailable ); |
|
247 } |
|
248 else |
|
249 { |
|
250 iObserverMessage.Complete( packet->OperationCode() ); |
|
251 } |
245 iObserverActive = EFalse; |
252 iObserverActive = EFalse; |
246 } |
253 } |
247 |
254 |
248 break; |
255 break; |
249 } |
256 } |
276 iObserverActive = ETrue; |
283 iObserverActive = ETrue; |
277 msgNeedsToBeCompleted = EFalse; |
284 msgNeedsToBeCompleted = EFalse; |
278 if( iPacketsArray.Count() ) |
285 if( iPacketsArray.Count() ) |
279 { |
286 { |
280 CIMCacheBufferArray* packet = iPacketsArray[ 0 ] ; |
287 CIMCacheBufferArray* packet = iPacketsArray[ 0 ] ; |
281 iObserverMessage.Complete( packet->OperationCode() ); |
288 if( packet->OperationCode() == EIMOperationFetchAll ) |
|
289 { |
|
290 iObserverMessage.Complete( EIMOperationUnreadChange ); |
|
291 } |
|
292 else |
|
293 { |
|
294 iObserverMessage.Complete( packet->OperationCode() ); |
|
295 } |
282 iObserverActive = EFalse; |
296 iObserverActive = EFalse; |
283 } |
297 } |
284 break; |
298 break; |
285 } |
299 } |
286 case EIMCacheObserveMessageAccessUnRegister : |
300 case EIMCacheObserveMessageAccessUnRegister : |
558 void CIMCacheSession::SendUnreadChangeNotificationL( MIMCacheMessageHeader* aMsgHeader, |
572 void CIMCacheSession::SendUnreadChangeNotificationL( MIMCacheMessageHeader* aMsgHeader, |
559 CIMCacheMessageBase* aMessage ) |
573 CIMCacheMessageBase* aMessage ) |
560 { |
574 { |
561 // write the message into continuous memory stream |
575 // write the message into continuous memory stream |
562 if( iAccessorInitialized || |
576 if( iAccessorInitialized || |
563 iConvesationInitialized && aMsgHeader->IsChatStarted() ) |
577 iConvesationInitialized /*&& aMsgHeader->IsChatStarted()*/ ) |
564 { |
578 { |
565 ExternalizeSingleChatDataL(EIMOperationUnreadMessage, aMsgHeader, aMessage ); |
579 ExternalizeSingleChatDataL(EIMOperationUnreadMessage, aMsgHeader, aMessage ); |
566 if( iObserverActive ) |
580 if( iObserverActive ) |
567 { |
581 { |
568 iObserverMessage.Complete( EIMOperationUnreadMessage ); |
582 iObserverMessage.Complete( EIMOperationUnreadMessage ); |