diff --git a/test_runner/performance/test_pageserver.py b/test_runner/performance/test_pageserver.py index 35c5d12090..6ee102c9e8 100644 --- a/test_runner/performance/test_pageserver.py +++ b/test_runner/performance/test_pageserver.py @@ -2,22 +2,9 @@ from contextlib import closing from fixtures.zenith_fixtures import ZenithEnv from fixtures.benchmark_fixture import MetricReport, ZenithBenchmarker -def _get_page(): - # u8 tag: 2, big endian - # u8 latest - # u64 lsn - # reltag: - # u32 spcnode - # u32 dbnode - # u32 relnode - # u8 forknum - # u32 blkno - pass - def test_get_page(zenith_simple_env: ZenithEnv, zenbenchmark: ZenithBenchmarker): env = zenith_simple_env - # Create a branch for us env.zenith_cli.create_branch("test_pageserver", "empty") pg = env.postgres.create_start('test_pageserver') tenant_hex = env.initial_tenant.hex @@ -36,37 +23,3 @@ def test_get_page(zenith_simple_env: ZenithEnv, zenbenchmark: ZenithBenchmarker) print(res) env.run_psbench(timeline) - return - - import os - ps_log_filename = os.path.join(env.repo_dir, "pageserver.log") - with open(ps_log_filename) as log_file: - log = log_file.readlines() - - ps_connstr = env.pageserver.connstr() - - - - latest_write = None - for line in log: - if line.startswith("wal-at-lsn-modified-page "): - tokens = line.split() - lsn_hex = tokens[1] - page_hex = tokens[2] - latest_write = (lsn_hex, page_hex) - - with closing(env.pageserver.connect()) as psconn: - with psconn.cursor() as cur: - cur.execute(f"pagestream {tenant_hex} {timeline}") - with psconn.cursor() as cur: - cur.execute(f"select 1;") - - # res = cur.fetchall() - # print(res) - # TODO send query to pageserver, see what is logged - - # TODO send queries on these pages - # 1. Craft binary message - # 2. Send as postgres query - - # TODO maybe make rust program for this side of the protocol?