1 /*

     2 * Copyright (c) 2006-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:    UDP sender

    15 *

    16 */

    17 

    18 

    19 

    20 

    21 #include "cncmudpsender.h"

    22 #include "ncmconnectionmultiplexerlogs.h"

    23 #include "mncmreceiversenderobserver.h"

    24 #include "cncmsenditem.h"

    25 

    26 

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

    28 // CNcmUdpSender::CNcmUdpSender

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

    30 //

    31 CNcmUdpSender::CNcmUdpSender( RSocket& aSocket,

    32     MNcmReceiverSenderObserver& aObserver ) :

    33     CNcmSender( aSocket, aObserver ),

    34     iDestination( KAFUnspec )

    35     {

    36     }

    37 

    38 

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

    40 // CNcmUdpSender::NewL

    41 // ---------------------------------------------------------------------------

    42 //

    43 CNcmUdpSender* CNcmUdpSender::NewL( RSocket& aSocket,

    44     MNcmReceiverSenderObserver& aObserver )

    45     {

    46     __CONNECTIONMULTIPLEXER( "CNcmUdpSender::NewL" )

    47         

    48     CNcmUdpSender* self = CNcmUdpSender::NewLC( aSocket, aObserver );

    49     CleanupStack::Pop( self );

    50     return self;

    51     }

    52 

    53 

    54 // ---------------------------------------------------------------------------

    55 // CNcmUdpSender::NewLC

    56 // ---------------------------------------------------------------------------

    57 //

    58 CNcmUdpSender* CNcmUdpSender::NewLC( RSocket& aSocket,

    59     MNcmReceiverSenderObserver& aObserver )

    60     {

    61     __CONNECTIONMULTIPLEXER( "CNcmUdpSender::NewLC" )

    62         

    63     CNcmUdpSender* self = new( ELeave ) CNcmUdpSender( aSocket, aObserver );

    64             

    65     CleanupStack::PushL( self );

    66     return self;

    67     }

    68 

    69 

    70 // ---------------------------------------------------------------------------

    71 // CNcmUdpSender::~CNcmUdpSender

    72 // ---------------------------------------------------------------------------

    73 //

    74 CNcmUdpSender::~CNcmUdpSender()

    75     {

    76     __CONNECTIONMULTIPLEXER( "CNcmUdpSender::~CNcmUdpSender" )

    77     }

    78 

    79 

    80 // ---------------------------------------------------------------------------

    81 // CNcmUdpSender::SetDestination

    82 // ---------------------------------------------------------------------------

    83 //

    84 void CNcmUdpSender::SetDestination( const TInetAddr& aDestination )

    85     {

    86     __CONNECTIONMULTIPLEXER_ADDRLOG( 

    87         "CNcmUdpSender::SetDestination - ADDRESS: ", aDestination )

    88         

    89     iDestination = aDestination;

    90     }

    91 

    92 

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

    94 // From class CNcmSender

    95 //

    96 // CNcmUdpSender::DoSend

    97 // ---------------------------------------------------------------------------

    98 //

    99 void CNcmUdpSender::DoSend()

   100     {

   101     __CONNECTIONMULTIPLEXER( "CNcmUdpSender::DoSend" )

   102     

   103     TInt count = iSendItemArray.Count();

   104     TInt lastOneIndex = count - 1;

   105     

   106     if ( count && !IsActive() )

   107         {

   108         if ( iDestination.CmpAddr( KAFUnspec ) )

   109             {

   110             __CONNECTIONMULTIPLEXER( 

   111                 "CNcmUdpSender::DoSend - Error, DESTINATION not set" )

   112             

   113             // Remove last one       

   114             delete iSendItemArray[lastOneIndex];

   115             iSendItemArray.Remove( lastOneIndex );

   116                     

   117             iObserver.Error( KErrNotReady );

   118             return;

   119             }

   120             

   121         __CONNECTIONMULTIPLEXER_ADDRLOG(

   122             "CNcmUdpSender::DoSend - ADDRESS: ", iDestination )

   123         

   124         // Send oldest message

   125         iSendItemArray[0]->SetSendInProgress( ETrue );

   126         iSocket.SendTo( iSendItemArray[0]->Data(), iDestination, 0, iStatus );

   127         SetActive();

   128         }

   129     }