multipart_stream.h

Go to the documentation of this file.

#ifndef MULTIPART_STREAM_H_
#define MULTIPART_STREAM_H_

#include <ros/ros.h>
#include <async_web_server_cpp/http_connection.hpp>

#include <queue>

namespace web_video_server
{

struct PendingFooter {
  ros::Time timestamp;
  boost::weak_ptr<std::string> contents;
};

class MultipartStream {
public:
  MultipartStream(async_web_server_cpp::HttpConnectionPtr& connection,
                  const std::string& boundry="boundarydonotcross",
                  std::size_t max_queue_size=1);

  void sendInitialHeader();
  void sendPartHeader(const ros::Time &time, const std::string& type, size_t payload_size);
  void sendPartFooter(const ros::Time &time);
  void sendPartAndClear(const ros::Time &time, const std::string& type, std::vector<unsigned char> &data);
  void sendPart(const ros::Time &time, const std::string& type, const boost::asio::const_buffer &buffer,
                async_web_server_cpp::HttpConnection::ResourcePtr resource);

private:
  bool isBusy();

private:
  const std::size_t max_queue_size_;
  async_web_server_cpp::HttpConnectionPtr connection_;
  std::string boundry_;
  std::queue<PendingFooter> pending_footers_;
};

}

#endif