datacommsserver/esockserver/CoreProviders/src/corescpr.cpp
branchRCL_3
changeset 66 cbb19216b74d
parent 29 9644881fedd0
equal deleted inserted replaced
48:07656293a99c 66:cbb19216b74d
    37 using namespace ESock;
    37 using namespace ESock;
    38 using namespace NetStateMachine;
    38 using namespace NetStateMachine;
    39 using namespace Messages;
    39 using namespace Messages;
    40 using namespace MeshMachine;
    40 using namespace MeshMachine;
    41 
    41 
    42 //We reserve space for two preallocated activities that may start concurrently on the SCPR
       
    43 //node: destroy and data client stop.
       
    44 static const TUint KSCPRDefaultMaxPreallocatedActivityCount = 2;
       
    45 static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>);
       
    46 static const TUint KSCPRPreallocatedActivityBufferSize = KSCPRDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize;
       
    47 
       
    48 EXPORT_C CCoreSubConnectionProvider::CCoreSubConnectionProvider(CSubConnectionProviderFactoryBase& aFactory,
    42 EXPORT_C CCoreSubConnectionProvider::CCoreSubConnectionProvider(CSubConnectionProviderFactoryBase& aFactory,
    49                                                                 const MeshMachine::TNodeActivityMap& aActivityMap)
    43                                                                 const MeshMachine::TNodeActivityMap& aActivityMap)
    50 :CSubConnectionProviderBase(aFactory,aActivityMap)
    44 :CSubConnectionProviderBase(aFactory,aActivityMap)
    51 	{
    45 	{
    52 	LOG_NODE_CREATE(KCoreSCPRSubTag, CCoreSubConnectionProvider);
    46 	LOG_NODE_CREATE(KCoreSCPRSubTag, CCoreSubConnectionProvider);
    60 
    54 
    61 EXPORT_C CCoreSubConnectionProvider* CCoreSubConnectionProvider::NewL(CSubConnectionProviderFactoryBase& aFactory)
    55 EXPORT_C CCoreSubConnectionProvider* CCoreSubConnectionProvider::NewL(CSubConnectionProviderFactoryBase& aFactory)
    62 	{
    56 	{
    63     CCoreSubConnectionProvider* provider = new (ELeave) CCoreSubConnectionProvider(aFactory);
    57     CCoreSubConnectionProvider* provider = new (ELeave) CCoreSubConnectionProvider(aFactory);
    64     CleanupStack::PushL(provider);
    58     CleanupStack::PushL(provider);
    65     provider->ConstructL(KSCPRPreallocatedActivityBufferSize);
    59     provider->ConstructL();
    66     CleanupStack::Pop();
    60     CleanupStack::Pop();
    67     return provider;
    61     return provider;
    68 	}
    62 	}
    69 
    63 
    70 EXPORT_C CCoreSubConnectionProvider::~CCoreSubConnectionProvider()
    64 EXPORT_C CCoreSubConnectionProvider::~CCoreSubConnectionProvider()