TableScannerDispatchHandler.cc

Go to the documentation of this file.

#include "Common/Compat.h"
#include "AsyncComm/Protocol.h"

#include "Common/Error.h"
#include "Common/Logger.h"

#include "TableScannerDispatchHandler.h"
#include "TableScannerHandler.h"

using namespace Hypertable;
using namespace Serialization;

TableScannerDispatchHandler::TableScannerDispatchHandler(
  ApplicationQueueInterfacePtr &app_queue, TableScannerAsync *scanner, int interval_scanner,
  bool is_create)
  : m_app_queue(app_queue), m_scanner(scanner), m_interval_scanner(interval_scanner),
    m_is_create(is_create) {
}



void TableScannerDispatchHandler::handle(EventPtr &event) {
  // Create TableScannerHandler and add task to application queue
  m_app_queue->add(new TableScannerHandler(m_scanner, m_interval_scanner, event, m_is_create));
}