--- a/obex/obexprotocol/obex/test/tobex/serverhandlerbase.cpp	Tue Sep 28 20:14:08 2010 +0800
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,1007 +0,0 @@
-// Copyright (c) 2005-2009 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:
-//
-
-#include <es_sock.h>
-#include <ir_sock.h>
-#include <bautils.h>
-#include <usbman.h>
-#include <d32usbc.h>
-#include "serverhandlerbase.h" 
-#include "TOBEXCON.H"
-#include "btextnotifiers.h"
-#include "serverasyncao.h"
-#include <obexconstants.h>
-#include <obexbttransportinfo.h>
-#include <obexirtransportinfo.h>
-#include "obexconstantsinternal.h"
-
-#include "serverpacketaccessui.h"
-
-CObexServerHandlerBase::CObexServerHandlerBase(CActiveConsole* aParent)
-	: iAcceptPuts(ETrue), iParent(aParent)
-    {
-    }
-
-
-void CObexServerHandlerBase::BaseConstructL(TTransport aTransport)
-    {
-
-	iTransportLayer = aTransport;
-	switch (aTransport)
-		{
-		case (EBluetooth):
-			InitBluetoothL();
-			break;
-		
-		case (EIrda):
-			{
-			if(iParent->UseIrdaNickname())
-				{
-				TObexIrV3TransportInfo aInfo;
-				aInfo.iTransportName = KObexIrTTPProtocolV3;
-				aInfo.iReceiveMtu = iParent->iRecvMTU;
-				aInfo.iTransmitMtu = iParent->iTransmitMTU;
-				aInfo.iAddr.SetPort(KAutoBindLSAP);//default obex server for now
-				_LIT8(KClassName, "OBEX");
-				_LIT8(KAttributeName, "IrDA:TinyTP:LsapSel");
-				aInfo.iClassName     = KClassName;
-				aInfo.iAttributeName = KAttributeName;
-				aInfo.iDiscoverySlots = iParent->iDiscoverySlots;
-				aInfo.iDiscoveryAttempts = iParent->iDiscoveryAttempts;
-				aInfo.iLocalDeviceNickname = iParent->GetIrdaNickname();
-				aInfo.iLocalDeviceNicknameValid = ETrue;
-				iServer = CObexServer::NewL(aInfo);
-				}
-			else
-				{
-				TObexIrV2TransportInfo aInfo;
-				aInfo.iTransportName = KObexIrTTPProtocolV2;
-				aInfo.iReceiveMtu = iParent->iRecvMTU;
-				aInfo.iTransmitMtu = iParent->iTransmitMTU;
-				aInfo.iAddr.SetPort(KAutoBindLSAP);//default obex server for now
-				_LIT8(KClassName, "OBEX");
-				_LIT8(KAttributeName, "IrDA:TinyTP:LsapSel");
-				aInfo.iClassName     = KClassName;
-				aInfo.iAttributeName = KAttributeName;
-				aInfo.iDiscoverySlots = iParent->iDiscoverySlots;
-				aInfo.iDiscoveryAttempts = iParent->iDiscoveryAttempts;
-				iServer = CObexServer::NewL(aInfo);
-				}
-			User::LeaveIfError(iServer->Start(this));
-			
-/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 
-			// API with TTP transport.
-			// We get back an TObexIrTransportInfo because we asked for KObexIrTTPProtocol.
-			const TObexIrTransportInfo* transportInfo = static_cast<const TObexIrTransportInfo*>(iServer->TransportInfo());
-			iParent->Console()->Printf(_L("Transport info: \r\n"));
-			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);
-			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);
-			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);
-			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);
-			iParent->Console()->Printf(_L("\tTinyTP port: 0x%02x\r\n"), transportInfo->iAddr.Port());
-			TName wide;
-			wide.Copy(transportInfo->iClassName);
-			iParent->Console()->Printf(_L("\tclass name: %S\r\n"), &wide);
-			wide.Copy(transportInfo->iAttributeName);
-			iParent->Console()->Printf(_L("\tattribute name: %S\r\n"), &wide);
-*/
-			break;
-			}
-		
-		case (EUsb):
-			{
-			TObexUsbProtocolInfo info;
-			info.iTransport = KObexUsbProtocol;
-			info.iInterfaceStringDescriptor = _L("TOBEX Server Interface");
-
-			iServer = CObexServer::NewL (info);
-			User::LeaveIfError(iServer->Start (this));
-			
-/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 
-			// API with USB transport.
-			// We get back an TObexUsbTransportInfo because we asked for KObexUsbProtocol.
-			const TObexUsbTransportInfo* transportInfo = static_cast<const TObexUsbTransportInfo*>(iServer->TransportInfo());
-			iParent->Console()->Printf(_L("Transport info: \r\n"));
-			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);
-			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);
-			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);
-			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);
-			iParent->Console()->Printf(_L("\tinterface string desc: %S\r\n"), &transportInfo->iInterfaceStringDescriptor);
-*/
-			break;
-			}
-		
-		case (EWin32Usb):
-			{
-			TObexUsbProtocolInfo aInfo;
-			aInfo.iTransport = _L("Win32Usb");
-	        aInfo.iInterfaceStringDescriptor = _L("TOBEX Server Interface");
-	        
-			iServer = CObexServer::NewL (aInfo);
-			User::LeaveIfError(iServer->Start (this));
-			
-/*			// Uncomment this code to demonstrate CObexServer::TransportInfo 
-			// API with Win32USB transport.
-			// We get back an TObexUsbTransportInfo because we asked for KObexUsbProtocol.
-			const TObexUsbTransportInfo* transportInfo = static_cast<const TObexUsbTransportInfo*>(iServer->TransportInfo());
-			iParent->Console()->Printf(_L("Transport info: \r\n"));
-			iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);
-			iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);
-			iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);
-			iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);
-			iParent->Console()->Printf(_L("\tinterface string desc: %S\r\n"), &transportInfo->iInterfaceStringDescriptor);
-*/
-			break;
-			}
-		}
-	
-#ifdef ASYNC_INDICATION
-    iServerAsyncAO = CServerAsyncAO::NewL(*iServer);
-#endif
-	}
-
-void CObexServerHandlerBase::InitBluetoothL()
-	{
-	TBTServiceSecurity serv;
-	serv.SetUid(KObexTestUid);
-	
-	// UPF - change security here for Bluetooth security testing
-	serv.SetAuthentication(EFalse);
-	serv.SetAuthorisation(EFalse);
-	serv.SetEncryption(EFalse);
-
-	// now set up Obex...
-	TObexBluetoothProtocolInfo info;
-	info.iTransport = KObexRfcommProtocol;
-	info.iAddr.SetPort(KRfcommPassiveAutoBind);
-	info.iAddr.SetSecurity(serv);
-
-	TObexProtocolPolicy policy;
-	policy.SetReceiveMtu(iParent->iRecvMTU);
-	policy.SetTransmitMtu(iParent->iTransmitMTU);
-
-	iServer  = CObexServer::NewL(info, policy);
-	iServer->SetReadActivityObserver(this);
-
-	User::LeaveIfError(iServer->Start (this));
-	// We get back an TObexBtTransportInfo because we asked for KObexRfcommProtocol.
-	const TObexBtTransportInfo* transportInfo = static_cast<const TObexBtTransportInfo*>(iServer->TransportInfo());
-	iParent->Console()->Printf(_L("Transport info: \r\n"));
-	iParent->Console()->Printf(_L("\ttransport name: %S\r\n"), &transportInfo->iTransportName);
-	iParent->Console()->Printf(_L("\tversion: %d\r\n"), transportInfo->iVersion);
-	iParent->Console()->Printf(_L("\treceive MTU: %d\r\n"), transportInfo->iReceiveMtu);
-	iParent->Console()->Printf(_L("\ttransmitMTU: %d\r\n"), transportInfo->iTransmitMtu);
-	iParent->Console()->Printf(_L("\tRFCOMM port: 0x%02x\r\n"), transportInfo->iAddr.Port());
-	
-	// SDP registration 
-	User::LeaveIfError(iSdp.Connect());
-	User::LeaveIfError(iSdpdb.Open(iSdp));
-
-	TSdpServRecordHandle handle;
-	iSdpdb.CreateServiceRecordL(TUUID(0x1105), handle);
-	iSdpdb.UpdateAttributeL(handle, 0x100, _L8("Obex push server"));
-	
-
-	TSdpServRecordHandle ftphandle;
-	iSdpdb.CreateServiceRecordL(TUUID(0x1106), ftphandle);
-	iSdpdb.UpdateAttributeL(ftphandle, 0x100, _L8("File transfer server"));
-			
-	// Protocol Descriptor List (same for both profiles)
-	iProtDescList = CSdpAttrValueDES::NewDESL(0);
-
-	iProtDescList
-	->StartListL()
-		->BuildDESL()
-		->StartListL()
-			->BuildUUIDL(TUUID(TUint16(0x0100))) // L2CAP
-		->EndListL()
-		->BuildDESL()
-		->StartListL()
-			->BuildUUIDL(TUUID(TUint16(0x0003))) // RFCOMM
-			->BuildUintL(TSdpIntBuf<TInt8>(transportInfo->iAddr.Port()))
-		->EndListL()
-		->BuildDESL()
-		->StartListL()
-			->BuildUUIDL(TUUID(TUint16(0x0008))) // OBEX
-		->EndListL()
-	->EndListL();
-
-	iSdpdb.UpdateAttributeL(handle, 4, *iProtDescList);
-	iSdpdb.UpdateAttributeL(ftphandle, 4, *iProtDescList); // put into both records
-	delete iProtDescList;
-	iProtDescList = NULL;
-
-	// Supported formats list (OPP only)
-	iProtDescList = CSdpAttrValueDES::NewDESL(0);
-
-	iProtDescList->StartListL()
-		->BuildUintL(TSdpIntBuf<TUint8>(0xFF)) // Accept any type of object
-	->EndListL();
-
-	iSdpdb.UpdateAttributeL(handle, 0x0303, *iProtDescList);
-	
-	delete iProtDescList;
-	iProtDescList = NULL;
-	
-	// Add OPP to the supported profiles list
-	iProtDescList = CSdpAttrValueDES::NewDESL(0);
-
-	iProtDescList->StartListL()
-		->BuildDESL()
-		->StartListL()
-			->BuildUUIDL(TUUID(0x1105)) // OPP Profile
-			->BuildUintL(TSdpIntBuf<TUint16>(0x0100)) // Profile version
-		->EndListL()
-	->EndListL();
-
-	iSdpdb.UpdateAttributeL(handle, 9, *iProtDescList); // profile list
-
-	delete iProtDescList;
-	iProtDescList = NULL;
-
-	// Add FTP to the supported profiles list
-	iProtDescList = CSdpAttrValueDES::NewDESL(0);
-
-	iProtDescList->StartListL()
-		->BuildDESL()
-		->StartListL()
-			->BuildUUIDL(TUUID(0x1106)) // FTP Profile
-			->BuildUintL(TSdpIntBuf<TUint16>(0x0100)) // Profile version
-		->EndListL()
-	->EndListL();
-
-	iSdpdb.UpdateAttributeL(ftphandle, 9, *iProtDescList); // profile list
-
-	delete iProtDescList;
-	iProtDescList = NULL;
-	
-	// Set host name
-	RSocketServ ss;
-	ss.Connect();
-
-	RHostResolver hr;
-	User::LeaveIfError(hr.Open(ss,KBTAddrFamily,KBTLinkManager));
-	User::LeaveIfError(hr.SetHostName(_L("Symbian Push Server")));
-	ss.Close();
-
-	// Enable enquiry and page scan
-	User::LeaveIfError(RProperty::Set(KPropertyUidBluetoothCategory, KPropertyKeyBluetoothSetScanningStatus, EInquiryAndPageScan));
-	}
-
-CObexServerHandlerBase::~CObexServerHandlerBase ()
-    {
-    Stop();
-
-	if (iTransportLayer == EBluetooth)
-		{
-		// security now cleared with socket closure
-		iSdpdb.Close();
-		iSdp.Close();
-		}
-#ifdef PACKET_ACCESS_EXTENSION
-	delete iPacketAccessUi;
-#endif // PACKET_ACCESS_EXTENSION
-
-#ifdef ASYNC_INDICATION		
-	delete iServerAsyncAO;
-#endif
-    delete iServer;
-	delete iProtDescList;
-    }
-
-void CObexServerHandlerBase::RemoteAddress()
-	{
-	TSockAddr aAddr;
-	iServer->RemoteAddr( aAddr);
-	TBTDevAddr addr = static_cast <TBTSockAddr>(aAddr).BTAddr();
-	
-	TChar aChar;
-
-	iParent->Console()->Printf(_L("Remote Address = "));
-	for(TInt count = 0; count < addr.Des().Length(); count++) 
-		{
-		aChar = (addr.Des()[count] & 0xf0)>>4;
-		if (aChar <= 9)
-			aChar += 0x30;
-		else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-			aChar += 'A' - 0x0a;
-		iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-
-		aChar = (addr.Des()[count] & 0x0f);
-		if (aChar <= 9)
-			aChar += 0x30;
-		else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-			aChar += 'A' - 0x0a;
-		iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-		}
-    iParent->Console()->Printf(_L("\r\n"));
-	}
-
-
-void CObexServerHandlerBase::Start()
-    {
-    if (iServer)
-		{
-		iServer->Start(this);
-		}
-    }
-
-void CObexServerHandlerBase::Stop()
-    {
-	if (iServer)
-		{
-		iServer->Stop();
-		}
-    }
-
-void CObexServerHandlerBase::SetTargetChecking(CObexServer::TTargetChecking aValue)
-	{
-    iServer->SetTargetChecking(aValue);
-	}
-
-
-
-// MObexServerNotify interface functions
-
-void CObexServerHandlerBase::ErrorIndication (TInt aError)
-    {
-    iParent->Console()->Printf(_L("Obex Server Error: %d\r\n"), aError);
-    }
-
-void CObexServerHandlerBase::TransportUpIndication ()
-    {
-    iParent->Console()->Printf(_L("\r\nTransport layer now connected\r\n\r\n"));
-    }
-
-void CObexServerHandlerBase::TransportDownIndication ()
-    {
-    iParent->Console()->Printf(_L("\r\nTransport layer has gone down\r\n\r\n"));
-    
-    if (iObject)
-		{
-		if(!iObject->BytesReceived())
-			{
-			return;
-			}
-		
-		iParent->Console()->Printf(_L("\r\nWe have received part of an Obex object\r\n\r\n"));
-
-		iObject->Reset();//close file handle
-		}
-    }
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& /*aInfo*/)
-#else
-TInt CObexServerHandlerBase::ObexConnectIndication(const TObexConnectInfo& aRemoteInfo, const TDesC8& /*aInfo*/)
-#endif
-    {
-	iParent->Console()->Printf(_L("\r\nCObexServerHandler::ObexConnectIndication"));
-	iParent->Console()->Printf(_L("\r\nConnected to machine with OBEX version %d.%d\r\n"), 
-		     aRemoteInfo.VersionMajor (), aRemoteInfo.VersionMinor ());
-
-	if ( aRemoteInfo.iWho.Length() > 0 )
-		{
-		iParent->Console()->Printf(_L("EWho received from remote side ="));
-
-		for(TInt count = 0; count < aRemoteInfo.iWho.Length(); count++) 
-			{
-
-			TChar aChar;
-
-			aChar = (aRemoteInfo.iWho[count] & 0xf0)>>4;
-			if (aChar <= 9)
-				aChar += 0x30;
-			else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-				aChar += 'A' - 0x0a;
-			iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-
-			aChar = (aRemoteInfo.iWho[count] & 0x0f);
-			if (aChar <= 9)
-				aChar += 0x30;
-			else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-				aChar += 'A' - 0x0a;
-			iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-
-			}
-		iParent->Console()->Printf(_L("\r\n"));
-		}
-	else
-		iParent->Console()->Printf(_L("No Who Header received\r\n"));
-
-	if ( aRemoteInfo.iTargetHeader.Length() > 0 )
-		{
-		iParent->Console()->Printf(_L("ETarget received from remote side ="));
-		for(TInt count = 0; count < aRemoteInfo.iTargetHeader.Length(); count++) 
-			{
-			TChar aChar;
-
-			aChar = (aRemoteInfo.iTargetHeader[count] & 0xf0)>>4;
-			if (aChar <= 9)
-				aChar += 0x30;
-			else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-				aChar += 'A' - 0x0a;
-			iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-
-			aChar = (aRemoteInfo.iTargetHeader[count] & 0x0f);
-			if (aChar <= 9)
-				aChar += 0x30;
-			else if ((aChar >= 0x0a) && (aChar <= 0x0f))
-				aChar += 'A' - 0x0a;
-			iParent->Console()->Printf(_L("%C"),(TUint)aChar);
-			}
-		iParent->Console()->Printf(_L("\r\n"));
-		}
-	else
-		iParent->Console()->Printf(_L("No Target Header received\r\n"));
-
-#ifndef ASYNC_INDICATION
-	return KErrNone;
-#endif	
-    } 
-
-void CObexServerHandlerBase::ObexDisconnectIndication (const TDesC8& /*aInfo*/)
-    {
-    iParent->Console()->Printf(_L("\r\nObex Disconnected\r\n\r\n"));
-    }
-
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::PutRequestIndication ()
-#else
-CObexBufObject* CObexServerHandlerBase::PutRequestIndication ()
-#endif
-    {
-	iStartTime.HomeTime();
-	
-    iParent->Console()->Printf(_L("Receiving object...\r\n"));
-    iObject->Reset ();
-#ifdef ASYNC_INDICATION
-	iServerAsyncAO->RequestIndication(CObex::EOpPut, iAcceptPuts?iObject:NULL);
-#else
-	return iAcceptPuts?iObject:NULL;
-#endif
-    }
-
-TInt CObexServerHandlerBase::PutPacketIndication ()
-    {
-    // Only output % received if performance logging is disabled.
-	if(!iParent->iPerformanceLoggingEnabled)
-		{
-		TUint length = iObject->Length();
-		TUint received = iObject->BytesReceived();
-		TUint8 percent = 0;
-	    if (length > 0)
-			{
-			percent = TUint8((100 * received) / length);
-			iParent->Console()->Printf(_L("\r%d %%      "), percent);
-			}
-	    else
-			{
-			iParent->Console()->Printf(_L("\r%d Bytes      "), iObject->BytesReceived ());
-			}
-		}
-    return (KErrNone);
-    }
-    
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::PutCompleteIndication()
-#else
-TInt CObexServerHandlerBase::PutCompleteIndication()
-#endif
-    {
-	TTime finishTime;
-	finishTime.HomeTime();
-	TTimeIntervalMicroSeconds diff = finishTime.MicroSecondsFrom(iStartTime);	
-
-	iParent->Console()->Printf(_L("\nObject Received in %d"), diff.Int64());
-
-    TPtrC name=iObject->Name();
-	TBuf<100> type;
-	type.Copy(iObject->Type());
-	iParent->Console()->Printf(_L("\r\nSuccessfully received '%S'\r\nType[%d]: '%S'\r\n"), &name, type.Length(), &type);
-	
-	TInt err = KErrNone;
-	if (iParent->DisplayHeaders())
-		{
-		// No need to put header on the cleanup stack, as there are no leaving functions during its lifetime
-		CObexHeader* header = NULL;
-		TRAP(err, header = CObexHeader::NewL());
-		if (err)
-			{
-			iParent->iConsole->Printf(_L("Error allocating memory to display\r\n"));
-			}
-
-		iObject->HeaderSet().SetMask(NULL);
-		iObject->HeaderSet().First();
-
-		while (err == KErrNone)
-			{
-			err = iObject->HeaderSet().This(header);
-
-			switch (header->Type())
-				{
-				case (0x00): //Unicode
-					{
-					HBufC16* buf = NULL;
-					TRAPD(headerErr, buf = HBufC16::NewL((header->AsUnicode()).Size()));
-					if (headerErr)
-						{
-						iParent->iConsole->Printf(_L("Unicode Header (0x%x)- Error allocating memory to display\r\n"), header->HI());
-						}
-					else
-						{
-						TPtr16 type(buf->Des());
-						type.Copy(header->AsUnicode());
-
-						iParent->iConsole->Printf(_L("Unicode Header (0x%x) =  : \"%S\"\r\n"), header->HI(), &type);
-						delete buf;
-						}
-					break;
-					}
-				case (0x01): // ByteSeq
-					{
-					HBufC16* buf = NULL;
-					TRAPD(headerErr, buf = HBufC16::NewL((header->AsByteSeq()).Size()));
-					if (headerErr)
-						{
-						iParent->iConsole->Printf(_L("ByteSeq Header (0x%x)- Error allocating memory to display\r\n"), header->HI());
-						}
-					else
-						{
-						TPtr16 type(buf->Des());
-						type.Copy(header->AsByteSeq());
-
-						iParent->iConsole->Printf(_L("ByteSeq Header (0x%x) =  : \"%S\"\r\n"), header->HI(), &type);
-						delete buf;
-						}
-					break;
-					}
-				case (0x02): // Byte
-					{
-					iParent->iConsole->Printf(_L("Byte Header (0x%x) =  : 0x%x\r\n"), header->HI(), header->AsByte());
-					break;
-					}
-				case (0x03): //FourByte
-					{
-					iParent->iConsole->Printf(_L("FourByte Header (0x%x) =  : 0x%x\r\n"), header->HI(), header->AsFourByte());
-					break;
-					}
-				default : {break;}
-				}
-			
-			err = iObject->HeaderSet().Next();
-			}
-		
-		delete header;
-		}	
-
-	TDateTime dt = iObject->Time().DateTime();
-	iParent->Console()->Printf(_L("\r\nTimestamp: %d/%d/%d, %d:%d:%d\r\n\r\n"),
-				   dt.Day()+1, dt.Month()+1, dt.Year(), dt.Hour(), dt.Minute(), dt.Second());
-
-	// Reset err to no error;
-	err = KErrNone;
-
-	if ((iObject->Name() == KRef1Name) ||
-	    (iObject->Name() == KRef2Name) ||
-	    (iObject->Name() == KRef3Name) ||
-	    (iObject->Name() == KRef4Name) ||
-	    (iObject->Name() == KRef5Name) ||
-	    (iObject->Name() == KRef6Name) ||
-	    (iObject->Name() == KRef7Name) ||
-	    (iObject->Name() == KRef8Name) ||
-	    (iObject->Name() == KRef9Name))
-		{
-		iParent->Console()->Printf(_L("\r\nReference Object Received"));
-		TInt objComp = 0;
-		TRAP(err, objComp = iParent->iRefHandler->CompareObjectToReferenceL(*iObject, *iBuf, iParent->iTransport));
-		if ((objComp != 0) || (err != KErrNone)) // Make sure the objects match
-			{
-			User::Panic(_L("TOBEX - OBJCOMP"), err);
-			}
-		iParent->Console()->Printf(_L("\r\nReference Object Comparison OK\r\n\r\n"));
-		}
-	else
-		{
-		iParent->Console()->Printf(_L("Size of received object = %d\n"),iBuf->Size());
-
-	    // Only output packet contents info if performance logging is disabled.
-		if(!iParent->iPerformanceLoggingEnabled)
-			{
-		    TBuf8<1024> tempBuffer;
-			iBuf->Read(0, tempBuffer, tempBuffer.MaxSize() < iBuf->Size() ? tempBuffer.MaxSize() : iBuf->Size());
-
-			// Printf fails with Descriptor beigger than X hundred bytes so write byte at a time
-			for(TInt count = 0; count < tempBuffer.Size(); count++) 
-				{
-				iParent->Console()->Printf(_L("%C"),tempBuffer[count]);
-				}
-			}
-
-		if (iObject->Name() != KNullDesC )
-			{
-			TFileName filename;
-			filename = iParent->iInboxRoot;
-			
-			TInt bufSpaceLeft = filename.MaxLength() - filename.Length();
-			TInt objNameLen = iObject->Name().Length();
-			TInt numToCopy = objNameLen;
-			if (bufSpaceLeft < objNameLen)
-				{
-				numToCopy = bufSpaceLeft;
-				iParent->Console()->Printf(_L("Truncated resulting local filename\n"));
-				}
-			filename.Append(iObject->Name().Ptr(), numToCopy);
-			
-			err = iObject->WriteToFile(filename);
-
-			if (err == KErrAlreadyExists)
-				{
-				iParent->Console()->Printf(_L("\r\nWrite failed, File Already Exists\n"));
-				}
-			else if (err != KErrNone)
-				{
-				iParent->Console()->Printf(_L("\r\nWrite failed with error %d\n"), err);
-				}
-			}
-		else
-			{
-			err = KErrNone;
-			iParent->Console()->Printf(_L("\r\nReceived object with empty Name Header.\nNot writing to a file\n"));
-			}
-		}
-
-	TObexHeaderMask headers = iObject->ValidHeaders();
-	iParent->Console()->Printf(_L("\n"));
-	if (headers & KObexHdrBody)
-		iParent->Console()->Printf(_L("Body header received\n"));
-	if (headers & KObexHdrEndOfBody)
-		iParent->Console()->Printf(_L("EndOfBody header received\n"));
-
-    iObject->Reset ();
-#ifdef ASYNC_INDICATION    
-	if(err)
-		{
-		iServerAsyncAO->CompletionIndication(CObex::EOpPut, ERespNotAcceptable);
-		}
-	else
-		{
-		iServerAsyncAO->CompletionIndication(CObex::EOpPut, ERespSuccess);
-		}
-		
-#else
-	return err;
-#endif
-    }
-
-void CObexServerHandlerBase::HandleGetReferenceObjL(CObexBaseObject* aRequiredObject)
-	{
-	CObexBufObject& obj = *static_cast<CObexBufObject*>(aRequiredObject);
-	CBufFlat* dummyBufPtr = CBufFlat::NewL(0);
-	CleanupStack::PushL(dummyBufPtr);
-
-	// See if what we got in the Get request is the same as the reference object...
-	TInt objComp = iParent->iRefHandler->CompareObjectToReferenceL(obj, *dummyBufPtr, iParent->iTransport);
-	CleanupStack::PopAndDestroy(dummyBufPtr);
-	ASSERT(objComp == CReferenceHandler::EDifferentBuf);
-
-	// Everythings OK so set up the reference object to be returned
-	iParent->Console()->Printf(_L("Obex Get Reference Object Request\r\n"));
-
-
-	if (aRequiredObject->Name() == KRef1Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 1, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef2Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 2, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef3Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 3, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef4Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 4, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef5Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 5, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef6Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 6, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef7Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 7, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef8Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 8, iParent->iTransport);
-	else if (aRequiredObject->Name() == KRef9Name)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 9, iParent->iTransport);
-	else // capture error condition (use reference 1)
-		iParent->iRefHandler->CreateReferenceL(*iObject, *iBuf, 1, iParent->iTransport);
-
-	}
-
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::GetRequestIndication (CObexBaseObject* aRequiredObject)
-#else
-CObexBufObject* CObexServerHandlerBase::GetRequestIndication (CObexBaseObject* aRequiredObject)
-#endif
-    {
-	//check if app params header sent across
-	if ( aRequiredObject->ValidHeaders() & KObexHdrAppParam )
-		{
-		TBuf<30> localBuf;
-		localBuf.Copy(aRequiredObject->AppParam());
-		
-		iParent->iConsole->Printf(_L(" App Param received =  : %S\r\n"), &localBuf);
-		}
-	else 
-		{
-		iParent->iConsole->Printf(_L(" No App Param Headers received\r\n"));
-		}
-
-	//check if any HTTP headers were sent across
-	if ( aRequiredObject->ValidHeaders() & KObexHdrHttp)
-		{
-		//OK so lets get them out
-		const RPointerArray<HBufC8>* localHttpArray = aRequiredObject->Http(); 
-		//how many?
-		TInt count = localHttpArray->Count();
-		HBufC8* localArray;
-		TBuf8<30> localBuf;
-		TBuf<40> buf;
-		TInt size = 30;
-		for ( TInt x = 0; x < count; x++ )
-			{
-			localArray = (*localHttpArray)[x];
-			size = Max(localArray->Size(), 30);
-			localBuf.Copy(localArray->Ptr(), size);
-			buf.Copy(localBuf);
-			iParent->iConsole->Printf(_L(" HTTP Header Received : %S\r\n"), &buf);
-			}
-		}
-	else 
-		{
-		iParent->iConsole->Printf(_L(" No HTTP Headers received\r\n"));
-		}
-	
-	if ((aRequiredObject->Name() == KRef1Name) ||
-	    (aRequiredObject->Name() == KRef2Name) ||
-	    (aRequiredObject->Name() == KRef3Name) ||
-	    (aRequiredObject->Name() == KRef4Name) ||
-	    (aRequiredObject->Name() == KRef5Name) ||
-	    (aRequiredObject->Name() == KRef6Name) ||
-	    (aRequiredObject->Name() == KRef7Name) ||
-	    (aRequiredObject->Name() == KRef8Name) ||
-	    (aRequiredObject->Name() == KRef9Name))
-		{
-#ifdef _DEBUG
-		TRAPD(err, HandleGetReferenceObjL(aRequiredObject));
-		ASSERT(err==0);
-#else
-		TRAP_IGNORE(HandleGetReferenceObjL(aRequiredObject));
-#endif
-		}
-	else
-		{
-		TRAPD(err,SetUpGetObjectL(aRequiredObject));
-		if (err != KErrNone)
-			{
-			iParent->Console()->Printf(_L("\nSetUpGetObjectL() returned %d.\n"), err);
-#ifdef ASYNC_INDICATION
-			iServerAsyncAO->RequestIndication(CObex::EOpGet, NULL);
-#else
-			iServer->RequestIndicationCallbackWithError(err); //added to test PDEF097129
-			return (NULL);
-#endif
-			}
-		}
-#ifdef ASYNC_INDICATION
-	iServerAsyncAO->RequestIndication(CObex::EOpGet, iObject);
-#else
-	return (iObject);
-#endif
-	}
-
-TInt CObexServerHandlerBase::GetPacketIndication ()
-    {
-    if (iObject->Length () > 0)
-    	{
-    	TInt percentComplete = 100 * iObject->BytesSent () / iObject->Length ();
-    	iParent->Console()->Printf(_L("\r%d %%      "), percentComplete);
-    	}
-    else
-    	{
-    	iParent->Console()->Printf(_L("\r%d Bytes      "), iObject->BytesSent ());
-    	}
-    
-    return (KErrNone);
-    }
-
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::GetCompleteIndication ()
-#else
-TInt CObexServerHandlerBase::GetCompleteIndication ()
-#endif
-    {
-    iParent->Console()->Printf(_L("Obex Get Complete\r\n"));
-    iObject->Reset ();
-#ifdef ASYNC_INDICATION   
-	iServerAsyncAO->CompletionIndication(CObex::EOpGet, ERespSuccess);
-#else
-	return KErrNone;
-#endif
-    }
-
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::SetPathIndication (const CObex::TSetPathInfo& aPathInfo, const TDesC8& /*aInfo*/)
-#else
-TInt CObexServerHandlerBase::SetPathIndication (const CObex::TSetPathInfo& aPathInfo, const TDesC8& /*aInfo*/)
-#endif
-    {
-    iParent->Console()->Printf(_L("Obex SetPath request:\r\n"));
-    iParent->Console()->Printf(_L("   --- Flags = '%d' - Constants = '%d' - "), aPathInfo.iFlags, aPathInfo.iConstants);
-    if (aPathInfo.iNamePresent)
-		iParent->Console()->Printf(_L("Name = %S\r\n"), &aPathInfo.iName);
-	else
-		iParent->Console()->Printf(_L("> No Name Present <\r\n"));
-
-    iParent->Console()->Printf(_L("\nReturning success...!\n"));
-#ifdef ASYNC_INDICATION
-	iServerAsyncAO->CompletionIndication(CObex::EOpSetPath, ERespSuccess);
-#else
-	return (KErrNone);
-#endif
-    }
-
-void CObexServerHandlerBase::AbortIndication ()
-    {
-    iParent->Console()->Printf(_L("Obex Operation aborted\r\n"));
-    if(iObject)
-		{
-		if(!iObject->BytesReceived())
-		    return;
-		iParent->Console()->Printf(_L("\r\nWe have received part of an Obex object\r\n\r\n"));
-
-		iObject->Reset();//closes file handle
-		}
-    }
-
-void CObexServerHandlerBase::MoraoReadActivity()
-	{
-    iParent->Console()->Printf(_L("Obex Server: 'Read Activity' signalled\r\n"));
-	}
-	
-void CObexServerHandlerBase::SetUpGetObjectL(CObexBaseObject *aRequestedObject)
-	{
-	TFileName name;
-	name = iParent->iInboxRoot;
-	name.Append(aRequestedObject->Name ());
-	if(name.Length())
-		{
-		iParent->Console()->Printf(_L("Obex Get Request for name '%s'\r\n"), name.PtrZ ());
-		}
-	else if (aRequestedObject->Type().Length())
-		{
-		name = iParent->iInboxRoot;
-		TBuf<32> temp;
-		temp.Copy(aRequestedObject->Type());
-		name.Append(temp);
-		iParent->Console()->Printf(_L("Obex Get Request for type '%s'\r\n"), name.PtrZ ());
-		TInt pos;
-		while((pos=name.Locate('/')) >= 0)
-			name[pos] = '_';
-		pos=name.Length()-1;
-		if(pos>=0 && name[pos] == 0)
-			name.SetLength(pos); // Work around last character possibly being NULL
-		}
-	else
-		{
-		iParent->Console()->Printf(_L("Obex Get Request unknown details\r\n"));
-		User::Leave(KErrNotSupported);
-		}
-	iObject->Reset();
-
-	RFs fs;
-	RFile f;
-	if ((fs.Connect () != KErrNone) || 
-		(f.Open (fs, name, EFileShareReadersOnly | EFileRead) != KErrNone))
-		{
-		iParent->Console()->Printf(_L("\r\nError reading '%S'."), &name);
-		User::Leave(KErrNotFound);
-		}
-
-	TInt size = 0;
-	User::LeaveIfError(f.Size (size));
-	iBuf->ResizeL(size);
-	TPtr8 data (iBuf->Ptr(0));
-	f.Read (data);
-	if (iBuf->Size() < size)
-		User::Leave(KErrGeneral);
-	iObject->SetNameL(name);
-	iObject->SetLengthL(size);
-	TTime time;
-	if (f.Modified(time) == KErrNone)
-		iObject->SetTimeL(time);
-	}
-
-void CObexServerHandlerBase::EnableAuthentication()
-	{
-	TRAPD(err, iServer->SetChallengeL(iChallengePassword));
-	if (err == KErrNone)
-		{
-		iIsAuthenticationEnabled = ETrue;
-		}
-	else
-		{
-		iParent->iConsole->Printf(_L("Failed to set authentication password\r\n"));
-		}
-	}
-
-void CObexServerHandlerBase::DisableAuthentication()
-	{
-	iServer->ResetChallenge();
-	iIsAuthenticationEnabled = EFalse;
-	}
-
-void CObexServerHandlerBase::EnablePassword()
-	{
-	iServer->SetCallBack(*this);
-	}
-
-void CObexServerHandlerBase::ChangeChallengePassword(TDesC* aPassword)
-	{
-	if (aPassword)
-		iChallengePassword = *aPassword;
-	else
-		iParent->SetPassword(iChallengePassword);
-
-	if (iIsAuthenticationEnabled)
-		{
-		DisableAuthentication();
-		EnableAuthentication();
-		}
-	}
-
-void CObexServerHandlerBase::ChangeResponsePassword()
-	{
-	iParent->Cancel();
-	iParent->SetPassword(iResponsePassword);
-	iParent->RequestCharacter(); // re-request, to re-display menu
-	}
-
-void CObexServerHandlerBase::GetUserPasswordL(const TDesC& aUserID)
-	{
-	iParent->Console()->Printf(_L("\r\nServer has been challenged by %S"), &aUserID);
-	ChangeResponsePassword(); //get the password from user
-	iServer->UserPasswordL(iResponsePassword);
-	}
-
-void CObexServerHandlerBase::SetLocalWho()
-	{
-	iServer->SetLocalWho(KRefTarget);
-	}
-
-#ifdef ASYNC_INDICATION
-void CObexServerHandlerBase::CancelIndicationCallback()
-	{
-	iServerAsyncAO->Cancel();
-	}
-#endif
-
-#ifdef PACKET_ACCESS_EXTENSION	
-void CObexServerHandlerBase::PacketAccessUiL(TBool aEnable)
-	{
-	if (aEnable)
-		{
-		iPacketAccessUi = CObexServerPacketAccessUi::NewL(*this, *iServer);
-		}
-	else
-		{
-		delete iPacketAccessUi;
-		iPacketAccessUi = NULL;
-		}
-	}
-#endif // PACKET_ACCESS_EXTENSION