/*
* 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: CRedirectServer session
*
*/
#include "javaredirectsession.h"
#include "javaredirectconsts.h"
#include "javadiagnostic.h"
using namespace java::util;
CRedirectSession::CRedirectSession(DiagnosticListener& aListener) : mListener(aListener)
{
}
CRedirectSession::~CRedirectSession()
{
}
void CRedirectSession::ServiceL(const RMessage2& aMessage)
{
TInt function = aMessage.Function();
switch (function)
{
case ESystemOut:
case ESystemErr:
case ELog:
handleMessageL(aMessage);
break;
default:
break;
}
aMessage.Complete(KErrNone);
}
void CRedirectSession::handleMessageL(const RMessage2& aMessage)
{
TInt len = aMessage.GetDesLengthL(0);
RBuf8 data;
data.CleanupClosePushL();
data.CreateL(len);
aMessage.ReadL(0,data);
TInt function = aMessage.Function();
dispatchToListener(function, data);
CleanupStack::PopAndDestroy();
}
void CRedirectSession::dispatchToListener(TInt aType, const TDesC8& aData)
{
switch (aType)
{
case ESystemOut:
mListener.systemOut(aData);
break;
case ESystemErr:
mListener.systemErr(aData);
break;
case ELog:
mListener.log(aData);
break;
default:
break;
}
}