// Copyright (c) 2007-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:
//

#include "tavsrcSock.h"
#include "tavsrc.h"

#ifdef __WINS__
static const TSize KReaderConsole(55,10);
static const TSize KWriterConsole(55,12);
#else
static const TSize KReaderConsole(KConsFullScreen,KConsFullScreen);
static const TSize KWriterConsole(KConsFullScreen,KConsFullScreen);
#endif

//
// class CActivePacketDropIoctl
//
CActivePacketDropIoctl* CActivePacketDropIoctl::NewL(CActiveConsole* aLogConsole, RSocketArray aPendingSockets)
	{
	CActivePacketDropIoctl* self = new (ELeave) CActivePacketDropIoctl(aLogConsole, aPendingSockets);
	return self;
	}

CActivePacketDropIoctl::CActivePacketDropIoctl(CActiveConsole* aLogConsole, RSocketArray aPendingSockets) : CActive(0)
	{
	iPendingSockets = aPendingSockets;
	iLogConsole = aLogConsole;
	CActiveScheduler::Add(this);
	}

CActivePacketDropIoctl::~CActivePacketDropIoctl()
	{
	}

void CActivePacketDropIoctl::DoCancel()
	{
	Cancel();
	}

void CActivePacketDropIoctl::Start()
	{
	iPendingSockets[0].Ioctl(ENotifyAvdtpMediaPacketDropped, iStatus, &iPacketsLostPkgBuf, KSolBtAVDTPMedia);	
	SetActive();
	}

void CActivePacketDropIoctl::RunL()
	{
	__LOG(_L("\n**Packets Dropped Notification! %d packets lost.\n"), iPacketsLostPkgBuf());		
	}

//
// class CActiveSockReader
//
CActiveSockReader* CActiveSockReader::NewL(RSocket aSock, TAvdtpTransportSessionType aType)
	{
	CActiveSockReader* self = new (ELeave) CActiveSockReader(aSock);
	CleanupStack::PushL(self);
	self->ConstructL(aType);
	CleanupStack::Pop(self);
	return self;
	}

CActiveSockReader::CActiveSockReader(RSocket aSock)
: CActive(0), iSock(aSock), iBufferDes(NULL, NULL)
	{
	CActiveScheduler::Add(this);
	}
	
void CActiveSockReader::Start()
	{
	iSock.Read(iBufferDes,iStatus);
	SetActive();
	}
	
void CActiveSockReader::ConstructL(TAvdtpTransportSessionType aType)
	{
	iType = aType;
	switch (aType)
		{
	case EMedia:
		iConsole = Console::NewL(_L("Incoming Sink Data"),KReaderConsole);
		break;
	case EReporting:
		iConsole = Console::NewL(_L("Incoming Reporting Channel Data"),KReaderConsole);
		break;
	case ERecovery:
		iConsole = Console::NewL(_L("Incoming Recovery Channel Data"),KReaderConsole);
		break;
		}

	iBuffer = HBufC8::NewL(40);
	iBuffer->Des().SetMax();
	iBufferDes.Set(iBuffer->Des());
	}

CActiveSockReader::~CActiveSockReader()
	{
	Cancel();
	delete iConsole;
	iSock.Close();
	}
	
void CActiveSockReader::DoCancel()
	{
	iSock.CancelAll();
	}
	
void CActiveSockReader::RunL()
	{
	if (iStatus.Int()==KErrNone)
		{
		iConsole->Printf(_L("length: [%04d]\n"),iBufferDes.Length());
		for (TInt i=0;i<=iBufferDes.Length()-1;i++)
			{
			iConsole->Printf(_L("%c"),iBufferDes[i]);
			}
		iConsole->Printf(_L("\n\n"));
		iBuffer->Des().SetMax();
		iBufferDes.Set(iBuffer->Des());
		iSock.Read(iBufferDes,iStatus);
		SetActive();
		}
	else
		{
		iConsole->Printf(_L("SOCKET ERROR: %d"),iStatus.Int());
		}
	
	}

//
// class CActiveSockWriter
//
CActiveSockWriter* CActiveSockWriter::NewL(RSocket aSock,
													TAvdtpTransportSessionType aType)
	{
	CActiveSockWriter* writer = new (ELeave) CActiveSockWriter(aSock);
	CleanupStack::PushL(writer);
	writer->ConstructL(aType);
	CleanupStack::Pop();
	return writer;
	}

CActiveSockWriter::~CActiveSockWriter()
	{
	delete iSendBuffer;
	delete iConsole;
	// test for normal shutdown on media socket
	TRequestStatus stat;
	iSock.Shutdown(RSocket::ENormal, stat);
	User::WaitForRequest(stat);
	iSock.Close();
	}
	
void CActiveSockWriter::Send()
	{
	// periodic callback to send from app
	if (IsActive())
		{
		iConsole->Printf(_L("Info: Transport session %d tried to send, but active\n"), iType);
		}
	else
		{
		iSock.Write(*iSendBuffer, iStatus);
		SetActive();
		}
	}
	
CActiveSockWriter::CActiveSockWriter(RSocket aSock)
: CActive(-1), iSock(aSock)
	{
	CActiveScheduler::Add(this);
	}

void CActiveSockWriter::ConstructL(TAvdtpTransportSessionType aType)
	{
	//	Writer console to be used in the future if necessary for debugging
	//	iConsole = Console::NewL(_L("Writer"), KWriterConsole);
	
	iSendBuffer = HBufC8::NewL(512);
	TPtr8 des = iSendBuffer->Des();
	iType = aType;
	switch (aType)
		{
	case EMedia:
		des.Copy(_L("Media channel connected!"));
		break;
	case EReporting:
		des.Copy(_L("Reporting channel connected!"));
		break;
	case ERecovery:
		des.Copy(_L("Recovery channel connected!"));
		break;
	default:
		des.Copy(_L("Unknown channel "));
		des.AppendNum(aType);
		des.Append(_L(" connected!"));
		break;
		}
	}
	
void CActiveSockWriter::DoCancel()
	{
	iSock.CancelWrite();
	}
	
void CActiveSockWriter::RunL()
	{
	//	iConsole->Printf(_L("Info: Transport session %d SENT, result %d"), iType, iStatus.Int());
	}