Skip to content

Commit

Permalink
repro
Browse files Browse the repository at this point in the history
  • Loading branch information
kbr-scylla committed Jun 5, 2023
1 parent d2e0897 commit 1ae2f86
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 1 deletion.
3 changes: 2 additions & 1 deletion auth/roles-metadata.cc
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,8 @@ future<bool> default_role_row_satisfies(
meta::roles_table::qualified_name,
meta::roles_table::role_col_name);

return do_with(std::move(p), [&qp](const auto& p) {
co_await sleep(std::chrono::seconds{5});
co_return co_await do_with(std::move(p), [&qp](const auto& p) {
return qp.execute_internal(
query,
db::consistency_level::ONE,
Expand Down
9 changes: 9 additions & 0 deletions test/topology_custom/test_shutdown_hang.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@


@pytest.mark.asyncio
@pytest.mark.skip
async def test_hints_manager_shutdown_hang(manager: ManagerClient) -> None:
"""Reproducer for #8079"""
s1 = await manager.server_add(config={
Expand Down Expand Up @@ -61,3 +62,11 @@ async def test_hints_manager_shutdown_hang(manager: ManagerClient) -> None:

logger.info(f"Stop {s1} gracefully")
await manager.server_stop_gracefully(s1.server_id)


@pytest.mark.asyncio
async def test_auth_service_shutdown_hang(manager: ManagerClient) -> None:
s1 = await manager.server_add()
s2 = await manager.server_add()
await manager.server_stop(s1.server_id)
await manager.server_stop_gracefully(s2.server_id)

0 comments on commit 1ae2f86

Please sign in to comment.