39 using namespace Messages; |
39 using namespace Messages; |
40 using namespace ESock; |
40 using namespace ESock; |
41 using namespace NetStateMachine; |
41 using namespace NetStateMachine; |
42 using namespace MeshMachine; |
42 using namespace MeshMachine; |
43 |
43 |
44 //We reserve space for two preallocated activities that may start concurrently on the CPR |
|
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 KIPCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; |
|
49 |
|
50 //-========================================================= |
44 //-========================================================= |
51 // |
45 // |
52 // CIPConnectionProvider methods |
46 // CIPConnectionProvider methods |
53 // |
47 // |
54 //-========================================================= |
48 //-========================================================= |
55 CIPConnectionProvider* CIPConnectionProvider::NewL(ESock::CConnectionProviderFactoryBase& aFactory) |
49 CIPConnectionProvider* CIPConnectionProvider::NewL(ESock::CConnectionProviderFactoryBase& aFactory) |
56 { |
50 { |
57 CIPConnectionProvider* provider = new (ELeave) CIPConnectionProvider(aFactory); |
51 CIPConnectionProvider* provider = new (ELeave) CIPConnectionProvider(aFactory); |
58 CleanupStack::PushL(provider); |
52 CleanupStack::PushL(provider); |
59 provider->ConstructL(KIPCPRPreallocatedActivityBufferSize); |
53 provider->ConstructL(); |
60 CleanupStack::Pop(provider); |
54 CleanupStack::Pop(provider); |
61 return provider; |
55 return provider; |
62 } |
56 } |
63 |
57 |
64 CIPConnectionProvider::CIPConnectionProvider(ESock::CConnectionProviderFactoryBase& aFactory) |
58 CIPConnectionProvider::CIPConnectionProvider(ESock::CConnectionProviderFactoryBase& aFactory) |