1 /*

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

    21 // INCLUDE FILES

    22 #include "mccanysourcesinklogs.h"

    23 #include "mccdatareceiver.h"

    24 

    25 

    26 // ============================ MEMBER FUNCTIONS ===============================

    27 

    28 // -----------------------------------------------------------------------------

    29 // CMccDataReceiver::CMccDataReceiver

    30 // -----------------------------------------------------------------------------

    31 //

    32 CMccDataReceiver::CMccDataReceiver( MMccDataReceiverObserver& aObserver )

    33 	: CActive( EPriorityStandard ), iObserver( &aObserver )

    34 	{

    35 	CActiveScheduler::Add(this);

    36 	}

    37 

    38 // -----------------------------------------------------------------------------

    39 // CMccDataReceiver::ConstructL

    40 // -----------------------------------------------------------------------------

    41 //

    42 void CMccDataReceiver::ConstructL()

    43     {

    44     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::ConstructL" )

    45             

    46     TBuf16<30> aMessageBuffer(_L("RecvQueueForMCCMSRP"));

    47     

    48     TInt aNo = AssignNameToMessageQueueL(aMessageBuffer);

    49     aMessageBuffer.AppendNum(aNo);

    50     

    51     User::LeaveIfError(iMsgQueue.CreateGlobal(aMessageBuffer, 5, EOwnerProcess ));

    52     

    53     iMsgQueue.NotifyDataAvailable( iStatus );

    54     SetActive();

    55 

    56     }

    57 

    58 TInt CMccDataReceiver::AssignNameToMessageQueueL(const TDes16 &aMessageBuffer)

    59     {

    60     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::AssignNameToMessageQueueL" )

    61             

    62         

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

    64         {

    65         TBuf16<30> tempMessage1 = aMessageBuffer;

    66         tempMessage1.AppendNum(i);

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

    68         

    69         if(err1 == KErrNone)

    70             {

    71             TBuf16<30> tempMessage2 = aMessageBuffer;

    72             tempMessage2.AppendNum(i+1);

    73             TInt err2 = iMsgQueue2.CreateGlobal(tempMessage2, 5, EOwnerProcess );

    74             

    75             if(err2 == KErrNone)

    76                 {

    77                 iMsgQueue1.Close();

    78                 iMsgQueue2.Close();

    79                 __ANYSOURCESINK_CONTROLL_INT1( "CMccDataReceiver::AssignNameToMessageQueueL", i )

    80                 return i;

    81                 }

    82             else

    83                 {

    84                 iMsgQueue1.Close();

    85                 }

    86             }

    87         }    

    88     return 0;

    89     }

    90 

    91 // -----------------------------------------------------------------------------

    92 // CMccDataReceiver::NewL

    93 // -----------------------------------------------------------------------------

    94 //

    95 CMccDataReceiver* CMccDataReceiver::NewL( MMccDataReceiverObserver& aObserver )

    96     {

    97     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::NewL" )

    98     CMccDataReceiver* self = 

    99     	new ( ELeave ) CMccDataReceiver( aObserver );

   100     CleanupStack::PushL( self );

   101     self->ConstructL();

   102     CleanupStack::Pop( self );

   103     return self;

   104     }

   105 	

   106 // -----------------------------------------------------------------------------

   107 // CMccDataReceiver::~CMccDataReceiver

   108 // -----------------------------------------------------------------------------

   109 //

   110 CMccDataReceiver::~CMccDataReceiver()

   111     {

   112     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::~CMccDataReceiver" )

   113     Cancel();

   114 	iMsgQueue.Close();

   115     }

   116 

   117 // -----------------------------------------------------------------------------

   118 // CMccDataReceiver::DoCancel

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

   120 //

   121 void CMccDataReceiver::DoCancel()

   122 	{

   123     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::DoCancel" )

   124 	iMsgQueue.CancelDataAvailable();	

   125 	}

   126 

   127 // -----------------------------------------------------------------------------

   128 // CMccDataReceiver::RunL

   129 // -----------------------------------------------------------------------------

   130 //	

   131 void CMccDataReceiver::RunL()

   132 	{

   133     __ANYSOURCESINK_CONTROLL( "CMccDataReceiver::RunL" )

   134 	TQueueBuffer buffer;

   135 	iMsgQueue.Receive( buffer );

   136 	iObserver->DataReceivedL( buffer );

   137     iMsgQueue.NotifyDataAvailable( iStatus );

   138     SetActive();

   139 	}

   140 

   141 // -----------------------------------------------------------------------------

   142 // CMccDataReceiver::RunError

   143 // -----------------------------------------------------------------------------

   144 //	

   145 TInt CMccDataReceiver::RunError(TInt /*aError*/)

   146 	{

   147 	return KErrNone;

   148 	}