Method ValidateCellValueTest

src/observer/test/observer_test.cc:534–611

  }

  void ValidateCellValueTest() {
    tera::ErrorCode err;
    std::unique_ptr<tera::Client> client(tera::Client::NewClient(FLAGS_flagfile, &err));
    // for ut test
    EXPECT_EQ(tera::ErrorCode::kOK, err.GetType());
    // for no core
    if (tera::ErrorCode::kOK != err.GetType()) {
      LOG(ERROR) << "new client failed";
      return;
    }

    common::ThreadPool thread_pool(5);
    ScannerImpl* scanner = new ScannerImpl();
    scanner->key_selector_.reset(new RandomKeySelector());
    std::unique_ptr<Table> table(client->OpenTable("observer_test_table", &err));

    Observer* observer = new TestWorker();
    bool ret = scanner->Init();
    EXPECT_EQ(true, ret);
    if (!ret) {
      LOG(ERROR) << "fail to init scanner_impl";
      return;
    }
    err = scanner->Observe("observer_test_table", "Data", "Page", observer);
    EXPECT_EQ(err.GetType(), tera::ErrorCode::kOK);

    ScannerImpl::NotificationContext* context = new ScannerImpl::NotificationContext();
    common::Semaphore s(1);
    s.Acquire();
    std::shared_ptr<NotifyCell> notify_cell(new NotifyCell(s));
    context->notify_cell = notify_cell;
    Column column = {"observer_test_table", "Data", "qu"};
    notify_cell->row = "row";
    notify_cell->observed_column = column;
    notify_cell->table = table.get();

    // no value
    RowReader* row_reader(table->NewRowReader("no_row"));
    row_reader->SetContext(context);
    row_reader->AddColumn("Data", "qu");
    table->Get(row_reader);
    scanner->ValidateCellValue(row_reader);
    sleep(1);
    EXPECT_FALSE(static_cast<TestWorker*>(observer)->notified_);

    // no table
    table->Put("row1", "Data", "qu", "value", &err);
    if (err.GetType() != tera::ErrorCode::kOK) {
      LOG(ERROR) << "put error: " << err.GetReason();
      return;
    }
    row_reader = table->NewRowReader("row1");
    context = new ScannerImpl::NotificationContext();
    context->notify_cell = notify_cell;
    notify_cell->row = "row 1";

    row_reader->SetContext(context);
    table->Get(row_reader);