mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-20 00:20:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

gossip: Fix passing by reference

Browse Source 
Fix the same issue as we do in 7516966db5 (message: Fix passing by
reference).
This commit is contained in:
Asias He
2015-05-07 15:14:04 +08:00
parent 177498375d
commit c79844e4e5
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tests/urchin/gossip.cc
View File

@@ -12,17 +12,16 @@ int main(int ac, char ** av) {
app.add_options()
("seed", bpo::value<std::vector<std::string>>(), "IP address of seed node")
("listen-address", bpo::value<std::string>()->default_value("0.0.0.0"), "IP address to listen");
return app.run(ac, av, [&] {
auto&& config = app.configuration();
auto listen = gms::inet_address(config["listen-address"].as<std::string>());
net::get_messaging_service().start(std::ref(listen)).then([&] {
return app.run(ac, av, [&app] {
auto config = app.configuration();
const gms::inet_address listen = gms::inet_address(config["listen-address"].as<std::string>());
net::get_messaging_service().start(listen).then([config] {
auto& server = net::get_local_messaging_service();
auto port = server.port();
auto listen = server.listen_address();
print("Messaging server listening on ip %s port %d ...\n", listen, port);
gms::get_failure_detector().start_single().then([&] {
gms::get_gossiper().start_single().then([&] {
auto&& config = app.configuration();
gms::get_failure_detector().start_single().then([config] {
gms::get_gossiper().start_single().then([config] {
std::set<gms::inet_address> seeds;
for (auto s : config["seed"].as<std::vector<std::string>>()) {
seeds.emplace(std::move(s));