equal
deleted
inserted
replaced
1702 in iOriginatorsCountSnapshot. See comment in ProcessBindToComplete(). |
1702 in iOriginatorsCountSnapshot. See comment in ProcessBindToComplete(). |
1703 */ |
1703 */ |
1704 { |
1704 { |
1705 __ASSERT_DEBUG(iPendingBinder, User::Panic(KSpecAssert_ESockCrStaCPRAC, 22)); |
1705 __ASSERT_DEBUG(iPendingBinder, User::Panic(KSpecAssert_ESockCrStaCPRAC, 22)); |
1706 |
1706 |
1707 PostRequestTo( |
1707 PostRequestTo( |
1708 address_cast<Messages::TNodeId>(FirstOriginator().RecipientId()), |
1708 SoleOriginator().Peer(), |
1709 TCFServiceProvider::TCommsBinderResponse(iPendingBinder->RecipientId()).CRef()); |
1709 TCFServiceProvider::TCommsBinderResponse(iPendingBinder->RecipientId()).CRef()); |
1710 |
1710 |
1711 iPendingBinder->SetFlags(TCFClientType::EActivating); |
1711 iPendingBinder->SetFlags(TCFClientType::EActivating); |
1712 } |
1712 } |
1713 |
1713 |
1714 |
1714 |
2116 // |
2116 // |
2117 //Gone Down Activity |
2117 //Gone Down Activity |
2118 // |
2118 // |
2119 //-========================================================= |
2119 //-========================================================= |
2120 |
2120 |
2121 MeshMachine::CNodeActivityBase* CGoneDownActivity::New(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode) |
2121 EXPORT_C MeshMachine::CNodeActivityBase* CGoneDownActivity::New(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode) |
2122 { |
2122 { |
2123 TAny* space = BorrowPreallocatedSpace(aNode, sizeof(CGoneDownActivity)); |
2123 TAny* space = BorrowPreallocatedSpace(aNode, sizeof(CGoneDownActivity)); |
2124 CGoneDownActivity* self = new (space) CGoneDownActivity(aActivitySig, aNode); |
2124 CGoneDownActivity* self = new (space) CGoneDownActivity(aActivitySig, aNode); |
2125 self->AppendPreallocatedActivity(); |
2125 self->AppendPreallocatedActivity(); |
2126 return self; |
2126 return self; |
2178 TBool CGoneDownActivity::IsIdle() const |
2178 TBool CGoneDownActivity::IsIdle() const |
2179 { |
2179 { |
2180 return NetStateMachine::ACore::IsIdle(); |
2180 return NetStateMachine::ACore::IsIdle(); |
2181 } |
2181 } |
2182 |
2182 |
2183 DEFINE_SMELEMENT(CGoneDownActivity::TSendErrorRecoveryReq, NetStateMachine::MStateTransition, CGoneDownActivity::TContext) |
2183 EXPORT_DEFINE_SMELEMENT(CGoneDownActivity::TSendErrorRecoveryReq, NetStateMachine::MStateTransition, CGoneDownActivity::TContext) |
2184 void CGoneDownActivity::TSendErrorRecoveryReq::DoL() |
2184 void CGoneDownActivity::TSendErrorRecoveryReq::DoL() |
2185 { |
2185 { |
2186 __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCorePrPanic, KPanicNoActivity)); |
2186 __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCorePrPanic, KPanicNoActivity)); |
2187 CGoneDownActivity& activity = static_cast<CGoneDownActivity&>(*iContext.iNodeActivity); |
2187 CGoneDownActivity& activity = static_cast<CGoneDownActivity&>(*iContext.iNodeActivity); |
2188 |
2188 |
2201 activity.PostRequestTo(*iContext.Node().ControlProvider(), |
2201 activity.PostRequestTo(*iContext.Node().ControlProvider(), |
2202 TCFSafeMessage::TRequestCarrierEast<TEErrorRecovery::TErrorRecoveryRequest>(msg).CRef()); |
2202 TCFSafeMessage::TRequestCarrierEast<TEErrorRecovery::TErrorRecoveryRequest>(msg).CRef()); |
2203 activity.ClearPostedTo(); |
2203 activity.ClearPostedTo(); |
2204 } |
2204 } |
2205 |
2205 |
2206 DEFINE_SMELEMENT(CGoneDownActivity::TIgnoreOrPropagate, NetStateMachine::MStateFork, CGoneDownActivity::TContext) |
2206 EXPORT_DEFINE_SMELEMENT(CGoneDownActivity::TIgnoreOrPropagate, NetStateMachine::MStateFork, CGoneDownActivity::TContext) |
2207 TInt CGoneDownActivity::TIgnoreOrPropagate::TransitionTag() |
2207 TInt CGoneDownActivity::TIgnoreOrPropagate::TransitionTag() |
2208 { |
2208 { |
2209 __ASSERT_DEBUG(iContext.iMessage.IsMessage<TEErrorRecovery::TErrorRecoveryResponse>(), User::Panic(KSpecAssert_ESockCrStaCPRAC, 38)); |
2209 __ASSERT_DEBUG(iContext.iMessage.IsMessage<TEErrorRecovery::TErrorRecoveryResponse>(), User::Panic(KSpecAssert_ESockCrStaCPRAC, 38)); |
2210 RNodeInterface* sp = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EStarted)); |
2210 RNodeInterface* sp = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EStarted)); |
2211 if (sp) |
2211 if (sp) |