--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/mmcefloorctrlplugin/src/fctbcpfloorcontrolimpl.cpp Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,286 @@
+/*
+* Copyright (c) 2005-2006 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: tbcpfloorcontorlimpl.cpp
+*
+*/
+
+
+
+
+#include <e32base.h>
+#include <e32std.h>
+#include <e32def.h>
+#include "fctbcpfloorcontrolimpl.h"
+#include "fcconnectioncontainer.h"
+#include "fcsender.h"
+#include "fcreceiver.h"
+#include "utf.h"
+#include "fcinterfaceinitparams.h"
+#include "fcnotifier.h"
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::NewL
+// -----------------------------------------------------------------------------
+//
+CTBCPFloorControlImpl* CTBCPFloorControlImpl::NewL(TAny* aInitParams)
+ {
+ TFCInterfaceInitParams* initParams=
+ static_cast<TFCInterfaceInitParams*>( aInitParams);
+
+ CTBCPFloorControlImpl* self =
+ new (ELeave) CTBCPFloorControlImpl(initParams->iMsgObserver);
+ CleanupStack::PushL( self );
+ self->ConstructL();
+ CleanupStack::Pop(self);
+ return self;
+ }
+
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::CTBCPFloorControlImpl
+// -----------------------------------------------------------------------------
+//
+ CTBCPFloorControlImpl::CTBCPFloorControlImpl(MFCMessageObserver &aObserver)
+: iMsgObserver (aObserver)
+ {
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ConstructL()
+ {
+ iSender = CFCSender::NewL(iSocket, *this);
+ iReceiver = CFCReceiver::NewL(iSocket, *this);
+ iConnection = CFCConnectionContainer::NewL(*this);
+ //Open the socketserver First
+ User::LeaveIfError( iSocketServ.Connect( KESockDefaultMessageSlots) );
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::~CTBCPFloorControlImpl
+// -----------------------------------------------------------------------------
+//
+CTBCPFloorControlImpl::~CTBCPFloorControlImpl()
+ {
+ if (iReceiver)
+ {
+ iReceiver->Cancel();
+ }
+ if (iSender)
+ {
+ iSender->Cancel();
+ }
+ if(iConnection)
+ {
+ iConnection->CloseConnection();
+
+ }
+ iSocket.Close();
+ delete iReceiver;
+ delete iSender;
+ delete iConnection;
+ iSocketServ.Close();
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ConnectL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ConnectL(TBool aReceiver)
+ {
+ //Open RConnection by calling CFCConnectionContainer
+ iStartListen = aReceiver;
+ User::LeaveIfError(iConnection->OpenConnection(iIapId, iSocketServ));
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ResetSocketL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ResetSocketL()
+ {
+ iSocket.Close();
+ User::LeaveIfError(iSocket.Open(iSocketServ, KAfInet, KSockDatagram,
+ KProtocolInetUdp, iConnection->Connection()));
+ iSocket.SetOpt(KSoReuseAddr, KSolInetIp, 1);
+ TInetAddr addr;
+ addr.SetAddress(KInetAddrAny);
+ addr.SetPort(iLocalPort);
+ iSocket.Bind(addr);
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::Stop
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::Stop()
+ {
+ if (iReceiver)
+ {
+ iReceiver->Cancel();
+ }
+ if (iSender)
+ {
+ iSender->Cancel();
+ }
+ if(iConnection)
+ {
+ iConnection->CloseConnection();
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::SendToNetL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::SendToNetL(HBufC8* aData)
+ {
+ iSender->SendL(aData, iRemoteAddr);
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::StartListenL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::StartListen()
+ {
+ iReceiver->Listen();
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::CancelSend
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::CancelSend()
+ {
+ iSender->Cancel();
+ //DoCancel
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::SetIapId
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::SetIapId(TUint32 aIapId )
+ {
+ //require from user
+ iIapId=aIapId;
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::SetAddress
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::SetAddressL(const TDesC& aAddr, TUint aPort)
+ {
+ TInetAddr address;
+ User::LeaveIfError(address.Input(aAddr));
+
+ if (address.Family() == KAfInet6 )
+ {
+ iRemoteAddr.SetAddress( address.Ip6Address() );
+ }
+ else
+ {
+ iRemoteAddr.SetAddress( address.Address() );
+ }
+
+ iRemoteAddr.SetPort(aPort);
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::SetLocalPort
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::SetLocalPort(TUint aPort)
+ {
+ iLocalPort=aPort;
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ReceivedData
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ReceivedData(HBufC8* aData)
+ {
+ iMsgObserver.ReceivedData( aData, this );
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ConnectionStarted
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ConnectionStarted( TInt aError )
+ {
+ TRAPD(leaveErr ,ConnectionStartedL(aError) );
+ if(leaveErr!=KErrNone)
+ {
+ ErrorNotify( leaveErr );
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ConnectionStartedL
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ConnectionStartedL( TInt aError )
+ {
+ if(aError!=KErrNone)
+ {
+ //return to Application-->ErrorNotify
+ iMsgObserver.ErrorNotify( aError, this );
+ }
+ else
+ {
+ User::LeaveIfError(iSocket.Open(iSocketServ, KAfInet, KSockDatagram,
+ KProtocolInetUdp, iConnection->Connection()));
+
+
+ iSender->ConnectedL();
+
+ TInetAddr addr;
+ addr.SetAddress(KInetAddrAny);
+ addr.SetPort(iLocalPort);
+ iSocket.Bind(addr);
+
+ if(iStartListen)
+ {
+ StartListen();
+ }
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::Name
+// -----------------------------------------------------------------------------
+//
+const TDesC8& CTBCPFloorControlImpl::Name() const
+ {
+ return KTBCP;
+ }
+
+// -----------------------------------------------------------------------------
+// CTBCPFloorControlImpl::ErrorNotify
+// -----------------------------------------------------------------------------
+//
+void CTBCPFloorControlImpl::ErrorNotify( TInt aErrCode)
+ {
+ if(aErrCode!=KErrNone)
+ {
+ TRAP_IGNORE(ResetSocketL());
+ iMsgObserver.ErrorNotify( aErrCode, this );
+ }
+ }