diff -r 3406c99bc375 -r 07b41fa8d1dd hti/HtiServicePlugins/HtiIpProxyServicePlugin/IPProxyEngine/Src/CExprTCPCloseAll.cpp --- a/hti/HtiServicePlugins/HtiIpProxyServicePlugin/IPProxyEngine/Src/CExprTCPCloseAll.cpp Thu Jul 15 20:25:38 2010 +0300 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,131 +0,0 @@ -/* -* Copyright (c) 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: IP-Proxy TCP protocol expression for closing all phone side -* sockets. -* -*/ - - - -// INCLUDE FILES -#include "CExprTCPCloseAll.h" -#include "CommRouterDefinitions.h" -#include "MExpressionObserverTCP.h" - -#define DEBUG_FILENAME "IPProxyEngine.log" -#include "DebugPrint.h" - - -// ============================ MEMBER FUNCTIONS =============================== - -// ----------------------------------------------------------------------------- -// CExprTCPCloseAll::CExprTCPCloseAll -// ----------------------------------------------------------------------------- -// -CExprTCPCloseAll::CExprTCPCloseAll( MExpressionObserverTCP* aObserver ) - : iObserver( aObserver ) - { - __ASSERT_DEBUG( iObserver, User::Invariant() ); - } - -// ----------------------------------------------------------------------------- -// CExprTCPCloseAll::NewL -// ----------------------------------------------------------------------------- -// -CExprTCPCloseAll* CExprTCPCloseAll::NewL( MExpressionObserverTCP* aObserver ) - { - CExprTCPCloseAll* self = CExprTCPCloseAll::NewLC( aObserver ); - CleanupStack::Pop(); - - return self; - } - -// ----------------------------------------------------------------------------- -// CExprTCPCloseAll::NewLC -// ----------------------------------------------------------------------------- -// -CExprTCPCloseAll* CExprTCPCloseAll::NewLC( MExpressionObserverTCP* aObserver ) - { - CExprTCPCloseAll* self = new( ELeave ) CExprTCPCloseAll( aObserver ); - CleanupStack::PushL( self ); - - return self; - } - - -// Destructor -CExprTCPCloseAll::~CExprTCPCloseAll() - { - } - - -// ----------------------------------------------------------------------------- -// CExprTCPCloseAll::HandleReceivedDataL() -// ----------------------------------------------------------------------------- -// -TBool CExprTCPCloseAll::HandleRecievedMsgL( TDes8& aData, TInt& aStartPos, - TInt& aLength ) - { - // Check if the prefix matches - aStartPos = aData.Find( KTCPCloseAllPrefix ); - - if ( aStartPos != KErrNotFound ) - { - // Found a matching prefix - // Let the observer know - iObserver->FrameStarted(); - - TPtr8 dataToParse( aData.MidTPtr( aStartPos ) ); - - TInt err = TryParsing( dataToParse, aLength ); - - if ( err != KErrNone ) - { - // corrupted data in the frame - iObserver->ProtocolErrorL( err, aData ); - // delete the corrupted data - aData.SetLength( 0 ); - } - - return ETrue; - } - else - { - return EFalse; - } - } - -// ----------------------------------------------------------------------------- -// CExprTCPOpen::TryParsing -// ----------------------------------------------------------------------------- -// -TInt CExprTCPCloseAll::TryParsing( TDes8& aData, TInt& aLength ) - { - __ASSERT_ALWAYS( aData.Left( KTCPCloseAllPrefix().Length() ) == KTCPCloseAllPrefix, - User::Panic( _L("Protocol"), 1 ) ); - - // TCP_CLOSEALL: - TInt frameOverhead = KTCPCloseAllPrefix().Length(); - - if ( aData.Length() >= frameOverhead ) - { - // send parsed results - iObserver->CloseAllTCPConnections(); - - aLength = frameOverhead; - } - return KErrNone; - } - -// End of File