/*
* Copyright (c) 2005-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:  
* System Includes
*
*/



#include <stdio.h>
#include <assert.h>


/*******************************************************************************
 *
 * Local Includes
 *
 ******************************************************************************/
#include "CDatalinkPacketise.h"


/*******************************************************************************
 *
 * Definitions
 *
 ******************************************************************************/


/*******************************************************************************
 *
 * Constructor - init state vars
 *
 ******************************************************************************/
CDatalinkPacketise::CDatalinkPacketise( TPhoneData *aPhoneData, CLog *aLog ) : iIncomingFrame("CDatalinkPacketise::IncomingFrame"), iOutgoingFrame("CDatalinkPacketise::OutgoingFrame")
{
	// check params
	assert( aPhoneData != NULL );
	assert( aLog != NULL );

	// set state
	iAirInterface = NULL;
	iTEChannel = NULL;
	iPhoneData = aPhoneData;
	iLog = aLog;
}


CDatalinkPacketise::~CDatalinkPacketise()
{
}


/*******************************************************************************
 *
 * Access methods
 *
 ******************************************************************************/
void CDatalinkPacketise::SetAirInterface( IAirInterface *aAirInterface )
{
	iAirInterface = aAirInterface;
}

void CDatalinkPacketise::SetTEChannel( ITEChannel *aTEChannel )
{
	iTEChannel = aTEChannel;
}


/*******************************************************************************
 *
 * Process data from the TEChannel
 *
 ******************************************************************************/
TDataPathError CDatalinkPacketise::ProcessTEData( char *data, int len, int *aErrCode )
{
//	int i;
	int errcode;
//	int frame_size;
//	char *frame_pointer;
//	TFrameError ferr;
//	TFrameStatus fstatus;
	TDataPathError derr = DPE_NONE;

	// check the params
	assert( aErrCode != NULL );
	*aErrCode = 0;
		
	// check that there is an air interface - not an error if not
	if( iAirInterface == NULL ) {
		return DPE_NONE;
	}

	// do not packetise the incoming interface
	derr = iAirInterface->SendPacket( data, len, &errcode );
	if( derr != DPE_NONE ) {
		iLog->WriteLogEntry( SV_WARNING, "CDatalinkPacketise::ProcessTEData", "SendPacket returned error", derr, errcode );
	}
	return DPE_NONE;

#if 0
	// process each byte
	for( i = 0; i < len; i++ ) {

		// add the byte to the frame
		ferr = iOutgoingFrame.AddByteToFrame( data[i] );

		// if this overflows the buffer then we send whatever is in the frame and then add it again
		if( ferr == FE_OVERFLOW ) {
			frame_pointer = iOutgoingFrame.GetFrameBuffer( &frame_size );
			derr = iAirInterface->SendPacket( frame_pointer, frame_size, &errcode );
			if( derr != DPE_NONE ) {
				iLog->WriteLogEntry( SV_WARNING, "CDatalinkPacketise::ProcessTEData", "SendPacket returned error", derr, errcode );
			}
			ferr = iOutgoingFrame.ClearFrameMemoryButNotState();
			assert( ferr == FE_NONE );
			ferr = iOutgoingFrame.AddByteToFrame( data[i] );
			assert( ferr == FE_NONE );
			continue;
		}

		// if the add was successful then check to see if the frame is complete and send it if it is
		fstatus = iOutgoingFrame.GetFrameStatus();
		if( fstatus == FS_COMPLETE ) {
			frame_pointer = iOutgoingFrame.GetFrameBuffer( &frame_size );
			derr = iAirInterface->SendPacket( frame_pointer, frame_size, &errcode );
			if( derr != DPE_NONE ) {
				iLog->WriteLogEntry( SV_WARNING, "CDatalinkPacketise::ProcessTEData", "SendPacket returned error", derr, errcode );
			}
			iOutgoingFrame.ClearFrame();
		}
	}
#endif 
	// done
	return DPE_NONE;
}


/*******************************************************************************
 *
 * Process data from the UU interface
 *
 ******************************************************************************/
TDataPathError CDatalinkPacketise::ProcessUUData( char *data, int len, int *aErrCode )
{
	int i, errcode;
	int frame_size;
	char *frame_pointer;
	TFrameError ferr;
	TFrameStatus fstatus;
	TDataPathError derr = DPE_NONE;

	// check the params
	assert( aErrCode != NULL );
	*aErrCode = 0;
		
	// check that there is an air interface - it is not unexpected or problematic if the
	// channel is not defined so this is not an error.
	if( iTEChannel == NULL ) {
		return DPE_NONE;
	}

	// process each byte 
	for( i = 0; i < len; i++ ) {

		// add the byte to the frame
		ferr = iIncomingFrame.AddByteToFrame( data[i] );

		// if this overflows the buffer then we send whatever is in the frame and then add it again
		if( ferr == FE_OVERFLOW ) {
			frame_pointer = iIncomingFrame.GetFrameBuffer( &frame_size );
			derr = iTEChannel->SendPacket( frame_pointer, frame_size, &errcode );
			if( derr != DPE_NONE ) {
				iLog->WriteLogEntry( SV_WARNING, "CDatalinkPacketise::ProcessTEData", "SendPacket returned error", derr, errcode );
			}
			ferr = iIncomingFrame.ClearFrameMemoryButNotState();
			assert( ferr == FE_NONE );
			ferr = iIncomingFrame.AddByteToFrame( data[i] );
			assert( ferr == FE_NONE );
			continue;
		}

		// get the frame status -- if the frame is complete then send it
		fstatus = iIncomingFrame.GetFrameStatus();
		if( fstatus == FS_COMPLETE ) {
			frame_pointer = iIncomingFrame.GetFrameBuffer( &frame_size );
			derr = iTEChannel->SendPacket( frame_pointer, frame_size, &errcode );
			if( derr != DPE_NONE ) {
				iLog->WriteLogEntry( SV_WARNING, "CDatalinkPacketise::ProcessUUData", "SendPacket returned an error", derr, errcode );
			}
			iIncomingFrame.ClearFrame();
		}
	}

	// done
	return DPE_NONE;
}