TableScannerHandler.cc

Go to the documentation of this file.

#include "Common/Compat.h"

#include "AsyncComm/Comm.h"

#include "TableScannerHandler.h"
#include "TableScannerAsync.h"

using namespace Hypertable;

void TableScannerHandler::run() {
  int32_t error;
  try {
    switch (m_event->type) {
    case(Event::MESSAGE):
      error = Protocol::response_code(m_event);
      if (error == Error::REQUEST_TIMEOUT)
        m_scanner->handle_timeout(m_interval_scanner, m_event->to_str(), m_is_create);
      else if (error != Error::OK)
        m_scanner->handle_error(m_interval_scanner, error, m_event->to_str(), m_is_create);
      else
        m_scanner->handle_result(m_interval_scanner, m_event, m_is_create);
      break;
    case(Event::TIMER):
      m_scanner->handle_timeout(m_interval_scanner, m_event->to_str(), m_is_create);
      break;
    case(Event::ERROR):
      m_scanner->handle_error(m_interval_scanner, m_event->error, m_event->to_str(),
          m_is_create);
      break;
    default:
      HT_INFOF("Received event %s", m_event->to_str().c_str());
    }
  }
  catch (Exception &e) {
    HT_ERROR_OUT << e << HT_END;
    m_scanner->cancel();
  }
}