|
1 // Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies). |
|
2 // All rights reserved. |
|
3 // This component and the accompanying materials are made available |
|
4 // under the terms of "Eclipse Public License v1.0" |
|
5 // which accompanies this distribution, and is available |
|
6 // at the URL "http://www.eclipse.org/legal/epl-v10.html". |
|
7 // |
|
8 // Initial Contributors: |
|
9 // Nokia Corporation - initial contribution. |
|
10 // |
|
11 // Contributors: |
|
12 // |
|
13 // Description: |
|
14 // |
|
15 |
|
16 /** |
|
17 @file |
|
18 @internalTechnology |
|
19 @released |
|
20 */ |
|
21 |
|
22 #if !defined(__ES_SAP_H__) |
|
23 #define __ES_SAP_H__ |
|
24 |
|
25 #define SYMBIAN_NETWORKING_UPS |
|
26 |
|
27 #include <es_prot.h> |
|
28 #include <es_sock.h> |
|
29 #include <comms-infras/ss_subconnflow.h> |
|
30 #include <comms-infras/ss_flowbinders.h> |
|
31 #include <comms-infras/ss_nodemessages_dataclient.h> |
|
32 |
|
33 namespace ESock |
|
34 { |
|
35 |
|
36 class CNetworkFlow : public CSubConnectionFlowBase, protected MSessionData, protected MSessionControl, |
|
37 protected MFlowBinderControl |
|
38 /** Service Access Point for SAPs that have a seperate control side. |
|
39 |
|
40 Provides transport services to a single protocol. Several of the calls to |
|
41 CServProviderBase have pre-conditions attached to them - for example |
|
42 a connection oriented protocol must have its local address set (either by |
|
43 a SetLocalName() or AutoBind()) before it is opened. If the socket server |
|
44 calls the CServProviderBase in such an erroneous way, the protocol should panic. |
|
45 |
|
46 It also provides an interface towards subconnection providers to allow |
|
47 SAPs to work with a seperate control path. |
|
48 |
|
49 @internalTechnology |
|
50 @released Since 9.0 */ |
|
51 { |
|
52 friend class ProtocolManager; |
|
53 public: |
|
54 |
|
55 IMPORT_C virtual ~CNetworkFlow(); |
|
56 |
|
57 protected: |
|
58 void SetLocalName(TSockAddr& anAddr); |
|
59 TInt SetRemName(TSockAddr& anAddr); |
|
60 TUint Write(const TDesC8& aDesc,TUint aOptions, TSockAddr* anAddr); |
|
61 TInt Write(RMBufChain& aData, TUint aOptions, TSockAddr* anAddr); |
|
62 void BindToL(const TCFDataClient::TBindTo& aBindTo); |
|
63 NetInterfaces::TInterfaceControl* FetchInterfaceControlL(TSupportedCommsApiExt aInterfaceId); |
|
64 |
|
65 protected: |
|
66 |
|
67 virtual MFlowBinderControl* DoGetBinderControlL(); |
|
68 //MFlowBinderControl |
|
69 virtual MSessionControl* GetControlL(TInt aSessionType,MSessionControlNotify& aSessionControlNotify); |
|
70 virtual void Unbind(); |
|
71 virtual MSessionData* BindL(MSessionDataNotify& aNotify); |
|
72 virtual CSubConnectionFlowBase* Flow(); //returns its own flow |
|
73 |
|
74 TBool IsBoundToSession() const |
|
75 { |
|
76 return iSessionControlNotify || iSessionDataNotify; |
|
77 } |
|
78 |
|
79 void ProcessDCIdleState(); |
|
80 |
|
81 #ifdef SYMBIAN_NETWORKING_UPS |
|
82 virtual TBool ActivityRunning() = 0; |
|
83 #else |
|
84 inline TBool NoBearerGuard() |
|
85 { return iNoBearerRunning; } |
|
86 inline void SetNoBearerGuard() |
|
87 { iNoBearerRunning = ETrue; } |
|
88 inline void ClearNoBearerGuard() |
|
89 { iNoBearerRunning = EFalse; } |
|
90 #endif |
|
91 |
|
92 protected: |
|
93 IMPORT_C CNetworkFlow(CSubConnectionFlowFactoryBase& aFactory, const Messages::TNodeId& aSubConn, CProtocolIntfBase* aProtocolIntf); |
|
94 void UpdateDestinationAddress(const TSockAddr& aDest); |
|
95 |
|
96 protected: |
|
97 TSockAddr iLocalAddress; |
|
98 TSockAddr iRemoteAddress; |
|
99 |
|
100 //upper flow |
|
101 MSessionControlNotify* iSessionControlNotify; |
|
102 MSessionDataNotify* iSessionDataNotify; |
|
103 //lower flow |
|
104 MFlowBinderControl* iLowerFlow; |
|
105 MLowerControl* iLowerControl; //just to keep the lower flow up |
|
106 |
|
107 enum TDCIdleState |
|
108 { |
|
109 EClientsPresent = 0, // presumption is we're always created for a client (ie HR or socket) |
|
110 EIdle = 1, |
|
111 EIdleSent = 2 |
|
112 }; |
|
113 TBool iLocalAddressSet:1; |
|
114 TBool iRemoteAddressSet:1; |
|
115 TBool iConnectionInfoSet:1; |
|
116 TBool iJoinOutstanding:1; |
|
117 TBool iLeaveOutstanding:1; |
|
118 #ifndef SYMBIAN_NETWORKING_UPS |
|
119 TBool iNoBearerRunning:1; // NoBearer msg has been issued to SCPR |
|
120 #endif |
|
121 TBool iIsStarted:1; |
|
122 TDCIdleState iDCIdle:2; |
|
123 }; |
|
124 |
|
125 } //namespace ESock |
|
126 |
|
127 #endif // __ES_SAP_H__ |
|
128 |
|
129 |