// Copyright (c) 2002-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:
// Contains MBufMgr Test Step 21 for commsbufs method
// 
//

// EPOC includes
#include <e32base.h>

// Test system includes
#include "networking/log.h"
#include "networking/teststep.h"

#ifdef SYMBIAN_OLD_EXPORT_LOCATION
#include "networking/log.h"
#include "networking/teststep.h"
#else
#include <networking/log.h>
#include <networking/teststep.h>
#endif

#include "TestStepCTMbufmgr.h"
#include "TestSuiteCTMbufmgr.h"

#include "Test21commsbufs.h"
#include <comms-infras/commsbufpond.h>
// constructor
CTest21CommsBufs::CTest21CommsBufs()
	{
	iTestStepName = _L("MBufMgrTest21");// Store the name of this test case
	}

// destructor
CTest21CommsBufs::~CTest21CommsBufs()
	{
	}

//
enum TVerdict CTest21CommsBufs::doTestStepL(void)
	{
	__UHEAP_MARK;
		
	//-------------- substep 1 --------------------
	Log(_L("  01 Creating CMBufManager and installing active scheduler:"));
    CleanupStack::PushL( iActSch = new(ELeave) CActiveScheduler );
	CActiveScheduler::Install(iActSch);
	CreateInstanceMBufMgrL(KMBufDefaultHeapSize);
	CleanupClosePushL(iBufPond);
	TCommsBufAllocator allocator = iBufPond.Allocator();
    Log(_L("  01 Allocate a RCommsBuf of size 128"));	
	RCommsBuf* buf = RCommsBuf::Alloc(128, allocator);
    Log(_L("  01 Check the initial offset and length should be 0 & 128"));
	// Check the initial offset and length. MUST be 0 & 128 as we 
	// allocated a buffer of size 128
	if(buf->Offset() != 0 || buf->Length() != buf->RawSize())
	    {
	    Log(_L("  Error: The offset and length checking failed"));
	    return EFail;
	    }
	
	Log(_L("  02 Write abcdef"));
	_LIT8(KWriteData, "abcdef");
	buf->Write(KWriteData, 20); // Write abcdef at offset 20
	// Check the offset should be 20
	// Check the length should 6 ie; abcdef
	Log(_L("  02 Check the write offset and length should be 20 & 6"));	
    if(buf->Offset() != 20 || buf->Length() != KWriteData().Length())
        {
        Log(_L("  Error 02: The offset and length checking failed"));        
        return EFail;
        }
	
    TBuf8<10> buffer;
    Log(_L("  02 Read the buffer at offset 0"));
    buf->Read(buffer);
    Log(_L("  02 check the content of the read buffer"));
    if(buffer.Compare(KWriteData()) != 0)
        {
        Log(_L("  Error 02 The read buffer content is not same as the write buffer"));
        return EFail;
        }

    Log(_L("  02 Read the buffer at offset 3"));
    buf->Read(buffer, 3);
    Log(_L("  02 check the content of the read buffer"));
    TPtrC8 ptr2 = KWriteData().Right(3); // Should be def
    if(buffer.Compare(ptr2) != 0)
        {
        Log(_L("  Error 02 The read buffer content is not same as the write buffer"));
        return EFail;        
        }

    Log(_L("  03 Allocate a RCommsBuf of size 128"));   
    RCommsBuf* buf2 = RCommsBuf::Alloc(128, allocator);
    Log(_L("  03 Write abcdef"));
    buf2->Write(KWriteData, 10); // Write abcdef at offset 20
    // Append ghijklm
    Log(_L("  03 Append ghijklm"));
    _LIT8(KAppendData, "ghijklm");
    buf2->Append(KAppendData);
    
    // Compare the data
    Log(_L("  03 Compare the contained data"));
    _LIT8(KCompareData, "abcdefghijklm");
    TBuf8<30> buffer2;
    buf2->Read(buffer2);
    if(buffer2.Compare(KCompareData()) != 0)
        {
        Log(_L("  Error 03 The read buffer content is not same as the write buffer"));
        return EFail;        
        }
    
    // Prepend 123
    _LIT8(KPrependData, "12345");
    Log(_L("  03 Prepend 12345"));
    buf2->Prepend(KPrependData);
    // Now offset would have been 5
    if(buf2->Offset() != 5)
        {
        Log(_L("  Error 03 after prepend the offset is not correct"));
        return EFail;
        }
    
    // Read the whole data
    buf2->Read(buffer2);
    
    _LIT8(KCompareData2, "12345abcdefghijklm");
    if(buffer2.Compare(KCompareData2()) != 0)
        {
        Log(_L("  Error 03 After prepend the read buffer is not correct."));
        return EFail;        
        }
     
    for(TInt i = 0; i < buffer2.Length(); ++i)
         {
         if(buffer2[i] != (*buf2)[i])
             {
             Log(_L("  Error 03 Comparison of individual characters failed."));
             return EFail;
             }
         }

    buf->Free();
	buf2->Free();
	CleanupStack::PopAndDestroy(); // pond
	CActiveScheduler::Install(NULL);
	CleanupStack::PopAndDestroy(iActSch);
	__UHEAP_MARKEND;
	return EPass;
	}