datacommsserver/esockserver/CoreProviders/src/corecprstates.cpp
changeset 1 21d2ab05f085
parent 0 dfb7c4ff071f
equal deleted inserted replaced
0:dfb7c4ff071f 1:21d2ab05f085
    19 
    19 
    20 /**
    20 /**
    21  @file
    21  @file
    22  @internalComponent
    22  @internalComponent
    23 */
    23 */
       
    24 
    24 #define SYMBIAN_NETWORKING_UPS
    25 #define SYMBIAN_NETWORKING_UPS
    25 
    26 
    26 #include <comms-infras/ss_log.h>
    27 #include <comms-infras/ss_log.h>
    27 #include <comms-infras/ss_subconnprov.h>
    28 #include <comms-infras/ss_subconnprov.h>
    28 #include <ss_glob.h>
    29 #include <ss_glob.h>
   326 	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCoreCprPanic, KPanicNoActivity));
   327 	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCoreCprPanic, KPanicNoActivity));
   327 	CprBindToActivity::CCprBindToActivity& activity = static_cast<CprBindToActivity::CCprBindToActivity&>(*iContext.iNodeActivity);
   328 	CprBindToActivity::CCprBindToActivity& activity = static_cast<CprBindToActivity::CCprBindToActivity&>(*iContext.iNodeActivity);
   328 	const TCFDataClient::TBindTo& bindToMsg(message_cast<const TCFDataClient::TBindTo>(iContext.iMessage));
   329 	const TCFDataClient::TBindTo& bindToMsg(message_cast<const TCFDataClient::TBindTo>(iContext.iMessage));
   329 
   330 
   330 	__ASSERT_DEBUG(!bindToMsg.iNodeId.IsNull(), User::Panic(KCoreCprPanic, KPanicNoServiceProvider));
   331 	__ASSERT_DEBUG(!bindToMsg.iNodeId.IsNull(), User::Panic(KCoreCprPanic, KPanicNoServiceProvider));
   331 	activity.iNewServiceProvider = iContext.Node().AddClientL(bindToMsg.iNodeId,
   332 
   332 							TClientType(TCFClientType::EServProvider, TCFClientType::EActivating));
   333     RNodeInterface* newServiceProvider = iContext.Node().AddClientL(bindToMsg.iNodeId,
   333 	//Join the new service provider
   334                             TClientType(TCFClientType::EServProvider, TCFClientType::EActivating));
   334 	iContext.iNodeActivity->PostRequestTo(*activity.iNewServiceProvider,
   335     __ASSERT_DEBUG(newServiceProvider, User::Panic(KCoreCprPanic, KPanicNoServiceProvider));
   335 							TCFControlClient::TJoinRequest(iContext.NodeId(), TClientType(TCFClientType::ECtrl), iContext.Node().Priority()).CRef());
   336     activity.iNewServiceProvider = bindToMsg.iNodeId;
       
   337     //Join the new service provider
       
   338     activity.PostRequestTo(*newServiceProvider,
       
   339                             TCFControlClient::TJoinRequest(iContext.NodeId(), TClientType(TCFClientType::ECtrl), iContext.Node().Priority()).CRef());
   336     }
   340     }
   337 
       
   338 }
   341 }
   339 
   342 
   340 EXPORT_DEFINE_SMELEMENT(THandleDataClientIdle, NetStateMachine::MStateTransition, CprStates::TContext)
   343 EXPORT_DEFINE_SMELEMENT(THandleDataClientIdle, NetStateMachine::MStateTransition, CprStates::TContext)
   341 EXPORT_C void THandleDataClientIdle::DoL()
   344 EXPORT_C void THandleDataClientIdle::DoL()
   342 	{
   345 	{