1 /*

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

    20 // INCLUDE FILES

    21 #include "mceclilogs.h"

    22 #include "mcedatareceiver.h"

    23 

    24 

    25 // ============================ MEMBER FUNCTIONS ===============================

    26 

    27 // -----------------------------------------------------------------------------

    28 // CMceDataReceiver::CMceDataReceiver

    29 // -----------------------------------------------------------------------------

    30 //

    31 CMceDataReceiver::CMceDataReceiver( MMceDataSinkObserver& aObserver )

    32     : CActive( EPriorityStandard ), iReady( EFalse ), iObserver( &aObserver )

    33     {

    34     CActiveScheduler::Add(this);

    35     }

    36 

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

    38 // CMceDataReceiver::ConstructL

    39 // -----------------------------------------------------------------------------

    40 //

    41 void CMceDataReceiver::ConstructL()

    42     {

    43     MCECLI_DEBUG("CMceDataReceiver::ConstructL, Entry");

    44     

    45     TBuf16<30> aMessageBuffer(_L("SendQueueForMCCMSRP"));

    46     

    47     TInt aNo = AssignNameToMessageQueueL(aMessageBuffer);

    48     aMessageBuffer.AppendNum(aNo);

    49     

    50     User::LeaveIfError( iSendMsgQueue.OpenGlobal(aMessageBuffer));

    51         

    52     iSendMsgQueue.NotifyDataAvailable( iStatus );

    53     SetActive();

    54     }

    55 

    56 

    57 TInt CMceDataReceiver::AssignNameToMessageQueueL(const TDes16 &aMessageBuffer)

    58     {

    59     MCECLI_DEBUG( "CMccDataReceiver::AssignNameToMessageQueueL" )

    60             

    61     

    62     // queue to be opened for Sending Data

    63     for(TInt i=1; i<=10; i++)

    64         {

    65         TBuf16<30> tempMessage1 = aMessageBuffer;

    66         tempMessage1.AppendNum(i);

    67         TInt err1 = iSendMsgQueue1.CreateGlobal(tempMessage1, 5, EOwnerProcess );

    68         if(err1 == KErrAlreadyExists)

    69             {

    70             TBuf16<30> tempMessage2 = aMessageBuffer;

    71             tempMessage2.AppendNum(i+1);

    72             TInt err2 = iSendMsgQueue2.CreateGlobal(tempMessage2, 5, EOwnerProcess );

    73             if(err2 == KErrNone)

    74                 {

    75                 iSendMsgQueue2.Close();

    76                 MCECLI_DEBUG_DVALUE( "CMccDataReceiver::AssignNameToMessageQueueL" , i )

    77                 return i;

    78                 }

    79             }

    80         else

    81             {

    82             iSendMsgQueue1.Close();

    83             }

    84         }

    85     return 0;

    86             

    87 

    88     }

    89 

    90 // -----------------------------------------------------------------------------

    91 // CMceDataReceiver::NewL

    92 // -----------------------------------------------------------------------------

    93 //

    94 CMceDataReceiver* CMceDataReceiver::NewL( MMceDataSinkObserver& aObserver )

    95     {

    96     MCECLI_DEBUG("CMceDataReceiver::NewL, Entry");

    97     CMceDataReceiver* self = 

    98         new ( ELeave ) CMceDataReceiver( aObserver );

    99     CleanupStack::PushL( self );

   100     self->ConstructL();

   101     CleanupStack::Pop( self );

   102     return self;

   103     }

   104     

   105 // -----------------------------------------------------------------------------

   106 // CMceDataReceiver::~CMceDataReceiver

   107 // -----------------------------------------------------------------------------

   108 //

   109 CMceDataReceiver::~CMceDataReceiver()

   110     {

   111     MCECLI_DEBUG("CMceDataReceiver::~CMceDataReceiver, Entry");

   112     Cancel();

   113     iSendMsgQueue.Close();

   114     }

   115 

   116 // -----------------------------------------------------------------------------

   117 // CMceDataReceiver::DoCancel

   118 // -----------------------------------------------------------------------------

   119 //

   120 void CMceDataReceiver::DoCancel()

   121     {

   122     MCECLI_DEBUG("CMceDataReceiver::DoCancel, Entry");

   123     iSendMsgQueue.CancelDataAvailable();    

   124     }

   125 

   126 // -----------------------------------------------------------------------------

   127 // CMceDataReceiver::RunL

   128 // -----------------------------------------------------------------------------

   129 //  

   130 void CMceDataReceiver::RunL()

   131     {

   132     MCECLI_DEBUG("CMceDataReceiver::RunL, Entry");

   133     CMceMediaStream* dummy1 = NULL;

   134     CMceMediaSink* dummy2 = NULL;

   135     TQueueBuffer buffer;

   136     iSendMsgQueue.Receive( buffer );

   137     iObserver->DataReceived( *dummy1, *dummy2, buffer );

   138     iSendMsgQueue.NotifyDataAvailable( iStatus );

   139     SetActive();

   140     }

   141 

   142 // -----------------------------------------------------------------------------

   143 // CMceDataReceiver::RunError

   144 // -----------------------------------------------------------------------------

   145 //  

   146 TInt CMceDataReceiver::RunError(TInt /*aError*/)

   147     {

   148     MCECLI_DEBUG("CMceDataReceiver::RunError, Entry");

   149     return KErrNone;

   150     }