equal
deleted
inserted
replaced
34 |
34 |
35 #if defined(__CFLOG_ACTIVE) || defined(SYMBIAN_TRACE_ENABLE) |
35 #if defined(__CFLOG_ACTIVE) || defined(SYMBIAN_TRACE_ENABLE) |
36 _LIT8(KCoreCprSubTag, "corecpr"); |
36 _LIT8(KCoreCprSubTag, "corecpr"); |
37 #endif |
37 #endif |
38 |
38 |
39 //We reserve space for two preallocated activities that may start concurrently on the CPR |
|
40 //node: destroy and data client stop. |
|
41 static const TUint KDefaultMaxPreallocatedActivityCount = 2; |
|
42 static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>); |
|
43 static const TUint KCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize; |
|
44 |
|
45 using namespace ESock; |
39 using namespace ESock; |
46 using namespace NetStateMachine; |
40 using namespace NetStateMachine; |
47 using namespace Messages; |
41 using namespace Messages; |
48 using namespace MeshMachine; |
42 using namespace MeshMachine; |
49 |
43 |
57 |
51 |
58 EXPORT_C CCoreConnectionProvider* CCoreConnectionProvider::NewL(CConnectionProviderFactoryBase& aFactory) |
52 EXPORT_C CCoreConnectionProvider* CCoreConnectionProvider::NewL(CConnectionProviderFactoryBase& aFactory) |
59 { |
53 { |
60 CCoreConnectionProvider* provider = new (ELeave) CCoreConnectionProvider(aFactory,CprActivities::coreCprActivities::Self()); |
54 CCoreConnectionProvider* provider = new (ELeave) CCoreConnectionProvider(aFactory,CprActivities::coreCprActivities::Self()); |
61 CleanupStack::PushL(provider); |
55 CleanupStack::PushL(provider); |
62 provider->ConstructL(KCPRPreallocatedActivityBufferSize); |
56 provider->ConstructL(); |
63 CleanupStack::Pop(provider); |
57 CleanupStack::Pop(provider); |
64 return provider; |
58 return provider; |
65 } |
59 } |
66 |
60 |
67 EXPORT_C CCoreConnectionProvider::~CCoreConnectionProvider() |
61 EXPORT_C CCoreConnectionProvider::~CCoreConnectionProvider() |