mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

tests: Fix gossip_test

Browse Source 
Gossip depends on get_ring_delay from storage_service. storage_service
depends on database. Start them.
This commit is contained in:
Asias He
2016-01-01 09:32:03 +08:00
parent de508ba6cc
commit ca935bf602
1 changed files with 19 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
tests/gossip_test.cc
View File

@@ -29,19 +29,26 @@
#include "gms/failure_detector.hh"
#include "gms/gossiper.hh"
#include "core/reactor.hh"
#include "service/pending_range_calculator_service.hh"
#include "service/storage_service.hh"
#include "core/distributed.hh"
#include "database.hh"
SEASTAR_TEST_CASE(test_boot_shutdown){
return net::get_messaging_service().start(gms::inet_address("127.0.0.1")).then( [] () {
return gms::get_failure_detector().start().then([] {
return gms::get_gossiper().start().then([] {
return gms::get_gossiper().stop().then( [] (){
return gms::get_failure_detector().stop().then( [] (){
return net::get_messaging_service().stop().then ( [] () {
return make_ready_future<>();
});
});
});
});
});
return seastar::async([] {
distributed<database> db;
service::get_pending_range_calculator_service().start(std::ref(db));
service::get_storage_service().start(std::ref(db)).get();
db.start().get();
net::get_messaging_service().start(gms::inet_address("127.0.0.1")).get();
gms::get_failure_detector().start().get();
gms::get_gossiper().start().get();
gms::get_gossiper().stop().get();
gms::get_failure_detector().stop().get();
net::get_messaging_service().stop().get();
db.stop().get();
service::get_storage_service().stop().get();
service::get_pending_range_calculator_service().stop().get();
});
}