Method OnNotifyTest

src/observer/test/observer_test.cc:205–304

class ObserverImplTest : public ::testing::Test {
 public:
  void OnNotifyTest() {
    tera::ErrorCode err;
    LOG(ERROR) << "FALG FILE: " << FLAGS_flagfile;
    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_test_table");
    table_desc.EnableTxn();

    table_desc.AddLocalityGroup("lg1");
    tera::ColumnFamilyDescriptor* cf1 = table_desc.AddColumnFamily("cf", "lg1");
    cf1->EnableGlobalTransaction();
    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_test_table", &err));
    EXPECT_EQ(tera::ErrorCode::kOK, err.GetType());
    if (tera::ErrorCode::kOK != err.GetType()) {
      LOG(ERROR) << "open table failed";
      return;
    }

    sleep(1);
    std::unique_ptr<tera::Transaction> t(table->StartRowTransaction("www.baidu.com"));

    assert(t != NULL);
    std::unique_ptr<tera::RowMutation> mu0(table->NewRowMutation("www.baidu.com"));
    mu0->Put("_N_", "cf:Page", "I am not important");
    t->ApplyMutation(mu0.get());
    t->Commit();

    std::unique_ptr<tera::Transaction> g_txn(client->NewGlobalTransaction());
    assert(g_txn != NULL);
    std::unique_ptr<tera::RowMutation> mu1(table->NewRowMutation("www.baidu.com"));

    mu1->Put("cf", "Page", "hello world", -1);
    g_txn->ApplyMutation(mu1.get());
    g_txn->Commit();

    if (g_txn->GetError().GetType() != tera::ErrorCode::kOK) {
      std::cout << g_txn->GetError().ToString() << std::endl;
    } else {
      std::cout << "commit success" << std::endl;
    }