X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fnetwork%2Fserver.h;h=50c0f72fae98d6ac2a0f0ce00e7d49a9b194ad02;hb=b36f3dc43853c76b4710cb1a7b932a758e1693a1;hp=16022ba9d12664596ac4d19aec2881c8d985ca0f;hpb=d15ac13f2e170f155b4bbd124df48400c339b644;p=r2c2.git diff --git a/source/network/server.h b/source/network/server.h index 16022ba..50c0f72 100644 --- a/source/network/server.h +++ b/source/network/server.h @@ -4,9 +4,9 @@ #include #include #include -#include +#include #include "libr2c2/layout.h" -#include "libr2c2/trainstatus.h" +#include "libr2c2/trainai.h" #include "packets.h" #include "protocol.h" @@ -34,28 +34,30 @@ private: virtual void receive(const TrainControlPacket &); virtual void receive(const TrainFunctionPacket &); virtual void receive(const TrainRoutePacket &); + void comm_error(const std::exception &); void error(const std::string &); }; Protocol proto; Layout &layout; - Msp::Net::StreamListenSocket listen_sock; + Msp::Net::StreamServerSocket listen_sock; Msp::IO::EventDispatcher *event_disp; std::vector connections; public: Server(Layout &); + ~Server(); + void use_event_dispatcher(Msp::IO::EventDispatcher &); private: void incoming_connection(); void driver_state_changed(); - void emergency(const std::string &); + void emergency(Block *, const std::string &); void train_added(Train &); void train_control_changed(const Train &, const std::string &, float); void train_function_changed(const Train &, unsigned, bool); - void train_route_changed(const Train &, const Route *); - void train_status_changed(const Train &, const std::string &); + void train_ai_event(const Train &, TrainAI &, const TrainAI::Message &); template void send(const P &);