diff options
author | chriszero <zerov83@gmail.com> | 2014-11-17 21:38:09 +0100 |
---|---|---|
committer | chriszero <zerov83@gmail.com> | 2014-11-17 21:38:09 +0100 |
commit | fc243d8bfde7c24168b67f90341e7d0d114114b2 (patch) | |
tree | c8756fd61712d63801f2085959ac1b9468533af6 /SubscriptionManager.cpp | |
parent | 23f9f7712bfa33b5a488a447a6fabe6035cc3240 (diff) | |
download | vdr-plugin-plex-fc243d8bfde7c24168b67f90341e7d0d114114b2.tar.gz vdr-plugin-plex-fc243d8bfde7c24168b67f90341e7d0d114114b2.tar.bz2 |
Removed c++11 dependency
Diffstat (limited to 'SubscriptionManager.cpp')
-rw-r--r-- | SubscriptionManager.cpp | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/SubscriptionManager.cpp b/SubscriptionManager.cpp index 47f917d..c3e97b6 100644 --- a/SubscriptionManager.cpp +++ b/SubscriptionManager.cpp @@ -18,36 +18,37 @@ SubscriptionManager::SubscriptionManager() } void SubscriptionManager::Notify() { - mutex.lock(); + //mutex.lock(); //TODO: Implement - for(auto subs : m_mSubcribers) { - subs.second.SendUpdate(GetMsg(std::to_string(subs.second.m_iCommandId)), false); + for(std::map<std::string, Subscriber>::iterator it = m_mSubcribers.begin() ; it != m_mSubcribers.end(); ++it) { + Subscriber subs = it->second; + subs.SendUpdate(GetMsg(std::string(itoa(subs.m_iCommandId))), false); } - mutex.unlock(); + //mutex.unlock(); } void SubscriptionManager::AddSubscriber(Subscriber subs) { - mutex.lock(); + //mutex.lock(); m_mSubcribers[subs.GetUuid()] = subs; std::cout << "AddSubscriber: " << subs.to_string() << std::endl; - mutex.unlock(); + //mutex.unlock(); } void SubscriptionManager::RemoveSubscriber(std::string uuid) { - mutex.lock(); + //mutex.lock(); if(m_mSubcribers.find(uuid) != m_mSubcribers.end()) { m_mSubcribers.erase(uuid); } - mutex.unlock(); + //mutex.unlock(); } std::string SubscriptionManager::GetMsg(std::string commandId) { PlayerGetCurrentPosition(); int time = PlayerCurrent; - bool paused = PlayerPaused; + //bool paused = PlayerPaused; std::stringstream msg; msg << "<?xml version=\"1.0\" encoding=\"utf-8\"?>" @@ -93,7 +94,7 @@ void Subscriber::SendUpdate(std::string msg, bool isNav) { pRequest->add("X-Plex-Provides", "player"); pRequest->add("X-Plex-Version", "0.0.1a"); - auto session = new Poco::Net::HTTPClientSession(m_sHost, m_iPort); + Poco::Net::HTTPClientSession* session = new Poco::Net::HTTPClientSession(m_sHost, m_iPort); std::ostream& oustr = session->sendRequest(*pRequest); oustr << msg; } |