datacommsserver/esockserver/test/providers/dummy/src/dummypr_connprov.cpp
branchRCL_3
changeset 21 07656293a99c
parent 18 9644881fedd0
child 23 cbb19216b74d
--- 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<Messages::TEBase::TNull>();
+    }
+
 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);
     }