1 /*

     2 * Copyright (c) 2002-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:  GPRS Data channel for BIP

    15 *

    16 */

    17 

    18 

    19 #include <etelqos.h>

    20 #include <cmmanager.h>

    21 #include <cmconnectionmethod.h>

    22 #include <cmpluginpacketdatadef.h>

    23 #include <cs_subconevents.h>                    // For subconnection events

    24 #include <networking/qos3gpp_subconparams.h>    // For extension parameters

    25 #include <e32std.h>                             // TRealFormat

    26 #include <e32cmn.h>

    27 #ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

    28 #include <in_sock_internal.h>                   // For KSoUdpRecvBuf contant

    29 #endif

    30 #include "CSatBIPUtils.h"

    31 #include "CSatBIPGPRSDataChannel.h"

    32 #include "SatLog.h"

    33 #include "EnginePanic.h"

    34 #include "CSatBIPDataSender.h"

    35 #include "CSatBIPDataReceiver.h"

    36 #include "MSatSendDataObserver.h"

    37 #include "MSatConnectionObserver.h"

    38 #include "TSatChannelIDInfo.h"

    39 #include "TSatQoSParser.h"

    40 #include "csatbipsubconneventobserver.h"

    41 #include "csatsactivewrapper.h"

    42  

    43 // Required GPRS parameters

    44 const TUint8 KReqGprsQoSParams = 6;

    45 // Required packet protocol type is always 02 for GPRS -> IP Protocol

    46 const TUint8 KReqPacketProtType = 0x02;

    47 // Position of the protocol type in the array

    48 const TUint8 KProtocolPos = 5;

    49 // Lengths of IP address

    50 const TUint8 KIPv4Length = 4;

    51 const TUint8 KIPv6Length = 16;

    52 

    53 #ifdef SAT_USE_DUMMY_TSY

    54 const TUint8 KIpAddressSize( 15 );

    55 const TUint8 KIpv4Length( 4 );

    56 const TUint8 KIpv6Length( 16 );

    57 const TUint8 KIpAddressA( 0 );

    58 const TUint KIpAddressAValue( 127 );

    59 const TUint8 KIpAddressB( 1 );

    60 const TUint KIpAddressBValue( 0 );

    61 const TUint8 KIpAddressC( 2 );

    62 const TUint KIpAddressCValue( 0 );

    63 const TUint8 KIpAddressD( 3 );

    64 const TUint KIpAddressDValueDestination( 2 );

    65 const TUint KIpAddressDValueLocal( 3 );

    66 #endif

    67 

    68 #ifdef ENABLE_SAT_LOGGING

    69 const TUint8 KIpAddressLogSize( 40 );

    70 #endif

    71 

    72 const TInt KReCheckStatusDelay = 100000; // 100ms

    73 const TInt KMaxAttempts = 20;            // 20*100ms= 2s 

    74 // ======== MEMBER FUNCTIONS ========

    75 

    76 // ---------------------------------------------------------------------------

    77 // Two-phased constructor.

    78 // ---------------------------------------------------------------------------

    79 //

    80 CSatBIPGPRSDataChannel* CSatBIPGPRSDataChannel::NewL(

    81     CSatBIPUtils& aUtils,

    82     RSocketServ& aSocketServer,

    83     TSatChannelIdInfo& aChannelId,

    84     RConnection& aConnection,

    85     RSubConnection& aSubConnection )

    86     {

    87     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::NewL calling" )

    88 

    89     CSatBIPGPRSDataChannel* self = new( ELeave ) CSatBIPGPRSDataChannel( 

    90         aUtils, aSocketServer, aChannelId, aConnection, aSubConnection );

    91 

    92     CleanupStack::PushL( self );

    93     self->ConstructL();

    94     CleanupStack::Pop( self );

    95 

    96     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::NewL exiting" )

    97     return self;

    98     }

    99 

   100 // ---------------------------------------------------------------------------

   101 // Two-phased constructor.

   102 // ---------------------------------------------------------------------------

   103 //

   104 CSatBIPGPRSDataChannel* CSatBIPGPRSDataChannel::NewLC(

   105     CSatBIPUtils& aUtils,

   106     RSocketServ& aSocketServer,

   107     TSatChannelIdInfo& aChannelId,

   108     RConnection& aConnection,

   109     RSubConnection& aSubConnection )

   110     {

   111     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::NewLC calling" )

   112 

   113     CSatBIPGPRSDataChannel* self = new ( ELeave ) CSatBIPGPRSDataChannel( 

   114         aUtils, aSocketServer, aChannelId, aConnection, aSubConnection );

   115 

   116     CleanupStack::PushL( self );

   117     self->ConstructL();

   118 

   119     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::NewLC exiting" )

   120     return self;

   121     }

   122 

   123 // ---------------------------------------------------------------------------

   124 // destructor.

   125 // ---------------------------------------------------------------------------

   126 //

   127 CSatBIPGPRSDataChannel::~CSatBIPGPRSDataChannel()

   128     {

   129     LOG( SIMPLE,

   130          "SATENGINE: CSatBIPGPRSDataChannel::~CSatBIPGPRSDataChannel calling" )

   131 

   132     // Close sender

   133     delete iSender;

   134     

   135     // Close receiver

   136     delete iReceiver;

   137     

   138     // Close receiver

   139     delete iSubConnEventObserver;

   140     

   141     // Close Socket

   142     iSocket.Close();

   143     

   144     // Delete buffers

   145     delete iSendStore;

   146     iRcvBuffer.Zero();

   147     

   148     LOG( SIMPLE,

   149          "SATENGINE: CSatBIPGPRSDataChannel::~CSatBIPGPRSDataChannel exiting" )

   150     }

   151 

   152 // ---------------------------------------------------------------------------

   153 // Sets up connection

   154 // ---------------------------------------------------------------------------

   155 //

   156 void CSatBIPGPRSDataChannel::SetupConnectionL( 

   157     const TSatBipConnectionInfo& aConnParams )

   158     {

   159     LOG( SIMPLE, 

   160         "SATENGINE: CSatBIPGPRSDataChannel::SetupConnectionL calling" )

   161 

   162     // Allocate Send buffer

   163     iSendStore = HBufC8::NewL( aConnParams.iBufferSize );

   164 

   165     // Store the rest of connection information

   166     iConnInfo = aConnParams;

   167 

   168     // Define used protocol

   169     iUseTcpProtocol = ( RSat::ETcp == iConnInfo.iProtocol.iTransportProto );

   170 

   171     // Set connection stage

   172     iConnStage = ESatBIPClosed;

   173 

   174     LOG( SIMPLE, 

   175         "SATENGINE: CSatBIPGPRSDataChannel::SetupConnectionL exiting" )

   176     }

   177 

   178 // ---------------------------------------------------------------------------

   179 // Opens the connection

   180 // ---------------------------------------------------------------------------

   181 //

   182 void CSatBIPGPRSDataChannel::ActivateConnectionL(

   183     MSatConnectionObserver* aObserver )

   184     {

   185     LOG( SIMPLE,

   186         "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL calling" )

   187     

   188     TInt errCode( KErrNone );               // errCode

   189     RPacketQoS::TQoSGPRSNegotiated negQoS;  // The negotiated QoS

   190     

   191     // If the connection has not been setup or already connecting, leave

   192     if ( ESatBIPClosed != iConnStage )

   193         {

   194         LOG( SIMPLE,

   195         "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL \

   196         ESatBIPClosed != iConnStage" )

   197         User::Leave( KErrCancel );

   198         }

   199 

   200     iConnectionObserver = aObserver;

   201 

   202     if ( RSat::EIPv4Address == iConnInfo.iDestination.iType )

   203         {

   204         LOG( NORMAL, 

   205              "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   206              Using IPv4" )

   207         }

   208     else if ( RSat::EIPv6Address == iConnInfo.iDestination.iType )

   209         {

   210         LOG( NORMAL, 

   211              "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   212              Using IPv6" )

   213         }

   214     else

   215         {

   216         LOG( NORMAL, "  Unknown IP type" )

   217         User::Leave( KErrUnknown );

   218         }

   219     

   220     // Open connection if it is inactive

   221     if ( !iUtils.IsConnectionActivated() )

   222         {

   223         LOG( NORMAL, 

   224              "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   225              Connection is inactive, open connection " )

   226         // Write the primary PDP Context QoS Parameters to CMManager

   227         // before activating the primary PDP Context.  

   228         WritePrimaryPDPContextQoSParamsL();

   229         

   230         // Open sub-session to SocketServer    

   231         errCode = iConnection.Open( iSocketServ );

   232         LOG2( NORMAL, 

   233               "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   234               RConnection opened with code: %i", errCode )

   235         User::LeaveIfError( errCode );

   236         

   237         // Start connection. If there are no override settings, 

   238         // use default settings

   239         if ( iConnInfo.iOverrideSet )

   240             {

   241             LOG( NORMAL, "Starting connection with override settings" )

   242             TConnPrefList prefList;

   243             TExtendedConnPref extPrefs;

   244             

   245             extPrefs.SetNoteBehaviour( 

   246                     iConnInfo.iOverrideSet->NoteBehaviour() );

   247             extPrefs.SetIapId( iConnInfo.iOverrideSet->IapId() );

   248             prefList.AppendL( &extPrefs );

   249             

   250             errCode = iConnection.Start( prefList );

   251             }

   252         else

   253             {

   254             LOG( NORMAL, "Starting connection with default settings" )

   255             errCode = iConnection.Start();

   256             }

   257         

   258         LOG2( NORMAL, 

   259               "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   260               RConnection started with code: %i", errCode )

   261         User::LeaveIfError( errCode );

   262         

   263         // Erase the primary PDP Context QoS Parameters from CMManager 

   264         WriteDefaultQoSParamsL();

   265         

   266         // Set Connection activated

   267         iUtils.SetConnectionActivated( ETrue );

   268         // Make sure the subconnection is inactive.

   269         iUtils.SetSubConnectionActivated( EFalse );

   270         }

   271     else    

   272         {

   273         LOG( NORMAL, 

   274              "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   275              Connection is active " )

   276         // Connection is active, open SubConnection if it is inactive

   277         if ( !iUtils.IsSubConnectionActivated() ) 

   278             {

   279             LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::\

   280             ActivateConnectionL SubConnection is inactive, open \

   281             subconnection" )

   282             // Open SubConnection 

   283             OpenSubConnection();

   284             }

   285         }

   286     

   287     // Set up QoS values

   288     SetConnQoSParamsL();

   289     

   290     // Open socket

   291     OpenSocketL();

   292     

   293     // UDP Socket doesn't need ActiveObject, so we don't have to wait.

   294     if ( !iUseTcpProtocol )

   295         {

   296         LOG( NORMAL, 

   297              "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL\

   298              UDP protocol " )

   299         StartReceiveL();

   300         iConnStage = ESatBIPConnected;

   301         

   302         // Notify ConnectionObserver

   303         iConnectionObserver->ConnectionNotification( KErrNone );

   304         }

   305     

   306     LOG( SIMPLE,

   307         "SATENGINE: CSatBIPGPRSDataChannel::ActivateConnectionL exiting" )

   308     }

   309 

   310 // ---------------------------------------------------------------------------

   311 // ends or stores the data.

   312 // ---------------------------------------------------------------------------

   313 //

   314 void CSatBIPGPRSDataChannel::GetNegotiatedQoSParams( 

   315     RSat::TBearerParams& aResult ) const

   316     {

   317     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::NegotiatedQoSParams\

   318         calling - exiting" )

   319     aResult = iConnInfo.iBearerParams;

   320     }

   321 

   322 // ---------------------------------------------------------------------------

   323 // Sends or stores the data.

   324 // ---------------------------------------------------------------------------

   325 //

   326 TInt CSatBIPGPRSDataChannel::SendDataL( const TDes8& aData,

   327     const TBool aSendImmediately,

   328     TInt& aFreeBufferSize,

   329     MSatSendDataObserver* aObserver )

   330     {

   331     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL calling" )

   332 

   333     TInt errCode( MSatBIPUtils::ESatBIPSuccess );

   334     CSatSActiveWrapper* delay = NULL;

   335     TInt numberOfTries( 1 );

   336     // Check status of connection

   337     TBool suspended( RPacketService::EStatusSuspended == 

   338         iUtils.ConnectionStatus() );

   339 

   340     // Check that does the data fit in buffer

   341     const TInt bufsize( iSendStore->Length() );

   342 

   343     LOG2( NORMAL,

   344         "SATENGINE: CSatBIPGPRSDataChannel::SendDataL iSendBuffer size: %i",

   345         bufsize )

   346     LOG2( NORMAL,

   347         "SATENGINE: CSatBIPGPRSDataChannel::SendDataL aData size: %i",

   348         aData.Length() )

   349     if ( suspended )

   350         {

   351         // for async wait

   352         delay = new ( ELeave ) CSatSActiveWrapper();

   353         }

   354     

   355     while ( suspended && KMaxAttempts >= numberOfTries ) 

   356         {

   357         // In cases of SMS or Call suspend the pdp context, we need to 

   358         // evaluate the status of context after a small delay

   359         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL, wait, %d "\

   360             , numberOfTries )

   361         delay->After( KReCheckStatusDelay );

   362         suspended = RPacketService::EStatusSuspended == iUtils.ConnectionStatus();

   363         numberOfTries++;

   364         }

   365     

   366     delete delay;

   367     delay = NULL;

   368             

   369     if ( suspended && aSendImmediately )

   370         {

   371         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL \

   372             Connection suspended" )

   373         errCode = MSatBIPUtils::ESatBIPServiceError;

   374         }

   375     else if ( iConnInfo.iBufferSize < ( aData.Length() + bufsize ) )

   376         {

   377         LOG( NORMAL,

   378             "SATENGINE: CSatBIPGPRSDataChannel::SendDataL Buffer overflow" )

   379         errCode = MSatBIPUtils::ESatBIPReqBufSizeNotAvail;

   380         }

   381     else

   382         {

   383 

   384         // Append data to send buffer

   385         TPtr8 ptr = iSendStore->Des();

   386         ptr.Append( aData );

   387 

   388         // Send immediately, if required

   389         if ( aSendImmediately )

   390             {

   391             LOG( NORMAL,

   392                 "SATENGINE: CSatBIPGPRSDataChannel::SendDataL Sending data" )

   393 

   394             // If Sender object is NULL, create it

   395             if ( !iSender && aObserver )

   396                 {

   397                 LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL \

   398                 create iSender" )

   399                 iSender = new ( ELeave ) CSatBIPDataSender(

   400                         *aObserver, iSocket, iUseTcpProtocol,

   401                         iConnInfo.iBufferSize );

   402                 }

   403 

   404             if ( iSender )

   405                 {

   406                 LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL \

   407                 iSender true" )

   408                 // Send data

   409                 iSender->SendData( ptr, iDestAddr );

   410 

   411                 // Remove data from buffer.

   412                 iSendStore = HBufC8::NewL( iConnInfo.iBufferSize );

   413                 }

   414             }

   415         }

   416 

   417     // Place the number of bytes of empty space in the buffer to aFreeBufferSize

   418     aFreeBufferSize = ( iConnInfo.iBufferSize - iSendStore->Length() );

   419 

   420     LOG2( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::SendDataL exiting, \

   421           errCode: %d", errCode )

   422     return errCode;

   423     }

   424 

   425 // ---------------------------------------------------------------------------

   426 // Returns the received data in param aData

   427 // ---------------------------------------------------------------------------

   428 //

   429 TInt CSatBIPGPRSDataChannel::ReceiveDataL( TDes8& aData,

   430     const TInt aBytesToRead, TInt& aAvailableBytes )

   431     {

   432     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ReceiveDataL calling" )

   433 

   434     TInt errCode( MSatBIPUtils::ESatBIPSuccess );

   435 

   436     // Number of bytes to return, may not be the same as requested

   437     TInt bytesToReturn( aBytesToRead );

   438 

   439     const TInt bytesAvail( iRcvBuffer.Length() );

   440 

   441     // Compare the number of bytes received and the number of bytes requested.

   442     if ( bytesToReturn > bytesAvail )

   443         {

   444         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ReceiveDataL \

   445         bytesToReturn > bytesAvail" )

   446         // There are no requested bytes availabe, we return all we have.

   447         errCode = MSatBIPUtils::ESatBIPReqBufSizeNotAvail;

   448         bytesToReturn = bytesAvail;

   449         }

   450 

   451     LOG2( NORMAL, "  ReceiveDataL: Data available for receive: %i", bytesAvail )

   452 

   453     // Put the data into param aData.

   454     aData = iRcvBuffer.Left( bytesToReturn );

   455     // Remove read data from receive store

   456     iRcvBuffer.Delete( 0, bytesToReturn );

   457     // Put the number of unread bytes into param aAvailableBytes.

   458     aAvailableBytes = iRcvBuffer.Length();

   459     

   460     LOG2( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ReceiveDataL \

   461           aAvailableBytes: %d", aAvailableBytes )

   462     // Notify receiver if store is empty to get the next datagram in UDP sockets

   463     if ( ( 0 == aAvailableBytes ) && iReceiver )

   464         {

   465         iReceiver->ReceiveStoreEmptyNotificationL();

   466         }

   467 

   468     LOG2( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ReceiveDataL exiting. \

   469           errCode: %d", errCode )

   470     return errCode;

   471     }

   472 

   473 // ---------------------------------------------------------------------------

   474 // Returns the identifier of this channel

   475 // ---------------------------------------------------------------------------

   476 //

   477 TInt CSatBIPGPRSDataChannel::ChannelId() const

   478     {

   479     LOG2( SIMPLE,

   480     "SATENGINE: CSatBIPGPRSDataChannel::ChannelId calling - exiting,\

   481     ChannelId: %i", iChannelId.ChannelId() )

   482     return iChannelId.ChannelId();

   483     }

   484 

   485 // ---------------------------------------------------------------------------

   486 // Returns the identifier of this channel. This function is used only when

   487 // generating ChannelStatus TLV object

   488 // ---------------------------------------------------------------------------

   489 //

   490 TUint8 CSatBIPGPRSDataChannel::ChannelStatusChannelId() const

   491     {

   492     LOG( SIMPLE,

   493         "SATENGINE: CSatBIPGPRSDataChannel::ChannelStatusChannelId calling" )

   494 

   495     TUint8 channelId( iChannelId.ShortChannelId() );

   496 

   497     LOG2( SIMPLE,

   498         "SATENGINE: CSatBIPGPRSDataChannel::ChannelStatusChannelId exiting \

   499         with channel id: %i", channelId )

   500     return channelId;

   501     }

   502 

   503 // ---------------------------------------------------------------------------

   504 // Returns the status of this data channel

   505 // ---------------------------------------------------------------------------

   506 //

   507 TInt CSatBIPGPRSDataChannel::Status() const

   508     {

   509     LOG2( SIMPLE, 

   510     "SATENGINE: CSatBIPGPRSDataChannel::Status calling - exiting,\

   511     iChannelStatus: %i", iChannelStatus )

   512     return iChannelStatus;

   513     }

   514 

   515 // ---------------------------------------------------------------------------

   516 // Closes this data channel

   517 // ---------------------------------------------------------------------------

   518 //

   519 void CSatBIPGPRSDataChannel::CloseChannel()

   520     {

   521     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CloseChannel calling" )

   522 

   523     if ( ESatBIPConnected == iConnStage ||

   524          ESatBIPCancelled == iConnStage )

   525         {

   526         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::CloseChannel \

   527             Channel is connected" )

   528         CancelAll();

   529         // Close socket

   530         iSocket.Close();

   531 

   532         iConnStage = ESatBIPClosed;

   533         }

   534     else if ( iConnStage == ESatBIPConnect &&

   535               iUseTcpProtocol )

   536         {

   537         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::CloseChannel \

   538             Channel is connecting" )

   539         // If Channel is connecting and protocol is TCP,

   540         // have to call Cancel instead of CancelAll since this is an active

   541         // object in this situation

   542         Cancel();

   543         // Close socket

   544         iSocket.Close();

   545         

   546         iConnStage = ESatBIPClosed;

   547         }

   548     else

   549         {

   550         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::CloseChannel \

   551             Channel already closed" )

   552         }

   553 

   554     // Release channel ID

   555     iChannelId.ReleaseChannel();

   556 

   557     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CloseChannel exiting" )

   558     }

   559 

   560 // ---------------------------------------------------------------------------

   561 // Performs cancel actions.

   562 // ---------------------------------------------------------------------------

   563 //

   564 void CSatBIPGPRSDataChannel::CancelAll()

   565     {

   566     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll calling" )

   567 

   568     // Cancel all activity in sockets

   569     if ( iConnStage == ESatBIPConnected )

   570         {

   571         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll \

   572         iConnStage == ESatBIPConnected" )

   573         // Cancel sender

   574         if ( iSender )

   575             {

   576             LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll \

   577             cancel iSender" )

   578             iSender->Cancel();

   579             }

   580 

   581         // Cancel receiver

   582         if ( iReceiver )

   583             {

   584             LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll \

   585             cancel iReceiver" )

   586             iReceiver->Cancel();

   587             }

   588 

   589         // Cancel all actions

   590         iSocket.CancelAll();

   591         // Link dropped, when socket cancels all

   592         iChannelStatus = MSatBIPUtils::ESatLinkDropped;

   593         iConnStage = ESatBIPCancelled;

   594         }

   595     else if ( iConnStage == ESatBIPConnect )

   596         {

   597         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll \

   598             Cancelling connect" )

   599         // Cancel connection negotiations

   600         iSocket.CancelConnect();

   601         iConnStage = ESatBIPCancelled;

   602         }

   603     else

   604         {

   605         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll \

   606             Channel already cancelled or closed" )

   607         }

   608 

   609     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::CancelAll exiting" )

   610     }

   611 

   612 // ---------------------------------------------------------------------------

   613 // Returns the status of this data channel

   614 // ---------------------------------------------------------------------------

   615 //

   616 TBool CSatBIPGPRSDataChannel::IsContextActive() const

   617     {

   618     LOG2( SIMPLE,

   619     "SATENGINE: CSatBIPGPRSDataChannel::IsContextActive calling - exiting,\

   620     return: %d", ESatBIPConnected == iConnStage )

   621     return ESatBIPConnected == iConnStage;

   622     }

   623 

   624 // ---------------------------------------------------------------------------

   625 // Returns the status of this data channel

   626 // ---------------------------------------------------------------------------

   627 //

   628 const MSatBIPDataChannel::TSatBipConnectionInfo& CSatBIPGPRSDataChannel::ConnInfo() const

   629     {

   630     LOG( SIMPLE,

   631         "SATENGINE: CSatBIPGPRSDataChannel::ConnInfo calling - exiting" )

   632     return iConnInfo;

   633     }

   634 

   635 // -----------------------------------------------------------------------------

   636 // CSatBIPGPRSDataChannel::StopUdpSocket

   637 // -----------------------------------------------------------------------------

   638 //

   639 void CSatBIPGPRSDataChannel::StopUdpSocket()

   640     {

   641     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::StopUdpSocket calling" )

   642     

   643     if ( !iUseTcpProtocol )

   644     {

   645     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::StopUdpSocket UDP" )

   646     iSocket.Close();

   647     }

   648         

   649     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::StopUdpSocket exiting" )

   650     }

   651 

   652 // ---------------------------------------------------------------------------

   653 // From CActive

   654 // ---------------------------------------------------------------------------

   655 //

   656 void CSatBIPGPRSDataChannel::RunL()

   657     {

   658     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL calling " )

   659 

   660     if ( KErrNone == iStatus.Int() )

   661         {

   662         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL \

   663         KErrNone == iStatus.Int() " )

   664         // Check connection stage

   665         switch ( iConnStage )

   666             {

   667             case ESatBIPConnect:

   668                 {

   669                 LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL \

   670                     Connect OK" )

   671                     

   672                 // Start receiving data

   673                 StartReceiveL();

   674                 iConnStage = ESatBIPConnected;

   675                 // Notify ConnectionObserver

   676                 iConnectionObserver->ConnectionNotification( KErrNone );

   677                 break;

   678                 }

   679 

   680             case ESatBIPCancelled:

   681                 {

   682                 LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL \

   683                     Connection Cancelled" )

   684                 // Notify ConnectionObserver

   685                 iConnectionObserver->ConnectionNotification( KErrCancel );

   686                 break;

   687                 }

   688 

   689             default:

   690                 {

   691                 LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL default" )

   692                 PanicSatEngine( ESatBIPAccessViolation );

   693                 }

   694             }

   695         }

   696     else

   697         {

   698         // Notify ConnectionObserver with error

   699         iConnectionObserver->ConnectionNotification( iStatus.Int() );

   700         }

   701 

   702     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunL exiting " )

   703     }

   704 

   705 // ---------------------------------------------------------------------------

   706 // DoCancel

   707 // ---------------------------------------------------------------------------

   708 //

   709 void CSatBIPGPRSDataChannel::DoCancel()

   710     {

   711     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::DoCancel calling" )

   712 

   713     CancelAll();

   714 

   715     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::DoCancel calling" )

   716     }

   717 

   718 // ---------------------------------------------------------------------------

   719 // RunError

   720 // ---------------------------------------------------------------------------

   721 //

   722 TInt CSatBIPGPRSDataChannel::RunError( TInt aError )

   723     {

   724     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunError calling" )

   725 

   726     if ( iConnectionObserver )

   727         {

   728         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunError \

   729         iConnectionObserver true" )

   730         iConnectionObserver->ConnectionNotification( aError );

   731         }

   732 

   733     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::RunError calling" )

   734     return KErrNone;

   735     }

   736 

   737 // ---------------------------------------------------------------------------

   738 // Stores received data into buffer.

   739 // ---------------------------------------------------------------------------

   740 //

   741 void CSatBIPGPRSDataChannel::DataReceivedNotificationL( const TDesC8& aData )

   742     {

   743     LOG( SIMPLE,

   744         "SATENGINE: CSatBIPGPRSDataChannel::DataReceivedNotification calling" )

   745 

   746     // Check do we have to report data receive

   747     const TInt bufsize( iRcvBuffer.Length() );

   748 #ifdef ENABLE_SAT_LOGGING

   749     TBuf<KIpAddressLogSize> addressForLog;

   750 #endif

   751     // LOG values

   752     LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::RunL\

   753         ReceiveStore length: %i", bufsize )

   754 

   755     // In UDP context, we can store only one datagram at a time. If there is

   756     // previous datagram in store, we'll have to wait for the UICC to get all

   757     // before storing the netx datagram and to start receive again. If there are

   758     // more than one datagrams pending, they are stored in RSockets queue.

   759     if ( bufsize == 0 || RSat::ETcp == iConnInfo.iProtocol.iTransportProto )

   760         {

   761 #ifdef ENABLE_SAT_LOGGING

   762         iSourceAddr.Output( addressForLog );

   763         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::RunL\

   764             Received data length: %i", aData.Length() )

   765         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::RunL\

   766             Received from address: %S", &addressForLog )

   767         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::RunL\

   768             Received from port: %i", iSourceAddr.Port() )

   769 #endif

   770         // Store data, if it fits into store, else, do not receive until store

   771         // is empty.

   772         if ( KSatBIPMinReceiveBufferSize >= ( aData.Length() + bufsize ) )

   773             {

   774             LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::\

   775                  DataReceivedNotification store data" )

   776             iRcvBuffer.Append( aData );

   777 

   778             // It is possible that aData is empty, because this function 

   779             // is called

   780             // every time when SIM gets the final bytes from ReceiveStore.

   781             if ( 0 == bufsize && aData.Length() > 0 )

   782                 {

   783                 LOG( SIMPLE,

   784                 "SATENGINE: CSatBIPGPRSDataChannel::DataReceivedNotification \

   785                 aData.Length() > 0" )

   786                 // If the store is empty, send event download

   787                 iUtils.DataAvailable( ChannelId(), aData.Length() );

   788                 }

   789 

   790             // Start to receive again. This should never leave, because Receiver

   791             // object is already created.

   792             StartReceiveL();

   793             }

   794         }

   795 

   796     LOG( SIMPLE,

   797         "SATENGINE: CSatBIPGPRSDataChannel::DataReceivedNotification exiting" )

   798     }

   799 

   800 // ---------------------------------------------------------------------------

   801 // Error while receiving data

   802 // ---------------------------------------------------------------------------

   803 //

   804 void CSatBIPGPRSDataChannel::DataReceiveError( TInt aError )

   805     {

   806     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::DataReceiveError calling" )

   807 

   808     if ( KErrCancel != aError ) // Don't do anything if cancelled

   809         {

   810         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::DataReceiveError\

   811              Error: %i", aError )

   812         // Report error

   813         iConnStage = ESatBIPCancelled; 

   814         iChannelStatus = MSatBIPUtils::ESatLinkDropped;

   815         iUtils.ChannelStatus( ChannelId(), iChannelStatus );

   816         }

   817     else

   818         {

   819         // Cancelled

   820         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::DataReceiveError\

   821             Receive has been cancelled cancelled" )

   822         }

   823 

   824     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::DataReceiveError exiting" )

   825     }

   826 

   827 // ---------------------------------------------------------------------------

   828 // C++ default constructor can NOT contain any code, that

   829 // might leave.

   830 // ---------------------------------------------------------------------------

   831 //

   832 CSatBIPGPRSDataChannel::CSatBIPGPRSDataChannel( CSatBIPUtils& aUtils,

   833     RSocketServ& aSocketServer,

   834     TSatChannelIdInfo& aChannelId,

   835     RConnection& aConnection,

   836     RSubConnection& aSubConnection) :

   837     CActive( EPriorityStandard ),

   838     iUtils( aUtils ),

   839     iSocketServ( aSocketServer ),

   840     iChannelId( aChannelId ),

   841     iConnection( aConnection ),

   842     iSubConnection( aSubConnection )

   843     {

   844     LOG( SIMPLE,

   845         "SATENGINE: CSatBIPGPRSDataChannel::CSatBIPGPRSDataChannel calling" )

   846 

   847     CActiveScheduler::Add( this );

   848 

   849     LOG( SIMPLE,

   850         "SATENGINE: CSatBIPGPRSDataChannel::CSatBIPGPRSDataChannel exiting" )

   851     }

   852 

   853 // ---------------------------------------------------------------------------

   854 // Symbian 2nd phase constructor can leave.

   855 // ---------------------------------------------------------------------------

   856 //

   857 void CSatBIPGPRSDataChannel::ConstructL()

   858     {

   859     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ConstructL calling" )

   860 

   861     iChannelStatus = MSatBIPUtils::ESatNoFurtherInformation;

   862     

   863     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::ConstructL exiting" )

   864     }

   865 

   866 // ---------------------------------------------------------------------------

   867 // Opens and connects / binds Socket

   868 // ---------------------------------------------------------------------------

   869 //

   870 void CSatBIPGPRSDataChannel::OpenSocketL()

   871     {

   872     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL calling" )

   873 

   874     TInt errCode( KErrNone );

   875 

   876     // Define Destination address

   877     // Create InetAddress to hold remote device information

   878     LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   879          Port from SIM: %d", iConnInfo.iProtocol.iPrtNumber )

   880 

   881     // Remote server's IP Address

   882 #ifdef SAT_USE_DUMMY_TSY

   883     TBuf8<RSat::KPcktAddressMaxSize> destAddr( RSat::KPcktAddressMaxSize );

   884     

   885     // KAfInet or KAfInet6

   886     if ( RSat::EIPv6Address == iConnInfo.iDestination.iType )

   887         {

   888         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL IPv6" )

   889         // 0:0:0:0:0:0:0:2 is equivalent to 127, 0, 0, 2

   890         for ( TInt ndx = 0 ; ndx < KIpAddressSize ; ndx++ )

   891             {

   892             destAddr[ndx] = 0;

   893             }

   894         destAddr[KIpAddressSize] = KIpAddressDValueDestination;

   895         destAddr.SetLength( KIpv6Length );

   896         }

   897     else //ipv4

   898         {

   899         LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL IPv4" )

   900         destAddr[KIpAddressA] = KIpAddressAValue;

   901         destAddr[KIpAddressB] = KIpAddressBValue;

   902         destAddr[KIpAddressC] = KIpAddressCValue;

   903         destAddr[KIpAddressD] = KIpAddressDValueDestination;

   904         destAddr.SetLength( KIpv4Length );

   905         }

   906     iDestAddr = DestAddress( destAddr );

   907 #else

   908     iDestAddr = DestAddress( iConnInfo.iDestination.iAddress );

   909 #endif // SAT_USE_DUMMY_TSY

   910     

   911     LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   912          Complete defining destination address" )

   913     

   914     iSourceAddr = iDestAddr;

   915     

   916     TUint socketType( KSockStream );

   917     TUint protocol( KProtocolInetTcp );

   918     

   919     // Check is it UDP or TCP

   920     if ( !iUseTcpProtocol )

   921         {

   922         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   923             Opening UDP datagram socket" )

   924         socketType = KSockDatagram;

   925         protocol = KProtocolInetUdp;

   926         }

   927     else

   928         {

   929         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   930             Opening TCP stream socket" )

   931         }

   932         

   933     // Open socket

   934     if ( iUtils.IsSubConnectionActivated() )

   935         {

   936         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   937         using subconnection" )

   938         errCode = iSocket.Open( iSocketServ, KAfInet, socketType,

   939             protocol, iSubConnection );

   940         }

   941     else

   942         {

   943         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   944         using connection" )

   945         errCode = iSocket.Open( iSocketServ, KAfInet, socketType,

   946             protocol, iConnection );

   947         }

   948         

   949     // Check socket activation

   950     LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   951         Socket opened with code: %i", errCode )

   952     User::LeaveIfError( errCode );

   953     

   954     // Define local address. Local port is obtained automatically

   955     TInetAddr localAddress( KInetPortAny );

   956     

   957 #ifdef SAT_USE_DUMMY_TSY

   958         // win2000 doesn't support IPv6, so force to IPv4

   959         localAddress.SetFamily( KAfInet );

   960         // KAfInet or KAfInet6

   961         if ( RSat::EIPv6Address == iConnInfo.iDestination.iType )

   962             {

   963             LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   964                 IPv6" )

   965             // 0:0:0:0:0:0:0:3 is equivalent to 127, 0, 0, 3

   966             TIp6Addr ip6Adrr;

   967             

   968             for ( TInt index = 0 ; index < KIpAddressSize ; index++ )

   969                 {

   970                 ip6Adrr.u.iAddr8[index] = 0;

   971                 }

   972                 

   973             ip6Adrr.u.iAddr8[KIpAddressSize] = KIpAddressDValueLocal;

   974             localAddress.SetAddress( ip6Adrr );

   975             }

   976         else //ipv4

   977             {

   978             LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   979                 IPv4" )

   980             localAddress.SetAddress( INET_ADDR(

   981                 KIpAddressAValue,

   982                 KIpAddressBValue,

   983                 KIpAddressCValue,

   984                 KIpAddressDValueLocal ) );

   985             }

   986 #else

   987     // Check does the SIM provide a local address

   988     if ( 0 < iConnInfo.iSource.iAddress.Length() )

   989         {

   990         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   991             Setting pre-defined local address" )

   992         localAddress = DestAddress( iConnInfo.iSource.iAddress );

   993         localAddress.SetPort( KInetPortAny );

   994         }

   995     else

   996         {

   997         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

   998             Setting automatic local address" )

   999         // Unspecified. Local address is obtained automatically.

  1000         localAddress.SetFamily( KAFUnspec );

  1001         }

  1002 #endif       

  1003     LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

  1004         Bind local address" )

  1005     errCode = iSocket.Bind( localAddress );  

  1006         

  1007     // Check what was the response from "Bind"

  1008     if ( KErrNone == errCode )

  1009         {

  1010         // Set status to indicate that connection attempt ongoing

  1011         iConnStage = ESatBIPConnect;

  1012         

  1013         if ( iUseTcpProtocol )

  1014             {

  1015             // Connect the socket

  1016             iSocket.Connect( iDestAddr, iStatus );

  1017             SetActive();

  1018             }

  1019         else

  1020             {

  1021             // This option redefines the receive buffer size

  1022             iSocket.SetOpt( KSoUdpRecvBuf, KSolInetUdp, 

  1023                 KSatBIPMinReceiveBufferSize );

  1024             // Connect the socket

  1025             iSocket.Connect( iDestAddr, iStatus );

  1026             // UDP sockets dont need active object

  1027             User::WaitForRequest( iStatus );

  1028             LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

  1029                 UDP Socket connect status  %i", iStatus.Int() )

  1030             }

  1031         }

  1032     else

  1033         {

  1034         // Send Terminal Response indicating that static address allocation

  1035         // could not be done (KErrNotFound) or Bind failed for some other 

  1036         // reason

  1037         LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL\

  1038             Bind error:  %i", errCode )

  1039         iConnectionObserver->ConnectionNotification( errCode );

  1040         }

  1041 

  1042     LOG( SIMPLE, "SATENGINE: CSatBIPGPRSDataChannel::OpenSocketL exiting" )

  1043     }

  1044 

  1045 // ---------------------------------------------------------------------------

  1046 // Opens SubConnection and attaches socket into it

  1047 // ---------------------------------------------------------------------------

  1048 //

  1049 void CSatBIPGPRSDataChannel::OpenSubConnection()

  1050     {

  1051     LOG( SIMPLE,

  1052         "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection calling" )

  1053     

  1054     TInt errCode( KErrNone );

  1055     

  1056     // Create SubConnection. This is mandatory for multiple PDP Context support

  1057     LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection\

  1058         Opening Sub-connection" )

  1059     

  1060     errCode = iSubConnection.Open( iSocketServ, RSubConnection::ECreateNew, 

  1061                                    iConnection );

  1062     

  1063     LOG2( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection\

  1064         RSubConnection opened with code: %i", errCode )

  1065     

  1066     if ( KErrNone != errCode )

  1067         {

  1068         // No subconnections, Affects on sockets

  1069         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection\

  1070                 RSubConnection is opened incorrectly" )

  1071         iSubConnection.Close();

  1072         iUtils.SetSubConnectionActivated( EFalse );

  1073         }

  1074     else 

  1075         {

  1076         LOG( NORMAL, "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection\

  1077                 RSubConnection is opened correctly" )

  1078         iUtils.SetSubConnectionActivated( ETrue );

  1079         }

  1080         

  1081     LOG( SIMPLE,

  1082         "SATENGINE: CSatBIPGPRSDataChannel::OpenSubConnection exiting" )

  1083     }

  1084 

  1085 // ---------------------------------------------------------------------------

  1086 // Sets QoS parameters to active SubConnection

  1087 // ---------------------------------------------------------------------------

  1088 //

  1089 void CSatBIPGPRSDataChannel::SetSubConQoSParamsL()

  1090     {

  1091     LOG( SIMPLE,

  1092         "SATENGINE: CSatBIPGPRSDataChannel::SetSubConQoSParamsL calling" )

  1093     

  1094     const TInt paramLength( iConnInfo.iBearerParams.Length() );

  1095     TInt errCode( KErrNone );

  1096 

  1097     LOG2( NORMAL, "  QoS Parameters length: %i", paramLength )

  1098 

  1099     // GPRS requires 6 parameters from SIM

  1100     if ( KReqGprsQoSParams == paramLength )

  1101         {

  1102         // Check that is packet protocol valid, ie. IP protocol

  1103         if ( KReqPacketProtType != iConnInfo.iBearerParams[KProtocolPos] )

  1104             {

  1105             LOG( NORMAL, 

  1106                 "SATENGINE: CSatBIPGPRSDataChannel::SetSubConQoSParamsL\

  1107                 Requested packet protocol is not valid" )

  1108             User::Leave( KErrNotSupported );

  1109             }

  1110         }

  1111     else

  1112         {

  1113         LOG( NORMAL, 

  1114             "SATENGINE: CSatBIPGPRSDataChannel::SetSubConQoSParamsL\

  1115             Requested packet protocol is valid, not support" )

  1116         User::Leave( KErrNotSupported );

  1117         }

  1118 

  1119     // Creating and setting properties for a sub-connection

  1120     // Create a parameter bundle and add to the cleanup stack

  1121     RSubConParameterBundle parameterBundle;

  1122     CleanupClosePushL( parameterBundle );

  1123         

  1124     // Create a family owned by parameterBundle

  1125     CSubConParameterFamily* parameterFamily = 

  1126         CSubConParameterFamily::NewL( parameterBundle, KSubConQoSFamily );

  1127     

  1128     // Create extension paramset(Rel5) owned by parameterFamily

  1129     CSubConQosR5ParamSet* requestedQoSRel5 = 

  1130         CSubConQosR5ParamSet::NewL( *parameterFamily, 

  1131                                     CSubConParameterFamily::ERequested );

  1132     

  1133     if( requestedQoSRel5 )

  1134         {