Source symbols: t/unit/app/test_control.py

Deterministic, value-free symbol metadata extracted from public source. Implementations and literal values are not copied into this page.

• Revision: main@97ed017c09de03612a7d9617ff4c038c00bf916b · 2026-07-19T16:04:39Z
• Declarations: 80
• Referenced calls: 62

Declared symbols

• _info_for_commandclass — def at line 11; references items, getattr, inspect
• test_client_implements_all_commands — def at line 20; references _info_for_commandclass, getattr, inspect
• test_inspect_implements_all_commands — def at line 27; references inspect, _info_for_commandclass, getattr
• test_flatten_reply — class at line 36
• test_flatten_reply — def at line 38
• test_inspect — class at line 53; references Mock
• setup_method — def at line 55; references Mock
• test_prepare_reply — def at line 60; references _prepare
• assert_broadcast_called — def at line 73; references assert_called_with, active, clock, conf, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task
• test_active — def at line 96; references active, assert_broadcast_called, clock, conf, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task
• test_active_safe — def at line 100; references active, assert_broadcast_called, clock, conf, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task
• test_clock — def at line 104; references clock, assert_broadcast_called, conf, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report
• test_conf — def at line 108; references conf, assert_broadcast_called, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock
• test_conf__with_defaults — def at line 112; references conf, assert_broadcast_called, hello, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock
• test_hello — def at line 116; references hello, assert_broadcast_called, LimitedSet, range, add, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_hello__with_revoked — def at line 121; references LimitedSet, range, add, hello, assert_broadcast_called, memsample, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_memsample — def at line 129; references memsample, assert_broadcast_called, memdump, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_memdump — def at line 133; references memdump, assert_broadcast_called, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_memdump__samples_specified — def at line 137; references memdump, assert_broadcast_called, objgraph, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_objgraph — def at line 141; references objgraph, assert_broadcast_called, scheduled, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_scheduled — def at line 146; references scheduled, assert_broadcast_called, reserved, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_reserved — def at line 150; references reserved, assert_broadcast_called, stats, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_stats — def at line 154; references stats, assert_broadcast_called, revoked, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_revoked — def at line 158; references revoked, assert_broadcast_called, registered, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_registered — def at line 162; references registered, assert_broadcast_called, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_registered__taskinfoitems — def at line 166; references registered, assert_broadcast_called, ping, inspect, active_queues, query_task, report, Mock, broadcast
• test_ping — def at line 173; references ping, assert_broadcast_called, inspect, active_queues, query_task, report, Mock, broadcast
• test_ping_matcher_pattern — def at line 177; references inspect, ping, assert_broadcast_called, active_queues, query_task, report, Mock, broadcast
• test_active_queues — def at line 187; references active_queues, assert_broadcast_called, query_task, report, Mock, broadcast
• test_query_task — def at line 191; references query_task, assert_broadcast_called, report, Mock, broadcast
• test_query_task__compat_single_list_argument — def at line 195; references query_task, assert_broadcast_called, report, Mock, broadcast
• test_query_task__scalar — def at line 199; references query_task, assert_broadcast_called, report, Mock, broadcast
• test_report — def at line 203; references report, assert_broadcast_called, Mock, broadcast
• test_Control_broadcast — class at line 208; references Mock, broadcast
• setup_method — def at line 210; references Mock, broadcast
• test_broadcast — def at line 213; references broadcast
• test_broadcast_limit — def at line 221; references broadcast, assert_called, mailbox, assert_called_with
• test_Control — class at line 232; references Mock
• setup_method — def at line 234; references Mock
• mytask — def at line 239; references assert_called_with
• assert_control_called_with_args — def at line 243; references assert_called_with
• test_serializer — def at line 248; references Control, Mock, purge, TaskConsumer, assert_called_with, rate_limit, assert_control_called_with_args
• test_purge — def at line 254; references Mock, purge, TaskConsumer, assert_called_with, rate_limit, assert_control_called_with_args
• test_rate_limit — def at line 259; references rate_limit, assert_control_called_with_args
• test_rate_limit__with_destination — def at line 268; references rate_limit, assert_control_called_with_args
• test_time_limit — def at line 279; references time_limit, assert_control_called_with_args
• test_time_limit__with_destination — def at line 289; references time_limit, assert_control_called_with_args
• test_add_consumer — def at line 304; references add_consumer, assert_control_called_with_args
• test_add_consumer__with_options_and_dest — def at line 315; references add_consumer, assert_control_called_with_args
• test_cancel_consumer — def at line 328; references cancel_consumer, assert_control_called_with_args
• test_cancel_consumer__with_destination — def at line 336; references cancel_consumer, assert_control_called_with_args
• test_shutdown — def at line 346; references shutdown, assert_control_called_with_args
• test_shutdown__with_destination — def at line 350; references shutdown, assert_control_called_with_args
• test_heartbeat — def at line 355; references heartbeat, assert_control_called_with_args
• test_heartbeat__with_destination — def at line 359; references heartbeat, assert_control_called_with_args
• test_pool_restart — def at line 364; references pool_restart, assert_control_called_with_args, Mock, terminate, assert_called_with, enable_events
• test_terminate — def at line 373; references Mock, terminate, assert_called_with, enable_events, assert_control_called_with_args
• test_enable_events — def at line 382; references enable_events, assert_control_called_with_args
• test_enable_events_with_destination — def at line 386; references enable_events, assert_control_called_with_args
• test_disable_events — def at line 391; references disable_events, assert_control_called_with_args
• test_disable_events_with_destination — def at line 396; references disable_events, assert_control_called_with_args
• test_ping — def at line 401; references ping, assert_control_called_with_args
• test_ping_with_destination — def at line 407; references ping, assert_control_called_with_args
• test_revoke — def at line 418; references revoke, assert_control_called_with_args, revoke_by_stamped_headers
• test_revoke_by_stamped_headers — def at line 428; references revoke_by_stamped_headers
• test_revoke__with_options — def at line 438; references revoke, assert_control_called_with_args
• test_revoke_by_stamped_headers__with_options — def at line 455; references revoke_by_stamped_headers
• test_election — def at line 472; references election, assert_control_called_with_args
• test_autoscale — def at line 483; references autoscale, assert_control_called_with_args
• test_autoscale__with_options — def at line 488; references autoscale, assert_control_called_with_args
• test_pool_grow — def at line 496; references pool_grow, assert_control_called_with_args
• test_pool_grow__with_options — def at line 501; references pool_grow, assert_control_called_with_args
• test_pool_shrink — def at line 509; references pool_shrink, assert_control_called_with_args
• test_pool_shrink__with_options — def at line 514; references pool_shrink, assert_control_called_with_args
• test_revoke_from_result — def at line 522; references Mock, AsyncResult, revoke, assert_called_with, revoke_by_stamped_headers
• test_revoke_by_stamped_headers_from_result — def at line 530; references Mock, AsyncResult, revoke_by_stamped_headers
• test_revoke_from_resultset — def at line 538; references Mock, uuid, range, GroupResult, AsyncResult, revoke, assert_called_with
• test_after_fork_clears_mailbox_pool — def at line 549; references Mock, _after_fork
• test_control_exchange__default — def at line 560; references Control
• test_control_exchange__setting — def at line 564; references Control, raises

