1 /*

     2 * Copyright (c) 2008-2009 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 /**

    19  @file

    20  @internalComponent

    21 */

    22 

    23 #include "msmmclient.h"

    24 #include <usb/usblogger.h>

    25 

    26 #include <e32cmn.h>

    27 

    28 #include "srvdef.h"

    29  

    30 #ifdef __FLOG_ACTIVE

    31 _LIT8(KLogComponent, "UsbHostMsmmClient");

    32 #endif

    33 

    34 // Costants

    35 const TInt KConnectRetry = 0x2;

    36 

    37 //---------------------------------------------------------------------------

    38 //

    39 // NON-MEMBER FUNCTIONS

    40 

    41 static TInt StartServer()

    42     {

    43     LOG_STATIC_FUNC_ENTRY

    44     

    45     TInt ret = KErrNone;

    46 

    47     // Create the server process

    48     const TUidType serverUid(KNullUid, KNullUid, KMsmmServUid);

    49     RProcess server;

    50     _LIT(KNullCommand,"");

    51     ret = server.Create(KMsmmServerBinaryName, KNullCommand, serverUid);

    52 

    53     // Was server process created OK?

    54     if (KErrNone != ret)

    55         {

    56         return ret;

    57         }

    58 

    59     // Set up Rendezvous so that server thread can signal correct startup

    60     TRequestStatus serverDiedRequestStatus;

    61     server.Rendezvous(serverDiedRequestStatus);

    62 

    63     // Status flag should still be pending as we haven't 

    64     // resumed the server yet!

    65     if (serverDiedRequestStatus != KRequestPending)

    66         {

    67         server.Kill(0); // abort the startup here

    68         }

    69     else

    70         {

    71         server.Resume(); // start server

    72         }

    73 

    74     User::WaitForRequest(serverDiedRequestStatus);

    75 

    76     // determine the reason for the server exit

    77     TInt exitReason = (EExitPanic == server.ExitType()) ? 

    78             KErrGeneral : serverDiedRequestStatus.Int();

    79     server.Close();

    80     return exitReason;

    81     }

    82 

    83 //---------------------------------------------------------------------------

    84 // RMsmmSession

    85 //

    86 // Public member functions

    87 

    88 EXPORT_C TInt RMsmmSession::Connect()

    89     {

    90     LOG_FUNC

    91     

    92     TInt retry = KConnectRetry; // Attempt connect twice then give up

    93     TInt ret(KErrNone);

    94     FOREVER

    95         {

    96         ret = CreateSession(KMsmmServerName, Version(), KDefaultMessageSlots);

    97         if ((KErrNotFound != ret) && (KErrServerTerminated != ret))

    98             {

    99             break;

   100             }

   101 

   102         if ((--retry) == 0)

   103             {

   104             break;

   105             }

   106 

   107         ret = StartServer();

   108         if ((KErrNone != ret) && (KErrAlreadyExists != ret))

   109             {

   110             break;

   111             }

   112         }

   113 

   114     if (KErrNone != ret)

   115         {

   116         LOGTEXT2(_L("Underlying error value = %d"), ret)

   117         ret = KErrCouldNotConnect;

   118         }

   119     

   120     return ret; 

   121     }

   122 

   123 EXPORT_C TInt RMsmmSession::Disconnect()

   124     {

   125     LOG_FUNC

   126     

   127     Close();

   128     return KErrNone;

   129     }

   130 

   131 // Called to provide the version number of the server we require for this API

   132 EXPORT_C TVersion RMsmmSession::Version() const

   133     {

   134     LOG_FUNC

   135     

   136     return TVersion(KMsmmServMajorVersionNumber,

   137                     KMsmmServMinorVersionNumber,

   138                     KMsmmServBuildVersionNumber);

   139     }

   140 

   141 EXPORT_C TInt RMsmmSession::AddFunction(

   142         const TUSBMSDeviceDescription& aDevice,

   143         TUint8 aInterfaceNumber, TUint32 aInterfaceToken)

   144     {

   145     LOG_FUNC

   146     

   147     TInt ret(KErrNone);

   148     

   149     TIpcArgs usbmsIpcArgs;

   150     iDevicePkg = aDevice; // Package the device description

   151     usbmsIpcArgs.Set(0, &iDevicePkg);

   152     usbmsIpcArgs.Set(1, aInterfaceNumber);

   153     usbmsIpcArgs.Set(2, aInterfaceToken);

   154 

   155     ret = SendReceive(EHostMsmmServerAddFunction, usbmsIpcArgs);

   156     

   157     return ret;

   158     }

   159 

   160 EXPORT_C TInt RMsmmSession::RemoveDevice(TUint aDevice)

   161     {

   162     LOG_FUNC

   163     

   164     TInt ret(KErrNone);

   165 

   166     TIpcArgs usbmsIpcArgs(aDevice);

   167 

   168     ret = SendReceive(EHostMsmmServerRemoveDevice, usbmsIpcArgs);

   169     

   170     return ret;

   171     }

   172 

   173 EXPORT_C TInt RMsmmSession::__DbgFailNext(TInt aCount)

   174     {

   175     LOG_FUNC

   176     

   177 #ifdef _DEBUG

   178     return SendReceive(EHostMsmmServerDbgFailNext, TIpcArgs(aCount));

   179 #else

   180     (void)aCount;

   181     return KErrNone;

   182 #endif

   183     }

   184 

   185 EXPORT_C TInt RMsmmSession::__DbgAlloc()

   186     {

   187     LOG_FUNC

   188     

   189 #ifdef _DEBUG

   190     return SendReceive(EHostMsmmServerDbgAlloc);

   191 #else

   192     return KErrNone;

   193 #endif

   194     }

   195 

   196 // End of file