--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/networking/tcpcsy/src/connector.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,51 @@
+// connector.cpp
+// 
+// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the "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:
+// Accenture - Initial contribution
+//
+
+#include "connector.h"
+
+CConnector* CConnector::NewL(RSocketServ& aSocketServ, RSocket& aSocket, TUint aProtocolFamily, TUint aProtocol, const TSockAddr& aSockAddr, MConnectorObserver& aObserver)
+	{
+	CConnector* self = new(ELeave) CConnector(aSocket, aObserver);
+	CleanupStack::PushL(self);
+	self->ConstructL(aSocketServ, aProtocolFamily, aProtocol, aSockAddr);
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+CConnector::~CConnector()
+	{
+	Cancel();
+	}
+
+CConnector::CConnector(RSocket& aSocket, MConnectorObserver& aObserver)
+	: CActive(CActive::EPriorityStandard), iSocket(aSocket), iObserver(aObserver)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+void CConnector::ConstructL(RSocketServ& aSocketServ, TUint aProtocolFamily, TUint aProtocol, const TSockAddr& aSockAddr)
+	{
+	User::LeaveIfError(iSocket.Open(aSocketServ, aProtocolFamily, KSockStream, aProtocol));
+	iSocket.Connect(const_cast<TSockAddr&>(aSockAddr), iStatus);
+	SetActive();
+	}
+
+void CConnector::RunL()
+	{
+	iObserver.ConnectionComplete(iStatus.Int());
+	}
+
+void CConnector::DoCancel()
+	{
+	iSocket.CancelConnect();
+	}
+