Method TestStoreConfig

phxqueue/test/test_config.cpp:255–301

}

void TestConfig::TestStoreConfig(const config::StoreConfig *store_config) {
    const int expected_store_id{1};
    comm::proto::Addr expected_addr;
    expected_addr.set_ip("127.0.0.1");
    expected_addr.set_port(5100);
    expected_addr.set_paxos_port(5101);

    // GetAllStore
    {
        vector<shared_ptr<const config::proto::Store> > stores;
        const int expected_nr_store{1};

        assert(comm::RetCode::RET_OK == store_config->GetAllStore(stores));
        assert(expected_nr_store == stores.size());
    }

    // GetAllStoreID
    {
        set<int> store_ids;
        const int expected_nr_store{1};

        assert(comm::RetCode::RET_OK == store_config->GetAllStoreID(store_ids));
        assert(expected_nr_store == store_ids.size());
    }

    // GetStoreByStoreID
    {

        shared_ptr<const config::proto::Store> store;
        assert(comm::RetCode::RET_OK == store_config->GetStoreByStoreID(expected_store_id, store));
        assert(store);
    }

    // GetStoreIDByAddr
    {
        int store_id;
        assert(comm::RetCode::RET_OK == store_config->GetStoreIDByAddr(expected_addr, store_id));
        assert(expected_store_id == store_id);
    }

    // GetStoreByAddr
    {
        shared_ptr<const config::proto::Store> store;
        assert(comm::RetCode::RET_OK == store_config->GetStoreByAddr(expected_addr, store));
        assert(store);
    }
}


void TestConfig::TestConsumerConfig(const config::ConsumerConfig *consumer_config) {