1 /*

     2 * Copyright (c) 2002 Nokia Corporation and/or its subsidiary(-ies). 

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 *

     9 * Initial Contributors:

    10 * Nokia Corporation - initial contribution.

    11 *

    12 * Contributors:

    13 *

    14 * Description:  Sub-client to managed particular session slot

    15 *

    16 */

    17 

    18 

    19 // INCLUDE FILES

    20 #include "RPEngStorageSubFolderClient.h"

    21 

    22 #include "RPEngStorageClient.h"

    23 #include "TPEngStorageServerMessages.h"

    24 

    25 #include "PresenceDebugPrint.h"

    26 

    27 // PEC Engine internal constants

    28 #include "PEngInternalGlobalConsts.h"

    29 

    30 // MACROS

    31 #define RETURN_IF_NOT_CONNECTED()\

    32     if(!iConnected)\

    33         {\

    34         return KErrDisconnected;\

    35         }

    36 

    37 #define SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType )\

    38     TIpcArgs messArgs;\

    39     messArgs.Set( KMessageSlot0, &aStoreId );\

    40     messArgs.Set( KMessageSlot1, aStoreType );

    41 

    42 // ============================ MEMBER FUNCTIONS ===============================

    43 // -----------------------------------------------------------------------------

    44 // RPEngStorageSubFolderClient::RPEngStorageSubFolderClient

    45 // C++ default constructor can NOT contain any code, that might leave.

    46 // -----------------------------------------------------------------------------

    47 //

    48 RPEngStorageSubFolderClient::RPEngStorageSubFolderClient( )

    49     {

    50     }

    51 

    52 // Destructor

    53 RPEngStorageSubFolderClient::~RPEngStorageSubFolderClient()

    54     {

    55     }

    56 

    57 // =============================================================================

    58 // ============================ Close/Connect FUNCTIONS ========================

    59 // =============================================================================

    60 

    61 // -----------------------------------------------------------------------------

    62 // RPEngStorageSubFolderClient::Connect()

    63 // -----------------------------------------------------------------------------

    64 //

    65 TInt RPEngStorageSubFolderClient::Connect(

    66     RPEngStorageClient& aStorageMainClient,

    67     const TDesC8& aSessionName )

    68     {

    69     PENG_DP_TXT( "RPEngStorageSubFolderClient::Connect()" );

    70 

    71     TIpcArgs messArguments;

    72     messArguments.Set( KMessageSlot0, &aSessionName );

    73 

    74     TInt err( RSubSessionBase::CreateSubSession(

    75                   aStorageMainClient,

    76                   EMainSessCreateFolderSubSession,

    77                   messArguments ) );

    78 

    79     iConnected = ( err == KErrNone ? ETrue : EFalse );

    80     return err;

    81     }

    82 

    83 

    84 // -----------------------------------------------------------------------------

    85 // RPEngStorageSubFolderClient::Close()

    86 // -----------------------------------------------------------------------------

    87 //

    88 void RPEngStorageSubFolderClient::Close()

    89     {

    90     PENG_DP_TXT( "RPEngStorageSubFolderClient::Close()" );

    91 

    92 

    93     CloseSubSession( EMainSessCloseSubSession );

    94     iConnected = EFalse;

    95     }

    96 

    97 

    98 // =============================================================================

    99 // ======================= Storage FUNCTIONS ===================================

   100 // =============================================================================

   101 

   102 // -----------------------------------------------------------------------------

   103 // RPEngStorageSubFolderClient::Store()

   104 // -----------------------------------------------------------------------------

   105 //

   106 TInt RPEngStorageSubFolderClient::Store(

   107     const TDesC& aStoreId,

   108     TPEngStorageType aStoreType,

   109     const TDesC8& aData )

   110     {

   111     RETURN_IF_NOT_CONNECTED();

   112 

   113     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   114     messArgs.Set( KMessageSlot2, &aData );

   115     return SendReceive( EFolderSubSessWriteEntry, messArgs );

   116     }

   117 

   118 

   119 // -----------------------------------------------------------------------------

   120 // RPEngStorageSubFolderClient::Retrieve()

   121 // -----------------------------------------------------------------------------

   122 //

   123 TInt RPEngStorageSubFolderClient::Retrieve(

   124     const TDesC& aStoreId,

   125     TPEngStorageType aStoreType,

   126     TDes8& aData )

   127     {

   128     RETURN_IF_NOT_CONNECTED();

   129 

   130     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   131     messArgs.Set( KMessageSlot2, &aData );

   132     return SendReceive( EFolderSubSessReadEntry, messArgs );

   133     }

   134 

   135 

   136 // -----------------------------------------------------------------------------

   137 // RPEngStorageSubFolderClient::Delete()

   138 // -----------------------------------------------------------------------------

   139 //

   140 TInt RPEngStorageSubFolderClient::Delete(

   141     const TDesC& aStoreId,

   142     TPEngStorageType aStoreType )

   143     {

   144     RETURN_IF_NOT_CONNECTED();

   145 

   146     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   147     return SendReceive( EFolderSubSessRemoveEntry, messArgs );

   148     }

   149 

   150 

   151 // -----------------------------------------------------------------------------

   152 // RPEngStorageSubFolderClient::StoreEntryLocked()

   153 // -----------------------------------------------------------------------------

   154 //

   155 TInt RPEngStorageSubFolderClient::StoreEntryLocked(

   156     const TDesC& aStoreId,

   157     TPEngStorageType aStoreType,

   158     TPengStorageLockPriority aPriority ) const

   159     {

   160     RETURN_IF_NOT_CONNECTED();

   161 

   162     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   163     messArgs.Set( KMessageSlot2, aPriority );

   164     return SendReceive( EFolderSubSessIsEntryLocked, messArgs );

   165     }

   166 

   167 

   168 // -----------------------------------------------------------------------------

   169 // RPEngStorageSubFolderClient::LockStoreEntry()

   170 // -----------------------------------------------------------------------------

   171 //

   172 TInt RPEngStorageSubFolderClient::LockStoreEntry(

   173     const TDesC& aStoreId,

   174     TPEngStorageType aStoreType,

   175     TPengStorageLockPriority aPriority,

   176     TBool aCreateEntry ) const

   177     {

   178     RETURN_IF_NOT_CONNECTED();

   179 

   180     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   181     // priority and Create flag will be transported as one TInt value

   182     TInt value( aPriority );

   183     value |= ( aCreateEntry  ? KLockEntryCreateMask : 0 );

   184     messArgs.Set( KMessageSlot2,  value );

   185 

   186     return SendReceive( EFolderSubSessLockEntry, messArgs );

   187     }

   188 

   189 

   190 // -----------------------------------------------------------------------------

   191 // RPEngStorageSubFolderClient::UnlockStoreEntry()

   192 // -----------------------------------------------------------------------------

   193 //

   194 TInt RPEngStorageSubFolderClient::UnlockStoreEntry(

   195     const TDesC& aStoreId,

   196     TPEngStorageType aStoreType ) const

   197     {

   198     RETURN_IF_NOT_CONNECTED();

   199 

   200     SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );

   201     return SendReceive( EFolderSubSessUnlockEntry, messArgs );

   202     }

   203 

   204 

   205 // -----------------------------------------------------------------------------

   206 // RPEngStorageSubFolderClient::BufferServerSideNotifications()

   207 // -----------------------------------------------------------------------------

   208 //

   209 TInt RPEngStorageSubFolderClient::BufferServerSideNotifications(

   210     TInt aCount )

   211     {

   212     RETURN_IF_NOT_CONNECTED();

   213     TIpcArgs messArgs;

   214     messArgs.Set( KMessageSlot0, aCount );

   215     return SendReceive( EFolderSubSessSuspendNotification, messArgs );

   216     }

   217 

   218 

   219 // -----------------------------------------------------------------------------

   220 // RPEngStorageSubFolderClient::ReleaseServerSideBuffering()

   221 // -----------------------------------------------------------------------------

   222 //

   223 TInt RPEngStorageSubFolderClient::ReleaseServerSideBuffering(

   224     TInt aCount )

   225     {

   226     RETURN_IF_NOT_CONNECTED();

   227     TIpcArgs messArgs;

   228     messArgs.Set( KMessageSlot0, aCount );

   229     return SendReceive( EFolderSubSessResumeNotification, messArgs );

   230     }

   231 

   232 

   233 // =============================================================================

   234 // ======================= NOTIFY FUNCTIONS ====================================

   235 // =============================================================================

   236 

   237 

   238 // -----------------------------------------------------------------------------

   239 // RPEngStorageSubFolderClient::StartListeningSIdsChanges()

   240 // -----------------------------------------------------------------------------

   241 //

   242 TInt RPEngStorageSubFolderClient::StartListeningSIdsChanges(

   243     const TDesC& aEngagedSIds )

   244     {

   245     RETURN_IF_NOT_CONNECTED();

   246     TIpcArgs messArgs;

   247     messArgs.Set( KMessageSlot0, &aEngagedSIds );

   248     return SendReceive( EFolderSubSessListenSIDsChanges, messArgs );

   249     }

   250 

   251 

   252 // -----------------------------------------------------------------------------

   253 // RPEngStorageSubFolderClient::UpdateListenSIdsChangesScout()

   254 // -----------------------------------------------------------------------------

   255 //

   256 TInt RPEngStorageSubFolderClient::UpdateListenSIdsChangesScout(

   257     const TDesC& aEngagedSIds )

   258     {

   259     RETURN_IF_NOT_CONNECTED();

   260     TIpcArgs messArgs;

   261     messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );

   262     messArgs.Set( KMessageSlot1, &aEngagedSIds );

   263     return SendReceive( EFolderSubSessUpdateListenSIDsScout, messArgs );

   264     }

   265 

   266 

   267 // -----------------------------------------------------------------------------

   268 // RPEngStorageSubFolderClient::ReloadSIdsChangesScout()

   269 // -----------------------------------------------------------------------------

   270 //

   271 TInt RPEngStorageSubFolderClient::ReloadListenSIdsChangesScout(

   272     TRequestStatus& aStatus )

   273     {

   274     RETURN_IF_NOT_CONNECTED();

   275     TIpcArgs messArgs;

   276     messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );

   277     SendReceive( EFolderSubSessReloadAsynchronousScout, messArgs, aStatus );

   278     return KErrNone;

   279     }

   280 

   281 

   282 // -----------------------------------------------------------------------------

   283 // RPEngStorageSubFolderClient::FetchChangedSIdsIndexes()

   284 // -----------------------------------------------------------------------------

   285 //

   286 TInt RPEngStorageSubFolderClient::FetchChangedSIdsIndexes(

   287     TDes& aChangedIds )

   288     {

   289     RETURN_IF_NOT_CONNECTED();

   290     TIpcArgs messArgs;

   291     messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );

   292     messArgs.Set( KMessageSlot1, &aChangedIds );

   293     return SendReceive( EFolderSubSessFetchChangedSIDsIndexes, messArgs );

   294     }

   295 

   296 

   297 // -----------------------------------------------------------------------------

   298 // RPEngStorageSubFolderClient::StopListeningSIdsChanges()

   299 // -----------------------------------------------------------------------------

   300 //

   301 TInt RPEngStorageSubFolderClient::StopListeningSIdsChanges()

   302     {

   303     // add Start listen ID to the message container,

   304     // this request is sort of cancel of request

   305     RETURN_IF_NOT_CONNECTED();

   306     TIpcArgs messArgs;

   307     messArgs.Set( 0, EFolderSubSessListenSIDsChanges );

   308     return SendReceive( EFolderSubSessCancelRequest, messArgs );

   309     }

   310 

   311 

   312 // -----------------------------------------------------------------------------

   313 // RPEngStorageSubFolderClient::NotifyChangedSIDsBlind()

   314 // -----------------------------------------------------------------------------

   315 //

   316 TInt RPEngStorageSubFolderClient::NotifyChangedSIdBlind(

   317     const TDesC& aPackedChangedSId,

   318     TPEngStorageType aStoreType )

   319     {

   320     PENG_DP( D_PENG_LIT( "RPEngStorageSubFolderClient::NotifyChangedSIdBlind: %S" ),

   321              &aPackedChangedSId );

   322 

   323     RETURN_IF_NOT_CONNECTED();

   324 

   325     SET_MESSAGE_ARGUMENTS( aPackedChangedSId, aStoreType );

   326 

   327     return SendReceive( EFolderSubSessNotifyChangedSIDs, messArgs );

   328     }

   329 

   330 //  End of File

   331 

   332