--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dbgagents/trkagent/engine/TrkSocketCommPort.cpp	Tue Mar 02 10:33:16 2010 +0530
@@ -0,0 +1,190 @@
+/*
+* Copyright (c) 2004 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 "TrkSocketCommPort.h"
+#include "TrkFramingLayer.h"
+#include "TrkEngine.h"
+#include <e32cons.h>
+
+
+CTrkSocketCommPort::CTrkSocketCommPort()
+	: CTrkCommPort(CActive::EPriorityStandard),
+	  iConnected(EFalse)
+{
+}
+
+void CTrkSocketCommPort::ConstructL(const TDesC &/*aInitFilePath*/, TDes& /*aErrorMessage*/)
+{
+	CActiveScheduler::Add(this); 
+}
+
+void CTrkSocketCommPort::IssueReadRequest()
+{
+	iNextReadChar = 0;
+	TSockXfrLength len;
+	iSocket.RecvOneOrMore(iReceivedChars, 0, iStatus, len);
+
+	SetActive();
+}
+
+void CTrkSocketCommPort::DoCancel()
+{
+	iSocket.CancelRead();
+}
+
+void CTrkSocketCommPort::RunL()
+{
+	if (iStatus.Int() == KErrNone)
+		while (iNextReadChar < iReceivedChars.Length())
+			iFramingLayer->HandleByte(iReceivedChars[iNextReadChar++]);
+
+	IssueReadRequest();
+}
+
+
+CTrkSocketCommPort::~CTrkSocketCommPort()
+{
+	Cancel();
+//	iSocket.Close();
+	iConnected = EFalse;
+	iSocketServ.Close();
+}
+
+
+CTrkSocketCommPort* CTrkSocketCommPort::NewL(const TDesC& aInitFilePath, TDes& aErrorMessage)
+{
+	CTrkSocketCommPort* self = new(ELeave) CTrkSocketCommPort;
+	CleanupStack::PushL(self);
+	self->ConstructL(aInitFilePath, aErrorMessage);
+	CleanupStack::Pop(self);
+	return self;
+}
+
+
+void CTrkSocketCommPort::OpenPortL()
+{
+	TInt error = KErrNone;
+	
+	error = iSocketServ.Connect();
+	if (error != KErrNone)
+		User::Leave(100);
+
+	error = iSocket.Open(iSocketServ, KAfInet, KSockStream, KProtocolInetTcp);
+	if (error != KErrNone)
+		User::Leave(101);
+
+	TUint protocols = 0;
+	
+	error = iSocketServ.NumProtocols(protocols);
+	
+	TProtocolDesc desc;
+	
+	for (TUint i=0; i<protocols; i++)
+	{
+		error = iSocketServ.GetProtocolInfo(i, desc);
+	}
+	
+}
+
+void CTrkSocketCommPort::ConnectL()
+{
+	TInetAddr address;
+	TInt err = KErrNone;
+	
+//	address.SetPort(10000);
+//	err = address.Input(_L("10.86.2.93"));
+//
+//	TRequestStatus stat;
+//	iSocket.Connect(address, stat);
+//	User::WaitForRequest(stat);
+
+//	iConnected = ETrue;
+
+//	TSockAddr test;
+//	iSocket.LocalName(test);
+//	TUint lp = iSocket.LocalPort();
+
+	
+	address.SetPort(6110);
+	err = address.Input(_L("127.0.0.1"));
+//	err = address.Input(_L("0.0.0.0"));
+
+	err = iSocket.Bind(address);
+	if (err != KErrNone)
+	{
+		User::Leave(err);
+	}
+
+	err = iSocket.Listen(1);
+	if (err != KErrNone)
+	{
+		User::Leave(err);
+	}
+
+	RSocket blankSocket;
+	err = blankSocket.Open(iSocketServ);
+
+	TRequestStatus stat;
+	iSocket.Accept(blankSocket, stat);
+//	SetActive();
+	User::WaitForRequest(stat);
+	User::Leave(5000);
+
+//	iSocket.Connect(address, iStatus);
+
+	iConnected = ETrue;
+}
+
+void CTrkSocketCommPort::ClosePort()
+{
+	Cancel();
+	
+	if (iConnected)
+	{
+		iSocket.Close();
+		iConnected = EFalse;
+	}
+
+	iSocketServ.Close();
+}
+
+void CTrkSocketCommPort::SendDataL(const TDesC8& aBuffer)
+{
+	TRequestStatus status;
+	iSocket.Write(aBuffer, status);
+	User::WaitForRequest(status);
+
+	User::LeaveIfError(status.Int());
+}
+
+void CTrkSocketCommPort::Listen(CTrkFramingLayer */*aFramingLayer*/)
+{
+//#warning - can leave
+//	if (!iConnected)
+//		ConnectL();
+//	iFramingLayer = aFramingLayer;
+//	CActiveScheduler::Add(this);
+//	IssueReadRequest();
+}
+
+void CTrkSocketCommPort::StopListening()
+{
+	Cancel();
+	Deque();
+}