S60 3rd Edition SDK for Symbian OS Example Applications Guide

SIPExSocketReader.cpp

/*
* ==============================================================================
*  Name        : SIPExSocketReader.cpp
*  Part of     : SIPExSocketEngine
*  Interface   : 
*  Description : 
*  Version     : 
*
*  Copyright (c) 2004-2006 Nokia Corporation.
*  This material, including documentation and any related 
*  computer programs, is protected by copyright controlled by 
*  Nokia Corporation.
* ==============================================================================
*/

#include    "SIPExSocketReader.h"
#include    "SIPExReaderNotifier.h"
#include    <in_sock.h>
#include    <e32svr.h>

// -----------------------------------------------------------------------------
// CSIPExSocketReader::NewL
// Static constructor
// -----------------------------------------------------------------------------
//
CSIPExSocketReader* CSIPExSocketReader::NewL( 
    RSocket& aSocket, 
    MSIPExReaderNotifier& aNotifier )
    {
    CSIPExSocketReader* self = NewLC( aSocket, aNotifier );
    CleanupStack::Pop(self);
    return self;
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::NewLC
// Static constructor
// -----------------------------------------------------------------------------
//    
CSIPExSocketReader* CSIPExSocketReader::NewLC( 
    RSocket& aSocket, 
    MSIPExReaderNotifier& aNotifier )
    {
    CSIPExSocketReader* self = new (ELeave) CSIPExSocketReader( aSocket, aNotifier );
    CleanupStack::PushL(self);
    self->ConstructL();
    return self;
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::CSIPExSocketReader
// Constructor
// -----------------------------------------------------------------------------
//
CSIPExSocketReader::CSIPExSocketReader( 
    RSocket& aSocket, 
    MSIPExReaderNotifier& aNotifier )
    : CActive(CActive::EPriorityStandard), 
      iNotifier( aNotifier ), 
      iSocket( aSocket )
    {
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::~CSIPExSocketReader
// Destructor
// -----------------------------------------------------------------------------
//
CSIPExSocketReader::~CSIPExSocketReader()
    {
    Cancel();
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::ConstructL
// 2nd phase constructor
// -----------------------------------------------------------------------------
//
void CSIPExSocketReader::ConstructL()
    {
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::DoCancel
// Cancels outstanding request.
// -----------------------------------------------------------------------------
//
void CSIPExSocketReader::DoCancel()
    {
    iSocket.CancelRead();
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::RunL
// Buffers the characters read from socket and notifies the observer when buffer
// if full. If error notifies the observer.
// -----------------------------------------------------------------------------
//
void CSIPExSocketReader::RunL()
    {
    if( iStatus.Int() == KErrNone )
        {
        iMessage.Append( iBuffer );
        iBuffer.Zero();
        if( iMessage.Length() == 4 )
            {
            iNotifier.MessageReceived( iMessage );
            iMessage.Zero();
            }
        Read();
        }
    else
        {
        iMessage.FillZ();
        iMessage.Zero();
        iNotifier.ErrorInReading( iStatus.Int() );
        }
    }

// -----------------------------------------------------------------------------
// CSIPExSocketReader::Read
// Asynchronous
// Starts the asynchoronous reading if not already active.
// -----------------------------------------------------------------------------
//
void CSIPExSocketReader::Read()
    {
    if( !IsActive() )
        {
        iSocket.Read( iBuffer, iStatus );
        SetActive();
        }
    }

// End of file

---

© Nokia 2006