manes/ods/call_serializer.h

   1 #ifndef _CALL_SERIALIZER_H_
   2 #define _CALL_SERIALIZER_H_
   3
   4 #include "obj_ref.h"
   5 #include "obj_val.h"
   6
   7 #include "libs/pointer.h"
   8 #include "libs/buffer.h"
   9
  10 namespace manes {
  11         namespace ods {
  12                 /**
  13                  * @brief Remote procedure call
  14                  *
  15                  * Instances of this class contains serialized data required
  16                  * to perform a rpc.
  17                  */
  18                 class rpc_call : public serialized_object {
  19                         virtual ~rpc_call() {}
  20                 };
  21
  22                 /**
  23                  * @brief Functor
  24                  *
  25                  * @details Instances of this class carries all data needed
  26                  * to perform a procedure call invoked by the client. They are
  27                  * used to represent deserialized remote procedure calls.
  28                  */
  29                 class foreign_call {
  30                 public:
  31                         typedef unsigned int ret_val;
  32
  33                         /**
  34                          * Invokes functor
  35                          *
  36                          * This member function invokes procedure call requested
  37                          * by the client.
  38                          */
  39                         virtual ret_val operator()() = 0;
  40                 };
  41
  42                 /**
  43                  * @brief Call serializer
  44                  *
  45                  * @details This is a base class for all serializers able to
  46                  * marshall procedure invocation.
  47                  */
  48                 class call_serializer {
  49                 public:
  50                         /**
  51                          * Serialize procedure call
  52                          * @param mid method identifier
  53                          * @param stk part of stack coinatining invocation arguments
  54                          * @return marshalled, ready to sent, data
  55                          */
  56                         virtual p<rpc_call> serialize(ods_endpoint::method_id mid, ods_endpoint::stack stk) = 0;
  57
  58                         /**
  59                          * Deserialize procedure call
  60                          * @param buf serialized procedure call
  61                          * @return functor performing rpc
  62                          */
  63                         virtual foreign_call deserialize(p<rpc_call> buf) = 0;
  64
  65                 };
  66         }
  67 }
  68
  69 #endif