1 /*

     2 * Copyright (c) 2010 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:

    15 *

    16 */

    17 

    18 // INCLUDE FILES

    19 #include "stubsrvsession.h"

    20 #include "stubsrv.h"

    21 #include "stubsrvapiexecutor.h"

    22 #include "stubclientsrv.h"

    23 

    24 CStubSrvSess* CStubSrvSess::NewL(CStubSrv& aServer)

    25     {

    26     CStubSrvSess* self = new (ELeave) CStubSrvSess (aServer);

    27     CleanupStack::PushL(self);

    28     self->ConstructL();

    29     CleanupStack::Pop(self);

    30     return self;

    31     }

    32 

    33 CStubSrvSess::~CStubSrvSess()

    34     {

    35     delete iExecutor;

    36     iServer.ClientClosed(*this);

    37     }

    38 

    39 void CStubSrvSess::InvokeApiComplete()

    40     {

    41     delete iExecutor;

    42     iExecutor = NULL;

    43     }

    44 

    45 TInt CStubSrvSess::ConsumeApiBehavior(const TApiBehavior& aBeh, TInt aExeDuration)    

    46     {

    47     if (iExecutor && iExecutor->Mode() == ESuspendIfNoBehaviorSet &&

    48         iExecutor->ApiBehavior().MatchId(aBeh))

    49         {

    50         iExecutor->Resume(aBeh, aExeDuration);

    51         return KErrNone;

    52         }

    53     return KErrNotFound;

    54     }

    55     

    56 void CStubSrvSess::ServiceL(const RMessage2& aMessage)

    57     {

    58     TRAPD(err, DispatchMessageL( aMessage ));

    59     if (err != KErrNone)

    60         {

    61         aMessage.Panic(KStubSrvName, err);

    62         }

    63     }

    64 

    65 void CStubSrvSess::DispatchMessageL(const RMessage2& aMessage)

    66     {

    67     switch (aMessage.Function())

    68         {

    69         case EStubSrvEnqueApiBehavior:

    70             {

    71             iServer.EnqueueL(aMessage);

    72             aMessage.Complete(KErrNone);

    73             break;

    74             }

    75         case EStubSrvDeleteApiBehaviors:

    76             {

    77             iServer.DeleteQueues(aMessage);

    78             aMessage.Complete(KErrNone);

    79             break;

    80             }

    81         case EStubSrvInvokeApi:

    82             {

    83             if (iExecutor)

    84                 {

    85                 aMessage.Panic(KStubSrvName, EStubfApiAlreadyStarted);

    86                 break;

    87                 }

    88             TApiBehavior  beh;

    89             TApiBehaviorPckg pckg(beh);

    90             aMessage.ReadL(0, pckg);

    91             TInt transactionId = aMessage.Int2();

    92             TInt dur = 0;

    93             TInt err = iServer.Dequeue(beh, dur, transactionId);

    94             iExecutor = CApiExecutor::NewL();

    95             if (err)

    96                 {

    97                 iExecutor->ExecuteL(aMessage, *this, beh.iLib, beh.iApi);

    98                 }

    99             else

   100                 {

   101                 iExecutor->ExecuteL(aMessage, *this, beh, dur);

   102                 }

   103             break;

   104             }

   105         case EStubSrvInvokeApiCancel:

   106             {

   107             delete iExecutor;

   108             iExecutor = NULL;

   109             aMessage.Complete(KErrNone);

   110             break;

   111             }

   112         case EStubSrvGetApiCompletionCode:

   113             {

   114             iServer.GetApiCompleteCodeL(aMessage);

   115             break;

   116             }

   117         default:

   118             {

   119             aMessage.Panic(KStubSrvName, EStubfBadRequest);

   120             break;

   121             }

   122         }

   123     }

   124 

   125 CStubSrvSess::CStubSrvSess(CStubSrv& aServer) : iServer(aServer)

   126     {

   127     }

   128 

   129 void CStubSrvSess::ConstructL()

   130     {

   131     iServer.ClientOpened(*this);

   132     }

   133 

   134 

   135 // End of File