cm_rpctypes.h

/*
 * Developer : Alexey Zakharov (alexey.zakharov@vectioneer.com)
 * All rights reserved. Copyright (c) 2018 VECTIONEER.
 */
 
#ifndef MOTORCORTEX_CORE_CM_RPCTYPES_H
#define MOTORCORTEX_CORE_CM_RPCTYPES_H
 
#include "ps_types.h"
 
#include <set>
#include <atomic>
#include <thread>
#include <nng/nng.h>
 
namespace mcx::comm {
 
typedef std::set<uint32_t> MsgHashSet;
 
enum class RequestFlags {
  USER_HAS_CONTROL = 1,
};
 
struct RequestMsg {
  bool client_has_control;
  parameter_server::UserGroup user_group;
  uint8_t* msg;
  size_t size;
  uint32_t hash;
  uint32_t client_id;
};
 
struct ReplyMsg {
  size_t size;
  nng_msg* msg;
  uint8_t* body;
};
 
enum class ReplyState {
  EMPTY = 0,
  PROCESSING,
  READY,
  ERROR,
  TIMEOUT
};
 
struct ReplyHandle {
  std::atomic<ReplyState> state;
  uint32_t id;
};
 
ReplyMsg allocateMsgMem(size_t size);
 
ReplyMsg duplicateMsgMem(ReplyMsg msg);
 
ReplyMsg reallocateMsgMem(ReplyMsg msg_mem, size_t size);
 
void deallocateMsgMem(ReplyMsg msg_mem);
 
}  // namespace mcx::comm
 
#endif //MOTORCORTEX_CORE_CM_RPCTYPES_H