1 // Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

     2 // All rights reserved.

     3 // This component and the accompanying materials are made available

     4 // under the terms of "Eclipse Public License v1.0"

     5 // which accompanies this distribution, and is available

     6 // at the URL "http://www.eclipse.org/legal/epl-v10.html".

     7 //

     8 // Initial Contributors:

     9 // Nokia Corporation - initial contribution.

    10 //

    11 // Contributors:

    12 //

    13 // Description:

    14 // secpolreader.cpp - IPSec event message reader

    15 //

    16 

    17 #include <es_sock.h>

    18 #include <in_sock.h>

    19 

    20 #include "secpolreader.h"

    21 #include "ipsecpolmanhandler.h"

    22 

    23 //

    24 // CSecpolReader::CSecpolReader

    25 //

    26 CSecpolReader::CSecpolReader(CIPSecPolicyManagerHandler *control)

    27 : CActive(1), iControl(control)

    28     {

    29     CActiveScheduler::Add(this);

    30     }

    31 

    32 //

    33 // CSecpolReader::~CSecpolReader

    34 //

    35 CSecpolReader::~CSecpolReader()

    36     {

    37     if (IsActive())

    38         Cancel();

    39     iSocket.Close();

    40     }

    41 

    42 //

    43 // CSecpolReader::Construct()

    44 //  Open and activate the socket input

    45 //

    46 TInt CSecpolReader::Construct(const TDesC &aSocket)

    47     {

    48     TInt err;

    49     TInetAddr addr;

    50     

    51     err = iSocket.Open(iControl->iSS,aSocket);

    52     if( err != KErrNone )

    53 	return err;

    54     addr.SetAddress(KInetAddrNone);

    55     addr.SetPort(0);

    56     err = iSocket.Bind(addr);

    57     if( err != KErrNone )

    58 	return err;

    59     iSocket.LocalName(addr);

    60     iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);

    61     SetActive();

    62     return err;

    63     }

    64 

    65 //

    66 // CSecpolReader::RunL

    67 //  Called when request completed

    68 //

    69 void CSecpolReader::RunL()

    70     {

    71     //    DEB(TBuf<1000> str;)

    72     //    DEB(TBuf<40> buf;)

    73     //  TPayload packet(iMsg.Ptr());

    74     iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);  // start a new read

    75     SetActive();

    76     }

    77 

    78 //

    79 // CSecpolReader::DoCancel

    80 //  Called when a pending request should be cancelled

    81 //

    82 void CSecpolReader::DoCancel()

    83     {

    84     iSocket.CancelRecv();

    85     }

    86 

    87 //

    88 // CSecpolReader::RunError

    89 // Called when RunL() leaves 

    90 //

    91 TInt CSecpolReader::RunError(TInt /*aError*/)

    92     {

    93     iSocket.RecvFrom(iMsg, iAddr, 0, iStatus);  // start a new read 

    94     SetActive();

    95     

    96     return KErrNone; // Active scheduler Error() method NOT called              

    97     }