tests/test_worker_tcp_transport.py

test_remote_protocol_rejects_invalid_utf8_without_replacement · function · L52-L62 — def test_remote_protocol_rejects_invalid_utf8_without_replacement()
authority · function · L69-L70 — def authority(tmp_path)
test_the_signing_secret_is_owner_only_and_stable · function · L73-L78 — def test_the_signing_secret_is_owner_only_and_stable(tmp_path)
test_a_credential_verifies_once_and_only_once · function · L81-L86 — def test_a_credential_verifies_once_and_only_once(authority)
test_a_forged_credential_is_refused · function · L89-L100 — def test_a_forged_credential_is_refused(authority)
test_an_expired_credential_is_refused · function · L103-L109 — def test_an_expired_credential_is_refused(tmp_path)
test_an_old_epoch_is_refused_after_recovery · function · L112-L118 — def test_an_old_epoch_is_refused_after_recovery(authority)
test_the_credential_is_a_file_not_an_environment_variable · function · L121-L145 — def test_the_credential_is_a_file_not_an_environment_variable(authority, tmp_path)
test_listen_spec_parsing · function · L151-L158 — def test_listen_spec_parsing()
test_the_gateway_is_off_unless_asked_for · function · L161-L166 — def test_the_gateway_is_off_unless_asked_for(monkeypatch, authority)
gateway · function · L170-L176 — def gateway(authority)
_dial · function · L179-L190 — def _dial(gateway, payload: str) -> dict
test_an_unauthenticated_peer_is_refused_before_any_protocol · function · L193-L199 — def test_an_unauthenticated_peer_is_refused_before_any_protocol(gateway)
test_the_refusal_says_nothing_about_why · function · L202-L212 — def test_the_refusal_says_nothing_about_why(gateway, authority)
test_the_handshake_hands_back_an_authorization_generation · function · L215-L226 — def test_the_handshake_hands_back_an_authorization_generation(gateway, authority)
test_each_authenticated_connection_gets_its_own_generation · function · L229-L235 — def test_each_authenticated_connection_gets_its_own_generation(gateway, authority)
test_a_refused_peer_is_told_no_generation · function · L238-L242 — def test_a_refused_peer_is_told_no_generation(gateway)
test_a_local_kernel_refuses_to_adopt_a_generation · function · L245-L251 — def test_a_local_kernel_refuses_to_adopt_a_generation(tmp_path)
_settled_accepted · function · L254-L272 — def _settled_accepted(gateway, expected: int, timeout: float = 10.0) -> int
test_a_replayed_credential_cannot_open_a_second_connection · function · L275-L284 — def test_a_replayed_credential_cannot_open_a_second_connection(gateway, authority)
test_await_worker_is_keyed_by_epoch · function · L287-L297 — def test_await_worker_is_keyed_by_epoch(gateway, authority)
_RemoteWorker · class · L303-L333 — class _RemoteWorker
init · method · L306-L326 — def init( self, gateway, authority, tmp_path, *, allocation_id="alloc_1", epoch=0 )
close · method · L328-L333 — def close(self)
remote_kernel · function · L337-L354 — def remote_kernel(gateway, authority, tmp_path)
test_a_remote_worker_executes_cells · function · L357-L360 — def test_a_remote_worker_executes_cells(remote_kernel)
test_remote_reader_accepts_every_producer_admitted_frame · function · L363-L395 — def test_remote_reader_accepts_every_producer_admitted_frame()
test_a_remote_worker_keeps_its_namespace_across_cells · function · L398-L402 — def test_a_remote_worker_keeps_its_namespace_across_cells(remote_kernel)
test_host_call_round_trips_over_the_socket · function · L405-L428 — def test_host_call_round_trips_over_the_socket(remote_kernel)
dispatcher · function · L411-L421 — def dispatcher(method, args)
test_an_error_in_a_remote_cell_reports_its_line · function · L431-L437 — def test_an_error_in_a_remote_cell_reports_its_line(remote_kernel)
test_the_remote_transport_reports_no_local_process · function · L440-L447 — def test_the_remote_transport_reports_no_local_process(remote_kernel)
test_interrupting_a_remote_worker_without_a_hook_is_an_error · function · L450-L454 — def test_interrupting_a_remote_worker_without_a_hook_is_an_error(remote_kernel)
test_a_remote_interrupt_uses_the_hook_it_was_given · function · L457-L473 — def test_a_remote_interrupt_uses_the_hook_it_was_given(gateway, authority, tmp_path)
test_a_worker_told_to_connect_without_a_credential_refuses_to_start · function · L476-L493 — def test_a_worker_told_to_connect_without_a_credential_refuses_to_start( gateway, tmp_path )
test_the_local_path_is_untouched_by_all_of_this · function · L496-L507 — def test_the_local_path_is_untouched_by_all_of_this()
test_restarting_a_remote_worker_says_it_cannot_rather_than_pretending · function · L510-L531 — def test_restarting_a_remote_worker_says_it_cannot_rather_than_pretending( remote_kernel, )
test_a_burned_credential_stays_burned_across_a_restart · function · L534-L549 — def test_a_burned_credential_stays_burned_across_a_restart(tmp_path)
test_an_epoch_fence_survives_a_restart · function · L552-L564 — def test_an_epoch_fence_survives_a_restart(tmp_path)
test_pre_auth_handshakes_are_bounded · function · L567-L593 — def test_pre_auth_handshakes_are_bounded(authority)
test_a_dribbling_peer_cannot_hold_a_slot_past_the_deadline · function · L596-L624 — def test_a_dribbling_peer_cannot_hold_a_slot_past_the_deadline(authority, monkeypatch)
test_the_fence_file_is_owner_only · function · L627-L632 — def test_the_fence_file_is_owner_only(tmp_path)
test_a_corrupt_fence_refuses_admission_rather_than_forgetting · function · L635-L674 — def test_a_corrupt_fence_refuses_admission_rather_than_forgetting(tmp_path)
test_a_wrong_shaped_fence_fails_closed · function · L688-L696 — def test_a_wrong_shaped_fence_fails_closed(tmp_path, payload)
test_a_failed_nonce_persistence_refuses_and_rolls_back · function · L699-L726 — def test_a_failed_nonce_persistence_refuses_and_rolls_back(tmp_path, monkeypatch)
replace · function · L710-L713 — def replace(source, target)
test_a_failed_fence_directory_fsync_refuses_the_nonce · function · L729-L760 — def test_a_failed_fence_directory_fsync_refuses_the_nonce(tmp_path, monkeypatch)
fail_fsync · function · L744-L745 — def fail_fsync(directory)
test_an_uncertain_epoch_publish_cannot_reopen_the_old_epoch · function · L763-L786 — def test_an_uncertain_epoch_publish_cannot_reopen_the_old_epoch(tmp_path, monkeypatch)
fail_fsync · function · L772-L773 — def fail_fsync(_directory)
test_a_failed_epoch_persistence_does_not_publish_the_new_fence · function · L789-L819 — def test_a_failed_epoch_persistence_does_not_publish_the_new_fence( tmp_path, monkeypatch )
replace · function · L801-L804 — def replace(source, target)
test_a_missing_fence_is_still_an_empty_fence · function · L822-L827 — def test_a_missing_fence_is_still_an_empty_fence(tmp_path)