#ifndef ucoolib_arch_host_mex_mex_node_hh #define ucoolib_arch_host_mex_mex_node_hh // ucoolib - Microcontroller object oriented library. {{{ // // Copyright (C) 2012 Nicolas Schodet // // APBTeam: // Web: http://apbteam.org/ // Email: team AT apbteam DOT org // // 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 2 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, write to the Free Software // Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. // // }}} #include "ucoolib/common.hh" #include "mex_msg.hh" #include "mex_socket.hh" #include #include #include namespace ucoo { namespace mex { class Node; /// Abstract message reception handler. class Handler { public: /// Handle a received message or request. virtual void handle (Msg &msg) = 0; }; /// Helper class for member function reception handler. template class HandlerMemfun : public Handler { public: HandlerMemfun (T &obj, void (T::*f) (Msg &)) : obj_ (obj), f_ (f) { } void handle (Msg &msg) { (obj_.*f_) (msg); } private: T &obj_; void (T::*f_) (Msg &); }; /// Helper class for static function reception handler. class HandlerPtrfun : public Handler { public: HandlerPtrfun (void (*f) (Msg &)) : f_ (f) { } void handle (Msg &msg) { f_ (msg); } private: void (*f_) (Msg &); }; /// Mex node, singleton. class Node { public: /// Connect to mex hub. Node (); /// Disconnect. ~Node (); /// Get single instance, may return NULL if none constructed. static Node *instance () { return instance_; } /// Wait forever. void wait (); /// Wait until date is reached. void wait (uint32_t date); /// Return current date. uint32_t date () const { return date_; } /// Send a message. void send (Msg &msg); /// Send a request and return response. std::auto_ptr request (Msg &msg); /// Send a response while handling a request. void response (Msg &msg); /// Reserve a message type. mtype_t reserve (const std::string &name); /// Register an handler for a message type. void handler_register (mtype_t mtype, Handler &handler); private: /// Receive one message. std::auto_ptr recv (); /// Dispatch message to the right handler. void dispatch (Msg &msg); /// Handle an incomming DATE message. void handle_date (Msg &msg); /// Handle an incomming REQ message. void handle_req (Msg &msg); private: /// Pointer to single instance. static Node *instance_; /// Connection to hub. Socket socket_; /// Current date. uint32_t date_; /// When handling a request, this is the request identifier, else -1. int req_; /// Registered handlers. typedef std::map handlers_type; handlers_type handlers_; /// Handlers objects. HandlerMemfun handler_date, handler_req; }; } // namespace mex } // namespace ucoo #endif // ucoolib_arch_host_mex_mex_node_hh