i am alive )

updated copyrights (new year)
server:
	started implementation of api for module events (module should be able to fire event which will be delivered to clients which have subscribed for this event type)

1 files changed, 4 insertions, 1 deletions

diff --git a/server/src/server_session.cpp b/server/src/server_session.cpp
index a79d5b6..5a15e5b 100644
--- a/server/src/server_session.cpp
+++ b/server/src/server_session.cpp
@@ -1,5 +1,5 @@
 /*
-	Copyright © 2015 Gluzskiy Alexandr (sss)
+	Copyright © 2015-2016 Gluzskiy Alexandr (sss)
 
     This file is part of Unknown Download Manager (UDM).
 
@@ -271,6 +271,7 @@ void add_download_content_menu_element(module_download_menu_element_info_s &elem
 
 bool server_session::handle_command(client_msg *msg)
 {
+	//TODO: thread safety ?
 	if(msg->type() !=  CLIENT_MSG_TYPE::CLIENT_AUTH_REQUEST && clients.find(msg->auth_token()) == clients.end())
 	{
 		BOOST_LOG_TRIVIAL(error)<<"unauthorized client trying to execute command";
@@ -631,6 +632,7 @@ void server_session::send_download_list()
 
 void server_session::send_message(server_msg *msg)
 {
+	//TODO: thread safety
 	int size = 0;
 	std::shared_ptr<char*> ptr = pack_msg(msg, &size);
 	boost::asio::async_write(*socket_, boost::asio::buffer(*ptr, size), boost::bind(&server_session::handle_write, this, boost::asio::placeholders::error));
@@ -653,6 +655,7 @@ void server_session::handle_write(const boost::system::error_code& error)
 
 void server_session::fire_event(SUBSCRIPTION_TYPE type, server_msg &msg)
 {
+	//TODO: thread safety
 	for(auto i : clients)
 	{
 		for(auto s : i.second->get_subscriptions())