diff -r 35c06c1d4fa6 -r 07656293a99c datacommsserver/esockserver/test/providers/dummy/src/dummypr_connprov.cpp --- a/datacommsserver/esockserver/test/providers/dummy/src/dummypr_connprov.cpp Wed Jun 09 11:00:38 2010 +0300 +++ b/datacommsserver/esockserver/test/providers/dummy/src/dummypr_connprov.cpp Mon Jun 21 17:02:22 2010 +0300 @@ -52,14 +52,13 @@ static const TUint KDefaultMaxPreallocatedActivityCount = 2; static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>); static const TUint KDummyCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; -static const TUint KDestroyDelay = 3; -static const TUint KMillion = 1000000; +static const TUint KDestroyDelay = 3000; //-================================================ // // States and Transitions // //-================================================ -CDelayTimer* CDelayTimer::NewL( Messages::RNodeInterface* aSender, const Messages::TNodeId& aRecipient, const Messages::TNodeSignal::TMessageId& aMessageId ) +CDelayTimer* CDelayTimer::NewL( const Messages::TNodeId& aSender, const Messages::TNodeId& aRecipient, const Messages::TNodeSignal::TMessageId& aMessageId ) { CDelayTimer* timer = new(ELeave) CDelayTimer( aSender, aRecipient, aMessageId ); CleanupStack::PushL( timer ); @@ -73,7 +72,7 @@ Cancel(); } -CDelayTimer::CDelayTimer( Messages::RNodeInterface* aSender, const Messages::TNodeId& aRecipient, const Messages::TNodeSignal::TMessageId& aMessageId ) : +CDelayTimer::CDelayTimer( const Messages::TNodeId& aSender, const Messages::TNodeId& aRecipient, const Messages::TNodeSignal::TMessageId& aMessageId ) : CTimer( EPriorityStandard ), iSender(aSender), iRecipient(aRecipient), @@ -90,13 +89,13 @@ void CDelayTimer::RunL() { CDelayTimer::TDelayMessage msg(iMessageId); - Messages::RClientInterface::OpenPostMessageClose(iSender->RecipientId() , iRecipient, msg ); + Messages::RClientInterface::OpenPostMessageClose(iSender, iRecipient, msg ); delete this; } -void CDelayTimer::Start( TInt aIntervalInSecs ) +void CDelayTimer::Start( TInt aIntervalInMSecs ) { - After( TTimeIntervalMicroSeconds32( aIntervalInSecs * KMillion ) ); + After( TTimeIntervalMicroSeconds32( aIntervalInMSecs * 1000 ) ); } CDelayTimer::TDelayMessage::TDelayMessage() @@ -109,6 +108,12 @@ } +DEFINE_SMELEMENT(CDelayTimer::TAwaitingTimerExpired, NetStateMachine::MState, CDelayTimer::TContext) +TBool CDelayTimer::TAwaitingTimerExpired::Accept() + { + return iContext.iMessage.IsMessage(); + } + namespace DummyCPRStates { DEFINE_SMELEMENT(TSetClientAsIncoming, NetStateMachine::MStateTransition, DummyCPRStates::TContext) @@ -141,7 +146,7 @@ DEFINE_SMELEMENT(TThreeSecDelayAndPostToSelf, NetStateMachine::MStateTransition, DummyCPRStates::TContext) void TThreeSecDelayAndPostToSelf::DoL() { - CDelayTimer* delay = CDelayTimer::NewL(iContext.Node().ControlProvider(), iContext.NodeId(), iContext.iMessage.MessageId() ); + CDelayTimer* delay = CDelayTimer::NewL(iContext.Node().ControlProvider()->RecipientId(), iContext.NodeId(), iContext.iMessage.MessageId() ); delay->Start(KDestroyDelay); }