summaryrefslogtreecommitdiff
path: root/server/src
diff options
context:
space:
mode:
Diffstat (limited to 'server/src')
-rw-r--r--server/src/api_core_events.cpp47
-rw-r--r--server/src/main.cpp6
-rw-r--r--server/src/server.cpp6
-rw-r--r--server/src/server_session.cpp2
4 files changed, 54 insertions, 7 deletions
diff --git a/server/src/api_core_events.cpp b/server/src/api_core_events.cpp
index 0259973..525f60b 100644
--- a/server/src/api_core_events.cpp
+++ b/server/src/api_core_events.cpp
@@ -23,14 +23,57 @@
#include "api_core_events.h"
#include "server_session.h"
+#include "utilities.h"
+#include "../../protocol/udm.pb.h"
+#include "api_module_base.h"
+#include <boost/log/trivial.hpp>
-extern std::list<server_session*> sessions;
+extern lockable_container<std::list<server_session*> > sessions;
+extern lockable_container<std::map<int, download_internal_s> > downloads;
namespace core_events
{
-void core_events::download_state_changed(int download_id, download_state state)
+void core_events::download_state_changed(module_base *m, std::list<download_state_info> state_list) //TODO: multiple downloads at once should be supported
{
+ //TODO: redesign, very unefficient implementation (reverse search in downloads list should be eleminated)
+ server_msg msg;
+ msg.set_type(SERVER_MSG_TYPE::SERVER_DOWNLOAD_STATE_CHANGE);
+ downloads.lock();
+ for(auto s : state_list)
+ {
+ for(auto d : downloads)
+ {
+ if(d.second.module_name == m->get_module_info().name)
+ {
+ if(s.download_id == d.second.module_id)
+ {
+ download_state_change *sc =msg.add_download_state_changes();
+ sc->set_download_id(d.first);
+ switch(s.state)
+ {
+ case download_state::download_stopped:
+ sc->set_state(SUBSCRIPTION_DOWNLOAD_STATE::SDS_STOPPED);
+ break;
+ case download_state::download_running:
+ sc->set_state(SUBSCRIPTION_DOWNLOAD_STATE::SDS_STARTED);
+ break;
+ default:
+ BOOST_LOG_TRIVIAL(debug)<<__FILE__<<":"<<__LINE__<<"\t"<<__func__<<"\nunhandled download state change event";
+ break;
+
+ }
+ }
+ }
+ }
+ }
+ downloads.unlock();
+ sessions.lock();
+ for(auto p : sessions)
+ {
+ p->fire_event(SUBSCRIPTION_TYPE::ST_DOWNLOAD_STATE_CHANGE, msg);
+ }
+ sessions.unlock();
}
};
diff --git a/server/src/main.cpp b/server/src/main.cpp
index 47dba02..b45ce8f 100644
--- a/server/src/main.cpp
+++ b/server/src/main.cpp
@@ -41,13 +41,13 @@ modules_handler *modules = nullptr;
namespace bpo = boost::program_options;
-std::map<std::string, client*> clients; //auth token used for key
+lockable_container<std::map<std::string, client*> > clients; //auth token used for key
runtime_config_s runtime_config;
-std::map<int, download_internal_s> downloads;
+lockable_container<std::map<int, download_internal_s> > downloads;
-std::list<server_session*> sessions; //sessions to access from apis for modules, should be mutex guarded fro thread safety
+lockable_container<std::list<server_session*> > sessions; //sessions to access from apis for modules, should be mutex guarded fro thread safety
server *serv = nullptr;
diff --git a/server/src/server.cpp b/server/src/server.cpp
index 3c769d3..ef60cf4 100644
--- a/server/src/server.cpp
+++ b/server/src/server.cpp
@@ -28,7 +28,7 @@
#include "../../protocol/udm.pb.h"
#include "socket_wraper.h"
-extern std::list<server_session*> sessions;
+extern lockable_container<std::list<server_session*> > sessions;
@@ -51,7 +51,9 @@ server::server(boost::asio::io_service& io_service,runtime_config_s &config, std
void server::start_accept()
{
server_session* new_session = new server_session(io_service_, runtime_config, clients, downloads);
+ sessions.lock();
sessions.push_back(new_session);
+ sessions.unlock();
if(runtime_config.config_file.get<bool>("server.enable_encryption", false))
acceptor_.async_accept(new_session->socket()->get_ssl_socket().lowest_layer(), boost::bind(&server::handle_accept, this, new_session, boost::asio::placeholders::error));
else
@@ -67,9 +69,11 @@ void server::handle_accept(server_session* new_session, const boost::system::err
else
{
//TODO: implement thread safety ?
+ sessions.lock();
auto s = std::find(sessions.begin(), sessions.end(), new_session);
if(s != sessions.end())
sessions.erase(s);
+ sessions.unlock();
delete new_session;
}
start_accept();
diff --git a/server/src/server_session.cpp b/server/src/server_session.cpp
index 5a15e5b..bfab451 100644
--- a/server/src/server_session.cpp
+++ b/server/src/server_session.cpp
@@ -30,7 +30,7 @@
#include "event_subscription_event.h"
#include "event_subscription_repeated.h"
-extern std::map<std::string, client> clients;
+extern lockable_container<std::map<std::string, client*> > clients;
extern modules_handler *modules;