CodeForge.com

rxtx.cpp in Code_Examples.zip

			
// RXTX.CPP
//
// Copyright (c) 2003-2004 Ian McDowall & Symbian Ltd.  All rights reserved.
//

#include "rxtx.h"
#include "log.h"

// Receiver AO implementation (class CRx)
CRx::CRx(RSocket* aSocket, CTx* aTx) :
  CActive(CActive::EPriorityStandard),iRecvLen(MAX_MSG_LEN), iSocket(aSocket), iTx(aTx)
  {
  }

CRx* CRx::NewL(RSocket* aSocket, CTx* aTx)
  {
  CRx* self = new (ELeave) CRx(aSocket, aTx);
  CleanupStack::PushL(self);
  self->ConstructL();
  CleanupStack::Pop();
  CActiveScheduler::Add(self);
  return self;
  }

CRx::~CRx()
  {
  Cancel(); // cancel ANY outstanding request at time of destruction
  }

void CRx::RxL()
  {
__LOG("CRx::RxL");
  // Issue read request
  iSocket->RecvOneOrMore(iDataBuffer, 0, iStatus, iRecvLen);
  SetActive();
  }

void CRx::ConstructL (void)
  {
  }

void CRx::RunL(void)
  {
  if (iStatus==KErrNone) // received some data, echo it
    {
__LOG("CRx::RunL OK");
	  iTx->TxL(iDataBuffer);
    }
  else
    {
    // some error condition
__LOG1("CRx::RunL error %d", iStatus);
	  CActiveScheduler::Stop();
    }
  }

void CRx::DoCancel (void)
  {
  // Cancel any outstanding read request
  iSocket->Canc			

			...
			...
			... to be continued.

  This is a preview. To get the complete source file, 
  please click here to download the whole source code package.