www.pudn.com > Bluetooth_PMP_Example_v1_0.zip > Connector.cpp

/* 
* ============================================================================ 
*  Name     : CConnector from Connector.h 
*  Part of  : BluetoothPMPExample 
*  Created  : 14.01.2004 by Forum Nokia 
*  Implementation notes: 
*     Initial content was generated by Series 60 AppWizard. 
*  Version  : 
*  Copyright: Nokia Corporation 
* ============================================================================ 
*/ 
 
// INCLUDE FILES 
#include "Connector.h" 
 
 
CConnector* CConnector::NewL(MConnectorObserver *aObserver,  
							 RSocketServ *aSocketServ) 
	{ 
	CConnector* self = CConnector::NewLC(aObserver, aSocketServ); 
    CleanupStack::Pop(self); 
	return self; 
	} 
 
 
CConnector* CConnector::NewLC(MConnectorObserver *aObserver,  
							  RSocketServ *aSocketServ) 
	{ 
	CConnector* self = new (ELeave) CConnector(aObserver, aSocketServ); 
	CleanupStack::PushL(self); 
	self->ConstructL(); 
	return self; 
	} 
 
 
void CConnector::ConstructL() 
	{ 
	} 
 
 
CConnector::CConnector(MConnectorObserver *aObserver,  
					   RSocketServ *aSocketServ): 
	CActive(CActive::EPriorityStandard), 
	iObserver(aObserver), 
	iSocketServ(aSocketServ), 
	iState(ENone) 
	{ 
	CActiveScheduler::Add(this); 
	} 
 
 
CConnector::~CConnector() 
	{ 
	Cancel(); 
	// disconnect and kill socket 
	DisconnectL(); 
	} 
 
 
void CConnector::DoCancel() 
	{ 
	iSock.CancelAll(); 
	} 
 
 
// ---------------------------------------------------------------------------- 
// CConnector::ConnectL(THostName aName, TBTDevAddr aAddr, TInt aPort) 
// 
// create a connection to given address on given port.   
// ---------------------------------------------------------------------------- 
TRequestStatus CConnector::ConnectL(THostName aName, TBTDevAddr aAddr,  
									TInt aPort) 
	{ 
	iName=aName; 
	iAddr=aAddr; 
	iPort=aPort; 
 
	// load protocol, RFCOMM 
	TProtocolDesc pdesc; 
	User::LeaveIfError(iSocketServ->FindProtocol(_L("RFCOMM"), pdesc)); 
 
	// open socket 
	User::LeaveIfError(iSock.Open(*iSocketServ, _L("RFCOMM"))); 
	// set address and port 
	TBTSockAddr addr; 
	addr.SetBTAddr(iAddr); 
	addr.SetPort(iPort); 
	// connect socket 
	TRequestStatus status; 
	iSock.Connect(addr, status); 
	User::WaitForRequest(status); 
	if ( status!=KErrNone ) 
		{ 
		// error opening conn 
		return status; 
		} 
	iState=EConnecting; 
	WaitAndReceiveL(); 
	return status; 
	} 
 
 
// ---------------------------------------------------------------------------- 
// CConnector::DisconnectL() 
// 
// disconnect from remote device, shutdown connected socket 
// ---------------------------------------------------------------------------- 
void CConnector::DisconnectL() 
	{ 
	TRequestStatus status; 
	// shutdown socket 
	iSock.Shutdown(RSocket::ENormal, status); 
	User::WaitForRequest(status); 
	iSock.Close(); 
	} 
 
 
// ---------------------------------------------------------------------------- 
// CConnector::SendDataL(const TDesC8& aData) 
// 
// send given data to remote device, write to connected socket 
// ---------------------------------------------------------------------------- 
void CConnector::SendDataL(const TDesC8& aData) 
	{ 
	// cancel any read requests on socket 
	iSock.CancelRead(); 
	Cancel(); 
	// send message 
	iState=ESending; 
	iSock.Write(aData, iStatus); 
	SetActive(); 
	} 
 
 
// ---------------------------------------------------------------------------- 
// CConnector::WaitAndReceiveL() 
// 
// wait for and receive data from remote device, read connected socket 
// ---------------------------------------------------------------------------- 
void CConnector::WaitAndReceiveL() 
    { 
	// cancel pending operations 
	iSock.CancelRead(); 
	Cancel(); 
	// receive data from socket 
	iState=EWaiting; 
    iSock.RecvOneOrMore(iBuffer, 0, iStatus, iLen); 
    SetActive(); 
    } 
 
 
void CConnector::RunL() 
	{ 
	if ( iStatus!=KErrNone ) 
		return; 
 
	switch (iState) 
		{ 
		case EConnecting: 
			{ 
			// wait incoming data on socket 
			WaitAndReceiveL(); 
			break; 
			} 
		case EWaiting: 
			{ 
			// we got incoming data! 
            HBufC* text = HBufC::NewLC(iBuffer.Length()); 
            text->Des().Copy(iBuffer); 
			// observer will handle data 
			HandleConnectorDataReceivedL(iName, *text); 
            CleanupStack::PopAndDestroy(text); 
 
			// start expecting new incoming data 
            WaitAndReceiveL();  
			break; 
			} 
		case ESending: 
			{ 
			// tried send a message 
			if(iState!=KErrNone) 
				{ 
					// Add error handling / socket re-read code 
					// here, not implemented in this example 
				} 
 
			// start expecting new incoming data 
			WaitAndReceiveL(); 
			break; 
			} 
		default: 
			break; 
		} 
	} 
 
 
// ---------------------------------------------------------------------------- 
// CConnector::HandleConnectorDataReceivedL(THostNama aName, TDesC& aData) 
// 
// a callback to observer indicating that connector has received data 
// ---------------------------------------------------------------------------- 
void CConnector::HandleConnectorDataReceivedL(THostName aName, TDesC& aData) 
{ 
	iObserver->HandleConnectorDataReceivedL(aName, aData); 
}