ReportRes.cc

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
#include "swcdb/manager/Protocol/Rgr/req/ReportRes.h"
 
 
namespace SWC { namespace Comm { namespace Protocol {
namespace Rgr { namespace Req {
 
 
SWC_CAN_INLINE
ReportRes::ReportRes(const Manager::Ranger::Ptr& a_rgr)
                    : client::ConnQueue::ReqBase(Buffers::make(1)),
                      rgr(a_rgr) {
  cbp->append_i8(Params::Report::Function::RESOURCES);
  cbp->header.set(REPORT, 60000);
}
 
void ReportRes::handle_no_conn() {
  Env::Mngr::rangers()->rgr_report(
    rgr->rgrid,
    Error::COMM_NOT_CONNECTED,
    Params::Report::RspRes()
  );
}
 
void ReportRes::handle(ConnHandlerPtr, const Event::Ptr& ev) {
  Params::Report::RspRes rsp_params;
  int err = ev->error;
  if(!err) {
    try {
      const uint8_t *ptr = ev->data.base;
      size_t remain = ev->data.size;
 
      err = Serialization::decode_i32(&ptr, &remain);
      if(!err)
        rsp_params.decode(&ptr, &remain);
 
    } catch(...) {
      const Error::Exception& e = SWC_CURRENT_EXCEPTION("");
      SWC_LOG_OUT(LOG_ERROR, SWC_LOG_OSTREAM << e; );
      err = e.code();
    }
  }
  Env::Mngr::rangers()->rgr_report(rgr->rgrid, err, rsp_params);
}
 
 
}}}}}