// 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:
//

#ifndef TAVSRCSOCK_H
#define TAVSRCSOCK_H

#include "tavsrc.h"
#include "tavsrcConsole.h"

#include <e32base.h>

class CActivePacketDropIoctl : public CActive
	{
public:
	static CActivePacketDropIoctl* NewL(CActiveConsole* aLogConsole, RSocketArray aPendingSockets);
	~CActivePacketDropIoctl();
	void DoCancel();
	void RunL();
	void Start();

private:
	CActivePacketDropIoctl(CActiveConsole* aLogConsole, RSocketArray aPendingSockets);

private:
	CActiveConsole* iLogConsole;
	RSocketArray iPendingSockets;
	TPckgBuf<TInt> iPacketsLostPkgBuf;
	};

class CActiveSockWriter : public CActive
	{
public:
	static CActiveSockWriter* NewL(RSocket aSock, TAvdtpTransportSessionType aType);
	~CActiveSockWriter();
	void Send();
	void DoCancel();
	void RunL();

private:
	CActiveSockWriter(RSocket aSock);
	void ConstructL(TAvdtpTransportSessionType aType);
	
private:
	RSocket	iSock;
	CConsoleBase* iConsole;
	HBufC8* iSendBuffer;
	TAvdtpTransportSessionType iType;
	};

class CActiveSockReader : public CActive
	{
public:
	static CActiveSockReader* NewL(RSocket aSock, TAvdtpTransportSessionType aType);
	~CActiveSockReader();
	void Start();

private:
	CActiveSockReader(RSocket aSock);
	void ConstructL(TAvdtpTransportSessionType aType);
	void DoCancel();
	void RunL();

private:
	RSocket	iSock;
	CConsoleBase* iConsole;
	HBufC8*	iBuffer;
	TPtr8 iBufferDes;
	TSockXfrLength iLen;
	TAvdtpTransportSessionType iType;
	};

#endif // TAVSRCSOCK_H