mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-31 12:06:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

scylla-gdb: add scylla compaction-tasks command

Browse Source 
Summarize the compaction_manager::task instances. Useful for detecting
compaction related problems. Example:

(gdb) scylla compaction-task
     2116 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_postimage_scylla_cdc_log"
      769 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_scylla_cdc_log"
      750 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_postimage_scylla_cdc_log"
      731 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_scylla_cdc_log"
      293 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table"
      286 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage"
      230 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_postimage"
       58 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_postimage"
        4 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_postimage_scylla_cdc_log"
        2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table"
        2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_postimage_scylla_cdc_log"
        2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage"
        1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_postimage"
        1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_scylla_cdc_log"
        1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_scylla_cdc_log"
Total: 5246 instances of compaction_manager::task

Signed-off-by: Botond Dénes <bdenes@scylladb.com>
Message-Id: <20200828135030.689188-1-bdenes@scylladb.com>
This commit is contained in:
Botond Dénes
2020-08-28 16:50:30 +03:00
committed by Tomasz Grabiec
parent 727e9be342
commit f063dc22af
1 changed files with 46 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
scylla-gdb.py
View File

@@ -3660,6 +3660,51 @@ class scylla_small_objects(gdb.Command):
gdb.write("[{}] 0x{:x} {}\n".format(offset + i, obj, sym_text))
class scylla_compaction_tasks(gdb.Command):
"""Summarize the compaction_manager::task instances.
The summary is created based on compaction_manager::_tasks and it takes the
form of a histogram with the compaction type and compaction running and
table name as keys. Example:
(gdb) scylla compaction-task
2116 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_postimage_scylla_cdc_log"
769 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_scylla_cdc_log"
750 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_postimage_scylla_cdc_log"
731 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_scylla_cdc_log"
293 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table"
286 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage"
230 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_postimage"
58 type=sstables::compaction_type::Compaction, running=false, "cdc_test"."test_table_preimage_postimage"
4 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_postimage_scylla_cdc_log"
2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table"
2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_postimage_scylla_cdc_log"
2 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage"
1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_postimage"
1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_scylla_cdc_log"
1 type=sstables::compaction_type::Compaction, running=true , "cdc_test"."test_table_preimage_scylla_cdc_log"
Total: 5246 instances of compaction_manager::task
"""
def __init__(self):
gdb.Command.__init__(self, 'scylla compaction-tasks', gdb.COMMAND_USER, gdb.COMPLETE_COMMAND)
def invoke(self, arg, from_tty):
db = find_db()
cm = std_unique_ptr(db['_compaction_manager']).get().dereference()
task_hist = histogram(print_indicators=False)
task_list = list(std_list(cm['_tasks']))
for task in task_list:
task = seastar_lw_shared_ptr(task).get().dereference()
schema = schema_ptr(task['compacting_cf'].dereference()['_schema'])
key = 'type={}, running={:5}, {}'.format(task['type'], str(task['compaction_running']), schema.table_name())
task_hist.add(key)
task_hist.print_to_console()
gdb.write('Total: {} instances of compaction_manager::task\n'.format(len(task_list)))
class scylla_gdb_func_dereference_smart_ptr(gdb.Function):
"""Dereference the pointer guarded by the smart pointer instance.
@@ -3942,6 +3987,7 @@ scylla_smp_queues()
scylla_features()
scylla_repairs()
scylla_small_objects()
scylla_compaction_tasks()
# Convenience functions