error_delivery.hpp

Go to the documentation of this file.

 
#ifndef ERROR_DELIVERY_HPP_INCLUDED
#define ERROR_DELIVERY_HPP_INCLUDED
 
#include <cstddef> // std::size_t
#include <utility> // std::move
 
#include <system_error>
#include <ostream>
#include <string>
#include <chrono>
 
#include "net_ip/basic_io_interface.hpp"
#include "net_ip/net_ip_error.hpp"
 
#include "queue/wait_queue.hpp"
 
 
namespace chops {
namespace net {
 
struct error_data {
  std::chrono::steady_clock::time_point   time_p;
  const void*                             io_intf_ptr;
  std::error_code                         err;
 
  error_data(const void* iop, std::error_code e) : 
      time_p(std::chrono::steady_clock::now()), io_intf_ptr(iop), err(std::move(e)) { }
};
 
using err_wait_q = chops::wait_queue<error_data>;
 
template <typename IOT>
auto make_error_func_with_wait_queue(err_wait_q& wq) {
  return [&wq] (basic_io_interface<IOT> io, std::error_code e) {
    wq.emplace_push(io.get_ptr(), e);
  };
}
 
inline std::size_t ostream_error_sink_with_wait_queue (err_wait_q& wq, std::ostream& os) {
  std::size_t cnt = 0;
  while (true) {
    auto elem = wq.wait_and_pop();
    if (!elem) {
      break;
    }
 
    auto t =
      std::chrono::duration_cast<std::chrono::milliseconds>((*elem).time_p.time_since_epoch()).count();
 
    os << '[' << t << "] io_addr: " << elem->io_intf_ptr << " err: " << 
          elem->err << ", " << (*elem).err.message() << '\n';
    ++cnt;
  }
  os.flush();
  return cnt;
}
 
} // end net namespace
} // end chops namespace
 
#endif