Ceph » RADOS

/a/nmordech-2025-11-12_16:07:54-rados-wip-rocky10-branch-of-the-day-2025-11-10-1762829866-distro-default-smithi/8599258

the test shows:

2025-11-12T19:02:12.941 INFO:teuthology.orchestra.run.smithi093.stdout:pool 'lazy_omap_test_pool' created
2025-11-12T19:02:12.946 INFO:teuthology.orchestra.run.smithi093.stdout:Querying pool id
2025-11-12T19:02:12.947 INFO:teuthology.orchestra.run.smithi093.stdout:Found pool ID: 2
2025-11-12T19:02:12.978 INFO:teuthology.orchestra.run.smithi093.stdout:Created payload with 2000 keys of 445 bytes each. Total size in bytes = 890000
2025-11-12T19:02:12.978 INFO:teuthology.orchestra.run.smithi093.stdout:Waiting for active+clean
2025-11-12T19:02:13.230 INFO:tasks.ceph.mgr.x.smithi093.stderr:2025-11-12T19:02:13.228+0000 7fd1c52fd6c0 -1 mgr.server reply reply (22) Invalid argument unparseable JSON
2025-11-12T19:02:13.230 INFO:teuthology.orchestra.run.smithi093.stderr:Failed to get ! Error: 22 Invalid argument
2025-11-12T19:02:13.234 DEBUG:teuthology.orchestra.run:got remote process result: 22

the mgr side shows:

2025-11-12T19:02:13.228+0000 7fd1c52fd6c0  1 -- [v2:172.21.15.93:6824/2003521395,v1:172.21.15.93:6825/2003521395] <== client.4189 172.21.15.93:0/4235421012 2 ==== mgr_command(tid 1: ) ==== 24+0+0 (secure 0 0 0) 0x55efb094a340 con 0x55efb0828800
2025-11-12T19:02:13.228+0000 7fd1c52fd6c0 -1 mgr.server reply reply (22) Invalid argument unparseable JSON 

Looking on the recent changes, we added std::move to the call of get_output inside do..while loop. First iterator is fine, we moved the JSON, but now we have an empty string, second iterator we are passing empty JSON, and that's the issue

void LazyOmapStatsTest::wait_for_active_clean()
{
  cout << "Waiting for active+clean" << endl;

  int index = -1;
  boost::regex reg(
      "\n" 
      R"((PG_STAT[\s\S]*))" 
      "\n +\n[0-9]");
  string command = R"({"prefix": "pg dump"})";
  int num_not_clean;
  do {
    string dump_output = get_output(std::move(command), true);
    if (index == -1) {
      boost::regex ireg(
          "\n" 
          R"((PG_STAT\s.*))" 
          "\n");
      index = find_index(dump_output, ireg, "STATE");
    }
    boost::smatch match;
    boost::regex_search(dump_output, match, reg, boost::match_not_dot_newline);
    istringstream buffer(match[1].str());
    string line;
    num_not_clean = 0;
    while (std::getline(buffer, line)) {
      if (line.compare(0, 1, "P") == 0) continue;
      boost::char_separator<char> sep{" "};
      boost::tokenizer<boost::char_separator<char>> tok(line, sep);
      vector<string> tokens(tok.begin(), tok.end());
      num_not_clean += tokens.at(index).compare("active+clean");
    }
    cout << "." << flush;
    this_thread::sleep_for(chrono::milliseconds(250));
  } while (num_not_clean);

  cout << endl;
}