/*
* Copyright (c) 2006-2007 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:    Abstract socket receiver
*
*/




#include "cncmreceiver.h"
#include "mncmreceiversenderobserver.h"
#include "ncmconnectionmultiplexerlogs.h"


// ---------------------------------------------------------------------------
// CNcmReceiver::CNcmReceiver
// ---------------------------------------------------------------------------
//
CNcmReceiver::CNcmReceiver( RSocket& aSocket,
    MNcmReceiverSenderObserver& aObserver ) :
    CActive( EPriorityStandard ), iSocket( aSocket ), iObserver( aObserver ),
    iFromAddr( KInetAddrNone, 0 )
    {
    CActiveScheduler::Add( this );
    }


// ---------------------------------------------------------------------------
// CNcmReceiver::~CNcmReceiver
// ---------------------------------------------------------------------------
//
CNcmReceiver::~CNcmReceiver()
    {
    __CONNECTIONMULTIPLEXER( "CNcmReceiver::~CNcmReceiver" )

    Cancel();
    }


// ---------------------------------------------------------------------------
// CNcmReceiver::Message
// ---------------------------------------------------------------------------
//
TDesC8& CNcmReceiver::Message()
    {
    return iBuffer;
    }


// ---------------------------------------------------------------------------
// CNcmReceiver::FromAddress
// ---------------------------------------------------------------------------
//
const TInetAddr& CNcmReceiver::FromAddress() const
    {
    return iFromAddr;
    }
 
  
// ---------------------------------------------------------------------------
// From class CActive
//
// CNcmReceiver::RunL
// ---------------------------------------------------------------------------
//
void CNcmReceiver::RunL()
    {
    __CONNECTIONMULTIPLEXER_INT1( "CNcmReceiver::RunL", iStatus.Int() )
    
    switch( iStatus.Int() )
        {
        case KErrNone:
            iObserver.MessageAvailable();
            DoReceive();
            break;
        case KErrEof:
            // Connection closed, nothing to do
            iObserver.Error( KErrDisconnected );
            break;
        default:
            iObserver.Error( iStatus.Int() );
        }
    }


// ---------------------------------------------------------------------------
// From class CActive
//
// CNcmReceiver::RunL
// ---------------------------------------------------------------------------
//
void CNcmReceiver::DoCancel()
    {
    __CONNECTIONMULTIPLEXER( "CNcmReceiver::DoCancel" )
        
    iSocket.CancelRecv();
    }


// ---------------------------------------------------------------------------
// CNcmReceiver::Activate
// ---------------------------------------------------------------------------
//
void CNcmReceiver::Activate()
    {
    DoReceive();
    }


// ---------------------------------------------------------------------------
// CNcmReceiver::Deactivate
// ---------------------------------------------------------------------------
//
void CNcmReceiver::Deactivate()
    {
    Cancel();
    }