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

// This file contains the implementation of the RSmsSocket class

// 

//

/**

 @file

*/

#include "smsustrm.h"

#include "smsumain.h"

#include <es_sock.h>

#include "smsstacklog.h"

/**

 *  Constructor

 *  @param aSocket representing the socket the buffer reads and writes to.

 */

RSmsSocketBuf::RSmsSocketBuf(RSocket& aSocket)

	:iSocket(aSocket)

	{

	SetBuf(ERead|EWrite,iBuffer,iBuffer);

	} // RSmsSocketBuf::RSmsSocketBuf

/**

 *  Fills the buffer's read area from the socket.

 *  

 *  @leave The function panics if the socket is not readable.

 *  @param aMaxLength Unused

 *  @return The length of the buffer

 */

TInt RSmsSocketBuf::UnderflowL(TInt)

//Leaves if the Request Status (s) is in error

//Panics if ERead==0

//

	{

	LOGSMSU1("RSmsSocketBuf::UnderflowL()");

	__ASSERT_ALWAYS(Avail(ERead)==0,SmsuPanic(KSsmuPanicStreamReadUnavailable));

	SocketWriteL();

	SetBuf(EWrite,iBuffer,iBuffer);

//

	TRequestStatus s;

	TSockXfrLength l;

	TPtr8 ptr(iBuffer,sizeof(iBuffer));

//	iSocket.RecvOneOrMore(ptr,0,s,l);

	iSocket.Recv(ptr,0,s,l);

	User::WaitForRequest(s); 

	User::LeaveIfError(s.Int());

	TInt len=ptr.Length();

	SetBuf(ERead,iBuffer,iBuffer+len);

	return len;

	} // RSmsSocketBuf::UnderflowL

/**

 *  Empties the buffer and sets up the buffer's write area.

 *  

 *  The function panics if the socket is not writable. 

 */

void RSmsSocketBuf::OverflowL()

//Panics if EWrite == 0

	{

	LOGSMSU1("RSmsSocketBuf::OverflowL()");

	__ASSERT_ALWAYS(Avail(EWrite)==0,SmsuPanic(KSsmuPanicStreamWriteUnavailable));

	SetBuf(ERead,iBuffer,iBuffer);

//

	SocketWriteL();

	SetBuf(EWrite,iBuffer,iBuffer+sizeof(iBuffer));

	} // RSmsSocketBuf::OverflowL

/**

 *  Synchronises the stream buffer with the stream, leaving if any error occurs.

 */

void RSmsSocketBuf::DoSynchL()

	{

	LOGSMSU1("RSmsSocketBuf::DoSynchL()");

	SocketWriteL();

	SetBuf(ERead|EWrite,iBuffer,iBuffer);

	} // RSmsSocketBuf::DoSynchL

/**

 *  Writes the buffered data to the socket.

 */

void RSmsSocketBuf::SocketWriteL()

	{

	LOGSMSU1("RSmsSocketBuf::SocketWriteL()");

	TInt length=Lag(EWrite);

	if (length==0)

		return;

//

	TRequestStatus s;

	iSocket.Write(TPtrC8(iBuffer,length),s);

	User::WaitForRequest(s);  

	User::LeaveIfError(s.Int());

	} // RSmsSocketBuf::SocketWriteL

/**

 *  Constructor.

 *  

 *  @param aSocket RSmsSocketBuf through which to read data

 *  @capability None

 */

EXPORT_C RSmsSocketReadStream::RSmsSocketReadStream(RSocket& aSocket)

	:RReadStream(&iBuf),

	iBuf(aSocket)

	{

	LOGSMSU1("RSmsSocketReadStream::RSmsSocketReadStream()");

	} // RSmsSocketReadStream::RSmsSocketReadStream

/**

 *  Constructor.

 *  

 *  @param aSocket RSmsSocketBuf through which to write data

 *  @capability None

 */

EXPORT_C RSmsSocketWriteStream::RSmsSocketWriteStream(RSocket& aSocket)

	:RWriteStream(&iBuf),

	iBuf(aSocket)

	{

	LOGSMSU1("RSmsSocketWriteStream::RSmsSocketWriteStream()");

	} // RSmsSocketWriteStream::RSmsSocketWriteStream