Sleep longer in ES tests

By default, Elasticsearch periodically refreshes indices every second. So we sleep 2 seconds before checking the results.
bitshares · May 5, 2020 · 7b7d9f7 · 7b7d9f7
1 parent ec7373b
commit 7b7d9f7
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/tests/elasticsearch/main.cpp b/tests/elasticsearch/main.cpp
@@ -54,7 +54,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_account_history) {
 
       // delete all first
       auto delete_account_history = graphene::utilities::deleteAll(es);
-      fc::usleep(fc::milliseconds(1000)); // this is because index.refresh_interval, nothing to worry
+      fc::usleep(fc::milliseconds(2000)); // this is because index.refresh_interval, nothing to worry
 
       if(delete_account_history) { // all records deleted
 
@@ -64,7 +64,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_account_history) {
          auto bob = create_account("bob");
 
          generate_block();
-         fc::usleep(fc::milliseconds(1000));
+         fc::usleep(fc::milliseconds(2000));
 
          // for later use
          //int asset_create_op_id = operation::tag<asset_create_operation>::value;
@@ -89,7 +89,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_account_history) {
          auto willie = create_account("willie");
          generate_block();
 
-         fc::usleep(fc::milliseconds(1000)); // index.refresh_interval
+         fc::usleep(fc::milliseconds(2000)); // index.refresh_interval
 
          es.endpoint = es.index_prefix + "*/data/_count";
          res = graphene::utilities::simpleQuery(es);
@@ -104,7 +104,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_account_history) {
          transfer(account_id_type()(db), bob, asset(300));
 
          generate_block();
-         fc::usleep(fc::milliseconds(1000)); // index.refresh_interval
+         fc::usleep(fc::milliseconds(2000)); // index.refresh_interval
 
          res = graphene::utilities::simpleQuery(es);
          j = fc::json::from_string(res);
@@ -145,14 +145,14 @@ BOOST_AUTO_TEST_CASE(elasticsearch_objects) {
       auto delete_objects = graphene::utilities::deleteAll(es);
 
       generate_block();
-      fc::usleep(fc::milliseconds(1000));
+      fc::usleep(fc::milliseconds(2000));
 
       if(delete_objects) { // all records deleted
 
          // asset and bitasset
          create_bitasset("USD", account_id_type());
          generate_block();
-         fc::usleep(fc::milliseconds(1000));
+         fc::usleep(fc::milliseconds(2000));
 
          string query = "{ \"query\" : { \"bool\" : { \"must\" : [{\"match_all\": {}}] } } }";
          es.endpoint = es.index_prefix + "*/data/_count";
@@ -195,10 +195,10 @@ BOOST_AUTO_TEST_CASE(elasticsearch_suite) {
       es.elasticsearch_url = "http://localhost:9200/";
       es.index_prefix = "bitshares-";
       auto delete_account_history = graphene::utilities::deleteAll(es);
-      fc::usleep(fc::milliseconds(1000));
+      fc::usleep(fc::milliseconds(2000));
       es.index_prefix = "objects-";
       auto delete_objects = graphene::utilities::deleteAll(es);
-      fc::usleep(fc::milliseconds(1000));
+      fc::usleep(fc::milliseconds(2000));
 
       if(delete_account_history && delete_objects) { // all records deleted
 
@@ -224,7 +224,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_history_api) {
       auto delete_account_history = graphene::utilities::deleteAll(es);
 
       generate_block();
-      fc::usleep(fc::milliseconds(1000));
+      fc::usleep(fc::milliseconds(2000));
 
       if(delete_account_history) {
 
@@ -237,7 +237,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_history_api) {
          create_bitasset("OIL", dan.id); // create op 6
 
          generate_block();
-         fc::usleep(fc::milliseconds(1000));
+         fc::usleep(fc::milliseconds(2000));
 
          graphene::app::history_api hist_api(app);
          app.enable_plugin("elasticsearch");
@@ -506,7 +506,7 @@ BOOST_AUTO_TEST_CASE(elasticsearch_history_api) {
          create_account("alice");
 
          generate_block();
-         fc::usleep(fc::milliseconds(1000));
+         fc::usleep(fc::milliseconds(2000));
 
          // f(C, 0, 4, 10) = { 7 }
          histories = hist_api.get_account_history("alice", operation_history_id_type(0), 4, operation_history_id_type(10));