111 NODEACTIVITY_END() |
111 NODEACTIVITY_END() |
112 } |
112 } |
113 |
113 |
114 namespace PDPSCprGoneDownActivity |
114 namespace PDPSCprGoneDownActivity |
115 { |
115 { |
116 DECLARE_DEFINE_NODEACTIVITY(ECFActivityGoneDown, goneDown, TPDPFSMMessages::TPDPFSMMessage) |
116 DECLARE_DEFINE_NODEACTIVITY(ECFActivityGoneDown, goneDown, TPDPMessages::TPDPFSMMessage) |
117 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingPDPContextGoneDown, MeshMachine::TActiveOrNoTag<ECFActivityStartDataClient>) |
117 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingPDPContextGoneDown, MeshMachine::TActiveOrNoTag<ECFActivityStartDataClient>) |
118 THROUGH_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TSendGoneDown, CoreNetStates::TNoTagOrNoDataClientsToStop) |
118 THROUGH_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TSendGoneDown, CoreNetStates::TNoTagOrNoDataClientsToStop) |
119 NODEACTIVITY_ENTRY(KNoTag, SCprStates::TStopYourFlows, CoreNetStates::TAwaitingDataClientStopped, MeshMachine::TTag<CoreNetStates::KNoDataClientsToStop>) |
119 NODEACTIVITY_ENTRY(KNoTag, SCprStates::TStopYourFlows, CoreNetStates::TAwaitingDataClientStopped, MeshMachine::TTag<CoreNetStates::KNoDataClientsToStop>) |
120 |
120 |
121 LAST_NODEACTIVITY_ENTRY(KActiveTag, CoreNetStates::TCancelDataClientStart) //MZTODO: This triple should wait for TError sent as a response to TCancel |
121 LAST_NODEACTIVITY_ENTRY(KActiveTag, CoreNetStates::TCancelDataClientStart) //MZTODO: This triple should wait for TError sent as a response to TCancel |
151 NODEACTIVITY_END() |
151 NODEACTIVITY_END() |
152 } |
152 } |
153 |
153 |
154 namespace PDPSCprParamsChanged |
154 namespace PDPSCprParamsChanged |
155 { |
155 { |
156 DECLARE_DEFINE_NODEACTIVITY(ECFActivityParamRequest, paramsChanged, TPDPFSMMessages::TPDPFSMMessage) |
156 DECLARE_DEFINE_NODEACTIVITY(ECFActivityParamRequest, paramsChanged, TPDPMessages::TPDPFSMMessage) |
157 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingParamsChanged, PDPSCprStates::TNoTagOrError) |
157 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingParamsChanged, PDPSCprStates::TNoTagOrError) |
158 LAST_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TRaiseParamsChanged) |
158 LAST_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TRaiseParamsChanged) |
159 LAST_NODEACTIVITY_ENTRY(KErrorTag, PDPSCprStates::TRaiseParamsRejectedL) |
159 LAST_NODEACTIVITY_ENTRY(KErrorTag, PDPSCprStates::TRaiseParamsRejectedL) |
160 NODEACTIVITY_END() |
160 NODEACTIVITY_END() |
161 } |
161 } |
162 |
162 |
163 namespace PDPSCprContextBlockedUnblockedActivity |
163 namespace PDPSCprContextBlockedUnblockedActivity |
164 { |
164 { |
165 DECLARE_DEFINE_NODEACTIVITY(ECFActivityParamRequest, ctxBlockedUnblocked, TPDPFSMMessages::TPDPFSMMessage) |
165 DECLARE_DEFINE_NODEACTIVITY(ECFActivityParamRequest, ctxBlockedUnblocked, TPDPMessages::TPDPFSMMessage) |
166 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingContextBlockedOrUnblocked, MeshMachine::TNoTag) |
166 FIRST_NODEACTIVITY_ENTRY(PDPSCprStates::TAwaitingContextBlockedOrUnblocked, MeshMachine::TNoTag) |
167 THROUGH_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TForwardContextBlockedOrUnblockedToDC, PDPSCprStates::TBlockedOrUnblocked) |
167 THROUGH_NODEACTIVITY_ENTRY(KNoTag, PDPSCprStates::TForwardContextBlockedOrUnblockedToDC, PDPSCprStates::TBlockedOrUnblocked) |
168 LAST_NODEACTIVITY_ENTRY(PDPSCprStates::KBlocked, PDPSCprStates::TSendDataTransferTemporarilyBlocked) |
168 LAST_NODEACTIVITY_ENTRY(PDPSCprStates::KBlocked, PDPSCprStates::TSendDataTransferTemporarilyBlocked) |
169 /** |
169 /** |
170 This needs to send DataTransferUnblocked progress, but this needs to be discussed with people in finland |
170 This needs to send DataTransferUnblocked progress, but this needs to be discussed with people in finland |
290 User::LeaveIfError(ctx.iReturn); |
290 User::LeaveIfError(ctx.iReturn); |
291 } |
291 } |
292 |
292 |
293 void CPDPSubConnectionProvider::Event(TInt aEvent, TInt aParam) |
293 void CPDPSubConnectionProvider::Event(TInt aEvent, TInt aParam) |
294 { |
294 { |
295 TPDPFSMMessages::TPDPFSMMessage msg(aEvent, aParam); |
295 TPDPMessages::TPDPFSMMessage msg(aEvent, aParam); |
296 |
296 |
297 RClientInterface::OpenPostMessageClose(TNodeCtxId(iActivityAwaitingResponse, Id()), Id(), msg); |
297 RClientInterface::OpenPostMessageClose(TNodeCtxId(iActivityAwaitingResponse, Id()), Id(), msg); |
298 iActivityAwaitingResponse = KActivityNull; |
298 iActivityAwaitingResponse = KActivityNull; |
299 } |
299 } |
300 |
300 |