ps_actbuffer.h

/*
 * Developer : Alexey Zakharov (alexey.zakharov@vectioneer.com)
 * All rights reserved. Copyright (c) 2015 VECTIONEER.
 */
 
#ifndef PS_ACTBUFFER_H
#define PS_ACTBUFFER_H
 
#include "utl_buffer.h"
#include <string>
 
namespace mcx {
 
namespace parameter_server {
 
class Parameter;
 
enum ActionType {
  NONE = 0,
  START_PUBLISH,
  STOP_PUBLISH,
  PUBLISH_ONCE,
  NEW_VALUE,
  OVERWRITE_OUTPUT,
  OVERWRITE_INPUT,
  ACTIVATE_OVERWRITE_OUTPUT,
  ACTIVATE_OVERWRITE_INPUT,
  DEACTIVATE_OVERWRITE,
  ACTIVATE_LINK,
  DEACTIVATE_LINK,
};
 
struct Action {
  ActionType type;
  Parameter* param;
};
 
class ActionBuffer {
public:
  ActionBuffer();
 
  virtual ~ActionBuffer();
 
  void setName(const char* name);
 
  void allocate(uint32_t element_size);
 
  void deallocate();
 
  bool push(const Action& new_action);
 
  bool pull(Action& action);
 
  bool isEmpty();
 
  ActionBuffer(const ActionBuffer&) = delete;
 
  ActionBuffer& operator=(const ActionBuffer&) = delete;
 
private:
  utils::MpmcQueue<Action>* queue_;
  uint32_t counter_;
  std::string name_;
};
 
} // namespace parameter_server
 
} // namespace mcx
 
#endif /* PS_INBUFFER_H */