// Copyright (c) 2005-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:
// TestDummy implementation file for a TierManager
// 
//

/**
 @file
 @internalComponent
*/

#include <elements/nm_messages_base.h>
#include <comms-infras/ss_nodemessages_dataclient.h>
#include <ss_glob.h>
#include "activityTest.h"

using namespace Messages;
using namespace MeshMachine;
using namespace ESock;

void CActivityCancelTest::StoreRequestL(const TSignatureBase& aRequest)
    {
    TBuf8<__Align8(TSignalBase::KMaxInlineMessageSize + TSignalBase::KMaxUnstoredOverhead)> msgBuf;
    aRequest.Store(msgBuf);
    TPtrC8 messageStore(msgBuf);
    TlsGlobals::Get().VirtualCtor()->New(messageStore, iStoredRequest);
    }


DEFINE_SMELEMENT(CActivityCancelTest::TNoTagForwardOrActiveTagBackward, NetStateMachine::MStateFork, TContext)
TInt CActivityCancelTest::TNoTagForwardOrActiveTagBackward::TransitionTag()
    {
    if (message_cast<TEBase::TError>(&iContext.iMessage))
        {
        return KActiveTag | NetStateMachine::EBackward;
        }
    return KNoTag | NetStateMachine::EForward;
    }

DEFINE_SMELEMENT(CActivityCancelTest::TBeginTest, NetStateMachine::MStateTransition, TContext)
void CActivityCancelTest::TBeginTest::DoL()
    {
    ASSERT(iContext.iNodeActivity);
    CActivityCancelTest& act = static_cast<CActivityCancelTest&>(*iContext.iNodeActivity);
    act.StoreRequestL(iContext.iMessage);
    }
    
DEFINE_SMELEMENT(CActivityCancelTest::TBeginLoop, NetStateMachine::MStateTransition, TContext)
void CActivityCancelTest::TBeginLoop::DoL()
    {
    ASSERT(iContext.iNodeActivity);
    CActivityCancelTest& act = static_cast<CActivityCancelTest&>(*iContext.iNodeActivity);    
    act.PostRequestTo(iContext.Node().Id(), act.StoredRequest());  
    act.NextLoop();
    }


DEFINE_SMELEMENT(CActivityCancelTest::TCancel, NetStateMachine::MStateTransition, TContext)
void CActivityCancelTest::TCancel::DoL()
    {
    ASSERT(iContext.iNodeActivity);
    CActivityCancelTest& act = static_cast<CActivityCancelTest&>(*iContext.iNodeActivity);    
    act.PostRequestTo(iContext.Node().Id(), TEBase::TCancel());
    }

DEFINE_SMELEMENT(CActivityCancelTest::TEndTest, NetStateMachine::MStateTransition, TContext)
void CActivityCancelTest::TEndTest::DoL()
    {
    ASSERT(iContext.iNodeActivity);
    CActivityCancelTest& act = static_cast<CActivityCancelTest&>(*iContext.iNodeActivity);   
    act.PostToOriginators(iContext.iMessage);
    ASSERT(act.Error() != KErrNone); //if the activity has done its job, the activity have been invariably errored; 
    act.SetError(KErrNone); //No point reporting this error though.
    }


namespace CancelTestBindToActivity
{
/* This is a largely generic activity written to test cancelling behaviour of another (typically 
 * production code) activity. In this case it is put on top of and to test the TBindTo 
 * activity, by the virtue of awaiting TCFDataClient::TBindTo. In principle though it can be put on
 * top of any other activity by awaiting for something else instead. CancelTestBindToActivity hijacks
 * and stores the original request (in this case TCFDataClient::TBindTo). It then goes to perform a 
 * loop:
 * { 
 * - It forwards the stored request to the overriden activity (in this case the TBindTo activity), 
 * - then follows it with a TCancel 
 * - and awaits for TError. 
 * }
 * Each loop will send the TCancel slightly later, i.e.: at consecutive ticks triggered by messages 
 * received by the local node (and subsequently resulting in AMMNodeBase::SignalActivities). 
 * If you examine CActivityCancelTest::TProgressiveCancel you will see that it is blocked 
 * (as any other synchronised activity) against gradually increasing number of ticks. It has been
 * pointed out that the tick resolution may be too small - i.e.: that we may want to tick the
 * activity with every message sent within the local thread (and thus with every even that can
 * change the state of the activity peers). This can be done by signalling CActivityCancelTest
 * from the transport upon every dispatch (or post). This is so far not done. Instead CancelTestBindToActivity
 * is put against every mm node performing bind to (CPR and SCPR).
 */
DEFINE_CUSTOM_NODEACTIVITY(CActivityCancelTest::ECancelTestActivity, CancelBindTo, TCFDataClient::TBindTo, CActivityCancelTest::NewL)
    FIRST_NODEACTIVITY_ENTRY(CActivityCancelTest::TAwaitingMessageState<TCFDataClient::TBindTo>, MeshMachine::TNoTag)
    THROUGH_NODEACTIVITY_ENTRY(KNoTag, CActivityCancelTest::TBeginTest, MeshMachine::TTag<KActiveTag>)
    THROUGH_NODEACTIVITY_ENTRY(KActiveTag, CActivityCancelTest::TBeginLoop, MeshMachine::TNoTag)    
    NODEACTIVITY_ENTRY(KNoTag, CActivityCancelTest::TProgressiveCancel, MeshMachine::TAcceptErrorState<MeshMachine::TAwaitingMessageState<TCFDataClient::TBindToComplete>  >, CActivityCancelTest::TNoTagForwardOrActiveTagBackward)
    LAST_NODEACTIVITY_ENTRY(KNoTag, CActivityCancelTest::TEndTest)
NODEACTIVITY_END()
}