From 028ddc8e576e78d500f1cba443d7e21401130bb6 Mon Sep 17 00:00:00 2001 From: Gluzskiy Alexandr Date: Thu, 11 Aug 2016 08:54:06 +0300 Subject: server: event_system: draft implementation of repeated events (we still have none defined by protcol) more appropriate names for some enums and structs messaging: a bit of refactoring in server_session (cut message handler to separate functions for each message type) more appropriate names for some functions curl_downloader: updating downloaded size variable during download process (thread safety required) --- server/include/server_session.h | 19 +++++++++++++++---- 1 file changed, 15 insertions(+), 4 deletions(-) (limited to 'server/include/server_session.h') diff --git a/server/include/server_session.h b/server/include/server_session.h index c0220f0..13f60fd 100644 --- a/server/include/server_session.h +++ b/server/include/server_session.h @@ -49,15 +49,26 @@ public: protected: private: server_session(const server_session&) = delete; - // net + // lowlevel net void handle_read(const boost::system::error_code& error, size_t bytes_transferred); void handle_write(const boost::system::error_code& error); void handle_write_no_read(const boost::system::error_code& error); void handle_handshake(const boost::system::error_code& error); - bool handle_command(client_msg* msg); //TODO: thread safety ? - void send_download_list(); - + //message handlers + //TODO: thread safety ? + bool handle_message(client_msg* msg); + bool handle_auth_request(client_msg *msg); + bool handle_modules_request(client_msg *msg); + bool handle_core_info_request(client_msg *msg); + bool handle_downloads_list_request(); + bool handle_download_info_request(client_msg *msg); + bool handle_download_add_request(client_msg *msg); + bool handle_download_start_request(client_msg *msg); + bool handle_download_stop_request(client_msg *msg); + bool handle_download_delete_request(client_msg *msg); + bool handle_subscription_request(client_msg *msg); + char* recv_data_ = nullptr; socket_wraper* socket_ = nullptr; boost::asio::io_service& io_service_; -- cgit v1.2.3