equal
deleted
inserted
replaced
39 using namespace Messages; |
39 using namespace Messages; |
40 using namespace MeshMachine; |
40 using namespace MeshMachine; |
41 using namespace ESock; |
41 using namespace ESock; |
42 using namespace NetStateMachine; |
42 using namespace NetStateMachine; |
43 using namespace Factories; |
43 using namespace Factories; |
44 |
|
45 //We reserve space for two preallocated activities that may start concurrently on the SCPR |
|
46 //node: destroy and data client stop. |
|
47 static const TUint KDefaultMaxPreallocatedActivityCount = 2; |
|
48 static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>); |
|
49 static const TUint KPDPSCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; |
|
50 |
44 |
51 //-========================================================= |
45 //-========================================================= |
52 // |
46 // |
53 // CPDPSubConnectionProvider Activities |
47 // CPDPSubConnectionProvider Activities |
54 // |
48 // |
264 void CPDPSubConnectionProvider::ConstructL() |
258 void CPDPSubConnectionProvider::ConstructL() |
265 /** |
259 /** |
266 IP SubConnection Provider Second Phase Constructor |
260 IP SubConnection Provider Second Phase Constructor |
267 */ |
261 */ |
268 { |
262 { |
269 CCoreSubConnectionProvider::ConstructL(KPDPSCPRPreallocatedActivityBufferSize); |
263 CCoreSubConnectionProvider::ConstructL(); |
270 } |
264 } |
271 |
265 |
272 void CPDPSubConnectionProvider::Received(TNodeContextBase& aContext) |
266 void CPDPSubConnectionProvider::Received(TNodeContextBase& aContext) |
273 { |
267 { |
274 Messages::TNodeSignal::TMessageId noPeerIds[] = { |
268 Messages::TNodeSignal::TMessageId noPeerIds[] = { |