equal
deleted
inserted
replaced
3110 * |
3110 * |
3111 * @param aMessage Received message |
3111 * @param aMessage Received message |
3112 ****************************************/ |
3112 ****************************************/ |
3113 void CMsvServerSession::SearchSortOnHeaderAndBodytMsgL(const RMessage2& aMessage) |
3113 void CMsvServerSession::SearchSortOnHeaderAndBodytMsgL(const RMessage2& aMessage) |
3114 { |
3114 { |
|
3115 //For Simultaneously query |
|
3116 if(CMSvSearchSortCacheManager::Instance()->OutstandingSOSOperations() > 0) |
|
3117 { |
|
3118 if(CMSvSearchSortCacheManager::Instance()->iProgress != KMsvSearchSortOpCompleted) |
|
3119 { |
|
3120 User::Leave(KErrServerBusy); // One is SOS request is under proress. |
|
3121 } |
|
3122 } |
|
3123 CMSvSearchSortCacheManager::Instance()->AddOutstandingSOSOperation(); |
|
3124 |
3115 //Header and body. |
3125 //Header and body. |
3116 TMsvOp operationId = aMessage.Int0(); |
3126 TMsvOp operationId = aMessage.Int0(); |
3117 |
3127 |
3118 HBufC8* buffer = NULL; |
3128 HBufC8* buffer = NULL; |
3119 ReadBufferL(aMessage, 1, buffer); |
3129 ReadBufferL(aMessage, 1, buffer); |
3169 * @param aMessage Received message |
3179 * @param aMessage Received message |
3170 ****************************************/ |
3180 ****************************************/ |
3171 |
3181 |
3172 void CMsvServerSession::SearchSortOnIndexEntryL(const RMessage2& aMessage) |
3182 void CMsvServerSession::SearchSortOnIndexEntryL(const RMessage2& aMessage) |
3173 { |
3183 { |
|
3184 //For Simultaneously query |
|
3185 if(CMSvSearchSortCacheManager::Instance()->OutstandingSOSOperations() > 0) |
|
3186 { |
|
3187 if(CMSvSearchSortCacheManager::Instance()->iProgress != KMsvSearchSortOpCompleted) |
|
3188 { |
|
3189 User::Leave(KErrServerBusy); // One is SOS request is under proress. |
|
3190 } |
|
3191 } |
|
3192 CMSvSearchSortCacheManager::Instance()->AddOutstandingSOSOperation(); |
|
3193 |
3174 //Search sort on index entry. |
3194 //Search sort on index entry. |
3175 // Recover the operation data |
3195 // Recover the operation data |
3176 TMsvOp operationId = aMessage.Int0(); |
3196 TMsvOp operationId = aMessage.Int0(); |
3177 |
3197 |
3178 HBufC8* buffer = NULL; |
3198 HBufC8* buffer = NULL; |
3478 aMessage.Complete(KErrNone); |
3498 aMessage.Complete(KErrNone); |
3479 } |
3499 } |
3480 |
3500 |
3481 void CMsvServerSession::GetResultForQueryIDL(const RMessage2& aMessage) |
3501 void CMsvServerSession::GetResultForQueryIDL(const RMessage2& aMessage) |
3482 { |
3502 { |
|
3503 //For Simultaneously query |
|
3504 if(CMSvSearchSortCacheManager::Instance()->OutstandingSOSOperations() > 0) |
|
3505 { |
|
3506 if(CMSvSearchSortCacheManager::Instance()->iProgress != KMsvSearchSortOpCompleted ) |
|
3507 { |
|
3508 User::Leave(KErrServerBusy); // One is SOS request is under proress. |
|
3509 } |
|
3510 } |
|
3511 CMSvSearchSortCacheManager::Instance()->AddOutstandingSOSOperation(); |
|
3512 |
3483 TInt operationId = aMessage.Int0(); |
3513 TInt operationId = aMessage.Int0(); |
3484 TInt queryID = aMessage.Int1(); |
3514 TInt queryID = aMessage.Int1(); |
3485 |
3515 |
3486 iMsvServer.PoliceSearchSortQueryReadRequestL(aMessage,__PLATSEC_DIAGNOSTIC_STRING("Checked by CMsvServerSession::GetResultForQueryIDL")); |
3516 iMsvServer.PoliceSearchSortQueryReadRequestL(aMessage,__PLATSEC_DIAGNOSTIC_STRING("Checked by CMsvServerSession::GetResultForQueryIDL")); |
3487 |
3517 |