Method NonTransactionTest

src/observer/test/observer_test.cc:387–460

  }

  void NonTransactionTest() {
    tera::ErrorCode err;
    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;
    }

    // create table
    tera::TableDescriptor table_desc("observer_table_ntx");

    table_desc.AddLocalityGroup("lg1");
    tera::ColumnFamilyDescriptor* cf1 = table_desc.AddColumnFamily("cf", "lg1");
    cf1->EnableNotify();
    ExtendNotifyLgToDescriptor(&table_desc);

    client->CreateTable(table_desc, &err);
    if (err.GetType() != tera::ErrorCode::kOK) {
      LOG(ERROR) << "Create table fail";
      return;
    }

    std::unique_ptr<Table> table(client->OpenTable("observer_table_ntx", &err));
    EXPECT_EQ(tera::ErrorCode::kOK, err.GetType());
    if (tera::ErrorCode::kOK != err.GetType()) {
      LOG(ERROR) << "open table failed";
      return;
    }

    table->Put("www.baidu.com", "_N_", "cf:Page", "I am not important", &err);
    if (err.GetType() != tera::ErrorCode::kOK) {
      LOG(ERROR) << "put _N_ error";
      return;
    }
    table->Put("www.baidu.com", "cf", "Page", "hello world", -1, &err);
    if (err.GetType() != tera::ErrorCode::kOK) {
      LOG(ERROR) << "put cf error";
      return;
    }

    Observer* observer = new TestWorkerNTX();

    Scanner* scanner = new ScannerImpl();
    bool ret = scanner->Init();

    EXPECT_EQ(true, ret);
    if (!ret) {
      LOG(ERROR) << "fail to init scanner_impl";
      return;
    }

    err = scanner->Observe("observer_table_ntx", "cf", "Page", observer);
    EXPECT_EQ(err.GetType(), tera::ErrorCode::kOK);

    if (!scanner->Start()) {