equal
deleted
inserted
replaced
38 |
38 |
39 using namespace MeshMachine; |
39 using namespace MeshMachine; |
40 using namespace Messages; |
40 using namespace Messages; |
41 using namespace ESock; |
41 using namespace ESock; |
42 using namespace NetStateMachine; |
42 using namespace NetStateMachine; |
43 |
|
44 //We reserve space for two preallocated activities that may start concurrently on the SCPR |
|
45 //node: destroy and data client stop. |
|
46 static const TUint KDefaultMaxPreallocatedActivityCount = 2; |
|
47 static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>); |
|
48 static const TUint KIPSCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; |
|
49 |
43 |
50 namespace IPSCprAddressUpdate |
44 namespace IPSCprAddressUpdate |
51 { |
45 { |
52 DECLARE_DEFINE_NODEACTIVITY(IPDeftSCprBaseActivities::ECFActivityAddressUpdate, IPSCprAddressUpdate, TCFIPMessage::TDataClientRouted) |
46 DECLARE_DEFINE_NODEACTIVITY(IPDeftSCprBaseActivities::ECFActivityAddressUpdate, IPSCprAddressUpdate, TCFIPMessage::TDataClientRouted) |
53 NODEACTIVITY_ENTRY(KNoTag, IPBaseSCprStates::TStoreAddressUpdate, IPBaseSCprStates::TAwaitingAddressUpdate, IpSCprStates::TNoTagOrDoNothingTag) |
47 NODEACTIVITY_ENTRY(KNoTag, IPBaseSCprStates::TStoreAddressUpdate, IPBaseSCprStates::TAwaitingAddressUpdate, IpSCprStates::TNoTagOrDoNothingTag) |
166 void CIpSubConnectionProvider::ConstructL() |
160 void CIpSubConnectionProvider::ConstructL() |
167 /** |
161 /** |
168 IP SubConnection Provider Second Phase Constructor |
162 IP SubConnection Provider Second Phase Constructor |
169 */ |
163 */ |
170 { |
164 { |
171 CIpSubConnectionProviderBase::ConstructL(KIPSCPRPreallocatedActivityBufferSize); |
165 CIpSubConnectionProviderBase::ConstructL(); |
172 } |
166 } |
173 |
167 |
174 RNodeInterface* CIpSubConnectionProvider::NewClientInterfaceL(const TClientType& aClientType, TAny* /*aClientInfo*/) |
168 RNodeInterface* CIpSubConnectionProvider::NewClientInterfaceL(const TClientType& aClientType, TAny* /*aClientInfo*/) |
175 { |
169 { |
176 __IPCPRLOG(IpCprLog::Printf(_L("CIpSubConnectionProvider::NewClientInterfaceL [%08x]"), this)); |
170 __IPCPRLOG(IpCprLog::Printf(_L("CIpSubConnectionProvider::NewClientInterfaceL [%08x]"), this)); |