Skip to content

Commit

Permalink
Added "--wait-other-notice" to ccm bridge
Browse files Browse the repository at this point in the history
- Also removed std::none_of() from int. tests
  • Loading branch information
mpenick committed Sep 7, 2014
1 parent f577016 commit db9ea7e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions test/ccm_bridge/src/cql_ccm_bridge.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -324,11 +324,11 @@ namespace cql {
}

void cql_ccm_bridge_t::start(int node) {
execute_ccm_command(boost::str(boost::format("node%1% start --wait-for-binary-proto") % node));
execute_ccm_command(boost::str(boost::format("node%1% start --wait-other-notice --wait-for-binary-proto") % node));
}

void cql_ccm_bridge_t::start(int node, const std::string& option) {
execute_ccm_command(boost::str(boost::format("node%1% start --wait-for-binary-proto --jvm_arg=%2%") % node % option));
execute_ccm_command(boost::str(boost::format("node%1% start --wait-other-notice --wait-for-binary-proto --jvm_arg=%2%") % node % option));
}

void cql_ccm_bridge_t::stop() {
Expand Down
4 changes: 2 additions & 2 deletions test/integration_tests/src/stress.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ BOOST_AUTO_TEST_CASE(parallel_insert_and_select)
}

boost::wait_for_all(futures.begin(), futures.end());
BOOST_REQUIRE(std::none_of(futures.begin(), futures.end(), is_failed));
BOOST_REQUIRE(std::find_if(futures.begin(), futures.end(), is_failed) == futures.end());
}

BOOST_AUTO_TEST_CASE(parallel_insert_and_select_with_nodes_failing)
Expand Down Expand Up @@ -232,7 +232,7 @@ BOOST_AUTO_TEST_CASE(parallel_insert_and_select_with_nodes_failing)
futures.insert(futures.begin() + 8, boost::async(boost::launch::async, boost::bind(kill_task, ccm)).share());

boost::wait_for_all(futures.begin(), futures.end());
BOOST_REQUIRE(std::none_of(futures.begin(), futures.end(), is_failed));
BOOST_REQUIRE(std::find_if(futures.begin(), futures.end(), is_failed) == futures.end());
}

BOOST_AUTO_TEST_SUITE_END()

0 comments on commit db9ea7e

Please sign in to comment.