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 : |