88 OS_EXPORT MmsServerConnectionFactory::~MmsServerConnectionFactory() |
88 OS_EXPORT MmsServerConnectionFactory::~MmsServerConnectionFactory() |
89 { |
89 { |
90 JELOG2(EWMA); |
90 JELOG2(EWMA); |
91 } |
91 } |
92 |
92 |
|
93 ServerConnection& |
|
94 MmsServerConnectionFactory::createPushServerConn(const std::wstring& aUri, |
|
95 const std::wstring& aFilter, |
|
96 ConnectionListener* aListener, |
|
97 PendingConnectionListener* aPendingConnListener) |
|
98 { |
|
99 JELOG2(EWMA); |
|
100 ScopedLock lockObj(mMutex); |
|
101 |
|
102 SrvConnContainerIter_t iter = mServerConnections.find(aUri); |
|
103 if (iter != mServerConnections.end()) |
|
104 { |
|
105 if ((SrvConnContainerData::NORMAL == iter->second.connType())) |
|
106 { |
|
107 LOG(EWMA,EInfo,"Clearing Unregister flag"); |
|
108 MmsServerConnection* serverConn = 0; |
|
109 serverConn = reinterpret_cast<MmsServerConnection*>(iter->second.getConn()); |
|
110 serverConn->clearUnregister(); |
|
111 } |
|
112 } |
|
113 return ServerConnectionFactoryBase::createPushServerConn(aUri,aFilter, |
|
114 aListener,aPendingConnListener); |
|
115 } |
|
116 |
|
117 void MmsServerConnectionFactory::deletePushConnection(const std::wstring& aUri) |
|
118 { |
|
119 JELOG2(EWMA); |
|
120 LOG1(EWMA,EInfo,"MmsServerConnection on ID %S", aUri.c_str()); |
|
121 MmsServerConnection* serverConn = 0; |
|
122 serverConn = reinterpret_cast<MmsServerConnection*>(getPushConnection(aUri)); |
|
123 if (0 != serverConn) |
|
124 serverConn->setUnregister(); |
|
125 ServerConnectionFactoryBase::deletePushConnection(aUri); |
|
126 } |
93 /** |
127 /** |
94 * |
128 * |
95 */ |
129 */ |
96 OS_EXPORT ServerConnection* MmsServerConnectionFactory::createSrvConnObj( |
130 OS_EXPORT ServerConnection* MmsServerConnectionFactory::createSrvConnObj( |
97 const std::wstring& aUri, |
131 const std::wstring& aUri, |