socketreader.cpp

基于SIP协议的即时消息聊天功能设计,Symbian平台下实现

/*
* ==============================================================================
*  Name        : SocketReader.cpp
*  Part of     : SocketEngine
*  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    "SocketReader.h"
#include    "ReaderNotifier.h"
#include    <e32svr.h>

// -----------------------------------------------------------------------------
// CSocketReader::NewL
// Static constructor
// -----------------------------------------------------------------------------
//
CSocketReader* CSocketReader::NewL( 
    RSocket& aSocket, 
    MReaderNotifier& aNotifier,
	TProtocolType aProtocolType)
    {
    CSocketReader* self = NewLC( aSocket, aNotifier, aProtocolType);
    CleanupStack::Pop(self);
    return self;
    }

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

// -----------------------------------------------------------------------------
// CSocketReader::CSocketReader
// Constructor
// -----------------------------------------------------------------------------
//
CSocketReader::CSocketReader( 
    RSocket& aSocket, 
    MReaderNotifier& aNotifier,
	TProtocolType aProtocolType)
    : CActive(CActive::EPriorityStandard), 
      iNotifier( aNotifier ), 
      iSocket( aSocket ),
	  iProtocolType(aProtocolType)
    {
    CActiveScheduler::Add(this);
    }

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

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

// -----------------------------------------------------------------------------
// CSocketReader::DoCancel
// Cancels outstanding request.
// -----------------------------------------------------------------------------
//
void CSocketReader::DoCancel()
    {
    iSocket.CancelRecv();
    }

// -----------------------------------------------------------------------------
// CSocketReader::RunL
// Buffers the characters read from socket and notifies the observer when buffer
// if full. If error notifies the observer.
// -----------------------------------------------------------------------------
//
void CSocketReader::RunL()
    {
		if(iBuffer.Length()>0)
		{
			iNotifier.MessageReceived(iBuffer);
			iBuffer.Zero();
			Read();
		}
    }


// -----------------------------------------------------------------------------
// CSocketReader::Read
// Asynchronous
// Starts the asynchoronous reading if not already active.
// -----------------------------------------------------------------------------
//
void CSocketReader::Read()
    {
    if( !IsActive() )
        {
			if(iProtocolType == EUDP)   //UDP mode
			{
				static TInetAddr addr;
				iSocket.RecvFrom(iBuffer, addr, 0, iStatus);
				SetActive();
			}
			else     // TCP mode
			{	
				iSocket.RecvOneOrMore(iBuffer, 0, iStatus, iLength);
				SetActive();
			}
        }
    }


// End of file