manes/ods/ods_endpoint.h

   1 #ifndef _ODS_ENDPOINT_H_
   2 #define _ODS_ENDPOINT_H_
   3
   4 namespace manes {
   5         /**
   6          * @brief Object Distribution System
   7          *
   8          * @details ODS is a vital part of Managed Execution System, which
   9          * allows to distribute objects regardless of connection types
  10          * between endpoints.
  11          */
  12         namespace ods {
  13                 /**
  14                  * @brief Endpoint in Object Distribution System
  15                  *
  16                  * @details Instances of this class represent an endpoint of
  17                  * Object Distribution System network. It is in charge
  18                  * of transmitting and receiving both data and
  19                  * procedure calls.
  20                  */
  21                 class ods_endpoint {
  22                 protected:
  23                         /**
  24                          * Serializer of objects transported by value.
  25                          */
  26                         p<data_transmit> data;
  27
  28                         /**
  29                          * Serializer of objects transported by reference.
  30                          */
  31                         p<ref_transmit> ref;
  32
  33                         /**
  34                          * Procedure calls serializer.
  35                          */
  36                         p<call_serializer> caller;
  37
  38                         /**
  39                          * Code injector.
  40                          */
  41                         p<injector> inject_tool;
  42
  43                         /** Default serializers factory */
  44                         typedef binary_serializers default_factory;
  45                 public:
  46                         /** Representation of public methods */
  47                         typedef unsigned int method_id;
  48                         typedef unsigned char* stack;
  49
  50                         /**
  51                          * Catch all calls of objects methods.
  52                          * @param obj observed object
  53                          */
  54                         virtual void inject(p<obj_ref> obj) = 0;
  55
  56                         /**
  57                          * Connect to ODS network
  58                          * @note Subclasses may require additional configuration,
  59                          * before connection will be established.
  60                          */
  61                         virtual void connect() = 0;
  62
  63                         /** Call caught */
  64                         virtual void do_call(method_id, stack) = 0;
  65                 };
  66         }
  67 }
  68
  69 #endif