Function TestAdd

phxqueue/test/test_store_main.cpp:33–71

void TestAdd(store::Store &store) {
    NLVerb("begin");

    comm::RetCode ret;

    const int topic_id = 1000;
    const int store_id = 1;
    const int queue_id = 0;
    const int pub_id = 1;
    const int handle_id = 1;
    const uint64_t uin = 123;
    const string buffer = "123";
    const int buffer_type = 0;
    const uint64_t sub_ids = 3;

    comm::proto::AddRequest req;
    comm::proto::AddResponse resp;
    req.set_topic_id(topic_id);
    req.set_store_id(store_id);
    req.set_queue_id(queue_id);

    auto &&item = req.add_items();
    auto &&meta = item->mutable_meta();
    meta->set_topic_id(topic_id);
    meta->set_handle_id(handle_id);
    meta->set_uin(uin);
    item->set_buffer(buffer);
    item->set_buffer_type(buffer_type);
    item->set_sub_ids(sub_ids);
    item->set_pub_id(pub_id);
    item->set_atime(time(nullptr));

    if (comm::RetCode::RET_OK != (ret = store.Add(req, resp))) {
        NLErr("Store Add ret %d", as_integer(ret));
        return;
    }

    NLVerb("cursor_id %" PRIu64, (uint64_t)resp.cursor_id());
}

void StoreRun(const int vpid) {
    comm::RetCode ret;