//---------------------------------------------------------------------------
/*
WtServerPusher, server to broadcast to all its WtServerPusherClients
Copyright (C) 2011-2015 Richel Bilderbeek
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
//---------------------------------------------------------------------------
//From http://www.richelbilderbeek.nl/CppWtServerPusher.htm
//---------------------------------------------------------------------------
#include <algorithm>
#include <chrono>
#include <numeric>
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Weffc++"
#pragma GCC diagnostic ignored "-Wunused-but-set-parameter"
#pragma GCC diagnostic ignored "-Wunused-local-typedefs"
#include <boost/bind.hpp>
#include <Wt/WApplication>
#include <Wt/WServer>
#include "wtserverpusher.h"
#pragma GCC diagnostic pop
boost::scoped_ptr<ribi::WtServerPusher> ribi::WtServerPusher::m_instance;
ribi::WtServerPusher::WtServerPusher()
: m_connections{},
m_mutex{}
{
}
ribi::WtServerPusher::~WtServerPusher()
{
}
void ribi::WtServerPusher::Connect(
WtServerPusherClient * const client,
const boost::function<void()>& function)
{
std::lock_guard<std::mutex> lock(m_mutex);
boost::shared_ptr<Connection> connection {
new Connection(
Wt::WApplication::instance()->sessionId(),
client,
function
)
};
m_connections.push_back(connection);
}
void ribi::WtServerPusher::Disconnect(const WtServerPusherClient* const client)
{
std::lock_guard<std::mutex> lock(m_mutex);
m_connections.erase(
std::remove_if(m_connections.begin(),m_connections.end(),
[client](const boost::shared_ptr<Connection>& c) { return c->m_client == client; } ));
}
ribi::WtServerPusher * ribi::WtServerPusher::GetInstance()
{
if (!m_instance) m_instance.reset(new WtServerPusher);
return m_instance.get();
}
std::string ribi::WtServerPusher::GetVersion()
{
return "1.0";
}
std::vector<std::string> ribi::WtServerPusher::GetVersionHistory()
{
return {
"2011-08-05: version 1.0: initial version"
};
}
void ribi::WtServerPusher::Post()
{
///Let this thread sleep, to give the other thread a chance
//std::this_thread::sleep_for(std::chrono::milliseconds(10));
std::lock_guard<std::mutex> lock(m_mutex);
for (auto c: m_connections)
{
Wt::WServer::instance()->post(c->m_session_id, c->m_function);
};
}
|
