ps_inbuffer.h

/*
 * Developer : Alexey Zakharov (alexey.zakharov@vectioneer.com)
 * All rights reserved. Copyright (c) 2015 VECTIONEER.
 */
 
#ifndef PS_INBUFFER_H
#define PS_INBUFFER_H
 
#include "ps_datacontainer.h"
#include "utl_buffer.h"
 
namespace mcx {
 
namespace parameter_server {
 
class InputBuffer : public utils::MpmcQueue<DataContainer> {
public:
  explicit InputBuffer(uint32_t buffer_size);
 
  ~InputBuffer() override;
 
  bool allocate(uint32_t element_size);
 
  void deallocate();
 
  InputBuffer(const InputBuffer&) = delete;
 
  InputBuffer& operator=(const InputBuffer&) = delete;
};
 
} // namespace parameter_server
 
} // namespace mcx
 
#endif /* PS_INBUFFER_H */