// Copyright (c) 2001-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the License "Symbian Foundation License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.symbianfoundation.org/legal/sfl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
//



//  INCLUDES
#include "ctlbsclientpostp179.h"
#include "ctlbsposclientholder.h"
#include <e32keys.h>

// CONSTANTS
_LIT(KPosPhoneTimeLocaleFormat,
     "         phone time: %F%H:%F%T:%F%S:%F%C");

// ================= MEMBER FUNCTIONS =======================

// ---------------------------------------------------------
// Constructor.
// ---------------------------------------------------------
CT_LbsClientPosTp179::CT_LbsClientPosTp179(CT_LbsServer& aParent): CT_LbsPortedStepBase(aParent)
	{ 
	_LIT(KTestName, "Tp179 - One Client, same PSY");
	SetTestStepName(KTestName); 
	}

// ---------------------------------------------------------
// Destructor.
// ---------------------------------------------------------
CT_LbsClientPosTp179::~CT_LbsClientPosTp179()
	{
	}

// ---------------------------------------------------------
// CT_LbsClientPosTp179::CloseTest
// Always called after the test, even if the test leaves
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientPosTp179::CloseTest()
    {
    }

// ---------------------------------------------------------
// CT_LbsClientPosTp179::StartL
//
// (other items were commented in a header).
// ---------------------------------------------------------
//
void CT_LbsClientPosTp179::StartL()
    {  
    const TInt NumClients = 3;
	SetupPsyL(iUidTestPsy12);

    //Make one request, the performance requirement are not valid for
    //the first request.
    TTime startTime, stopTime;
    TTime serverStartTime, serverStopTime;
    TTimeIntervalMicroSeconds requestTime, connectionTime;
    TBuf<150> buf;

    serverStartTime.UniversalTime();
    ConnectL();
    serverStopTime.UniversalTime();

    User::LeaveIfError(OpenPositioner());

    TPositionInfo posInfo = TPositionInfo();
    _LIT(KService, "service");
    // Request data from default psy should be test psy 2
    startTime.UniversalTime();
    TInt err = PerformSyncRequest(KService, &posInfo);
    stopTime.UniversalTime();

    if (err != KErrNone)
        {
        _LIT(KErrorRequest, "The request was not completed with KErrorNone");
        LogErrorAndLeaveL(KErrorRequest);
        }

    requestTime = stopTime.MicroSecondsFrom(startTime);
    connectionTime = serverStopTime.MicroSecondsFrom(serverStartTime);

    // Added some extra timing here
    _LIT(KDebug, "Connecting to Epos took: %d us");
    buf.Format(KDebug, connectionTime.Int64());
    INFO_PRINTF1(buf);
    _LIT(KSeparator, "********");
    INFO_PRINTF1(KSeparator);
    buf.Zero();
    _LIT(KFirstRequest, "The first request took: %d us");
    buf.Format(KFirstRequest, requestTime.Int64());
    INFO_PRINTF1(buf);
    INFO_PRINTF1(KSeparator);

    CT_LbsPosClientHolder* clients = CT_LbsPosClientHolder::NewLC(NumClients, iUidTestPsy12, ETrue);
    
    TTime starttime,stoptime;
    
    starttime.UniversalTime();
    
    clients->MakeRequests();
    
    stoptime.UniversalTime();
    
     // Substract total delay incurred due to TestPsy2...i.e 2sec
    TInt duration=stoptime.Int64()-starttime.Int64()-2000000;
    
    _LIT(KMessage,"3 simultaneous requests from 3 different sub-sessions with a psy completed in %d microsec");
    TBuf<256> message;
    message.Format(KMessage,duration);
    INFO_PRINTF1(message);
    
    if(duration>3000000)
    {
     _LIT(KTime, "Time taken>3 sec");
     INFO_PRINTF1(KTime);
    }
    
    TPositionInfo position[NumClients];

    TTimeIntervalMicroSeconds
        reqTime[NumClients],
        reqTimeLimit(5000000),
        timeDifferenceLimit(500000);
    TInt status;
    TBool error = EFalse;

	//some printing mostly used for information purpose.
    for (TInt i = 0; i < NumClients; i++)
        {
        clients->GetResult(status, position[i], reqTime[i], i);
		TPosition tmp;
		position[i].GetPosition(tmp);
        if (status != 0)
            {
            _LIT(KError, "The position requested could not be retrieved, status = %d");
            buf.Format(KError, status);
            ERR_PRINTF1(buf);
            error = ETrue;
            }
        if (reqTime[i].Int64() > reqTimeLimit.Int64())
            {
            _LIT(KErrorMsg, "The request time of client %d took more than 5 seconds, req. time = %d microsecs.");
            buf.Format(KErrorMsg, i, reqTime[i].Int64());
            ERR_PRINTF1(buf);
            error = ETrue;
            }
        for (TInt j = 0; j < i; j++)
            {
            _LIT(KReqMsg, "client %d request time: %d");

            buf.Format(KReqMsg, j, reqTime[j].Int64());
            INFO_PRINTF1(buf);
			TPosition posi;
			TPosition posj;
			position[i].GetPosition(posi);
			position[j].GetPosition(posj);
            posj.Time().FormatL(buf, KPosPhoneTimeLocaleFormat);
            INFO_PRINTF1(buf);

            buf.Format(KReqMsg, i, reqTime[i].Int64());
            INFO_PRINTF1(buf);
            posi.Time().FormatL(buf, KPosPhoneTimeLocaleFormat);
            INFO_PRINTF1(buf);

            _LIT(KSeparator, "********");
            INFO_PRINTF1(KSeparator);

            if (Abs(reqTime[i].Int64() - reqTime[j].Int64()) > timeDifferenceLimit.Int64())
                {
                _LIT(KMsg1, "Requests by client %d and %d wasn't served simultaniously: %d microsecs difference between reqTime.");
                TBuf<150> buf;
                buf.Format(KMsg1, i, j, Abs(reqTime[i].Int64() - reqTime[j].Int64()));
                ERR_PRINTF1(buf);
                error = ETrue;
                }
            if (Abs(posi.Time().Int64() - posj.Time().Int64()) > timeDifferenceLimit.Int64())
                {
                _LIT(KMsg2, "Requests by client %d and %d wasn't served simultaniously: %d microsecs difference between phoneTime.");
                TBuf<150> buf;
                buf.Format(KMsg2, i, j, Abs(posi.Time().Int64() - posj.Time().Int64()));
                ERR_PRINTF1(buf);
                error = ETrue;
                }
            }
        }

    CleanupStack::PopAndDestroy(); //clients
    ClosePositioner();

	Disconnect();

    if (error)
        User::Leave(KErrGeneral);
    }