File-level call references

• items — line 15
• _info_for_commandclass — line 21
• getattr — line 24
• inspect — line 28
• warns — line 44
• flatten_reply — line 45
• format — line 47
• next — line 48
• iter — line 48
• str — line 48
• Mock — line 56
• _prepare — line 61
• assert_called_with — line 83
• active — line 97
• assert_broadcast_called — line 98
• clock — line 105
• conf — line 109
• hello — line 117
• LimitedSet — line 122
• range — line 123
• add — line 124
• memsample — line 130
• memdump — line 134
• objgraph — line 142
• scheduled — line 147
• reserved — line 151
• stats — line 155
• revoked — line 159
• registered — line 163
• ping — line 174
• active_queues — line 188
• query_task — line 192
• report — line 204
• broadcast — line 214
• assert_called — line 215
• mailbox — line 216
• task — line 238
• Control — line 251
• purge — line 256
• TaskConsumer — line 257
• rate_limit — line 260
• assert_control_called_with_args — line 261
• time_limit — line 280
• add_consumer — line 305
• cancel_consumer — line 329
• shutdown — line 347
• heartbeat — line 356
• pool_restart — line 365
• terminate — line 375
• enable_events — line 383
• disable_events — line 392
• revoke — line 419
• revoke_by_stamped_headers — line 429
• election — line 473
• autoscale — line 484
• pool_grow — line 497
• pool_shrink — line 510
• AsyncResult — line 524
• uuid — line 540
• GroupResult — line 541
• _after_fork — line 555
• raises — line 581

Source: t/unit/app/test_control.py