equal
deleted
inserted
replaced
30 |
30 |
31 using namespace Messages; |
31 using namespace Messages; |
32 using namespace ESock; |
32 using namespace ESock; |
33 using namespace IPProtoSCpr; |
33 using namespace IPProtoSCpr; |
34 using namespace MeshMachine; |
34 using namespace MeshMachine; |
35 |
|
36 //We reserve space for two preallocated activities that may start concurrently on the SCPR |
|
37 //node: destroy and data client stop. |
|
38 static const TUint KDefaultMaxPreallocatedActivityCount = 2; |
|
39 static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>); |
|
40 static const TUint KIPProtoSCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; |
|
41 |
35 |
42 //-========================================================= |
36 //-========================================================= |
43 // |
37 // |
44 // Activities |
38 // Activities |
45 // |
39 // |
140 } |
134 } |
141 |
135 |
142 void CIPProtoSubConnectionProvider::ConstructL() |
136 void CIPProtoSubConnectionProvider::ConstructL() |
143 { |
137 { |
144 ADataMonitoringProvider::ConstructL(); |
138 ADataMonitoringProvider::ConstructL(); |
145 CCoreSubConnectionProvider::ConstructL(KIPProtoSCPRPreallocatedActivityBufferSize); |
139 CCoreSubConnectionProvider::ConstructL(); |
146 } |
140 } |
147 |
141 |
148 |
142 |
149 void CIPProtoSubConnectionProvider::ReceivedL(const TRuntimeCtxId& aSender, const TNodeId& aRecipient, TSignatureBase& aMessage) |
143 void CIPProtoSubConnectionProvider::ReceivedL(const TRuntimeCtxId& aSender, const TNodeId& aRecipient, TSignatureBase& aMessage) |
150 { |
144 { |