Code

GH-800: Drain the Pipeline#450

Code

Merged

utkarshg6 merged 69 commits intomasterMASQ-Project/Node:masterfrom GH-800MASQ-Project/Node:GH-800Copy head branch name to clipboardNov 29, 2024

+963-211

Commits

Commits on Jun 13, 2024

• GH-800: Write the most basic TODOs for this card

  utkarshg6

  committed
  4cfa253

  Copy full SHA for 4cfa253

Commits on Jun 25, 2024

• GH-800: Add todos for renaming purposes

  utkarshg6

  committed
  07cfef9

  Copy full SHA for 07cfef9

Commits on Jun 27, 2024

• GH-800: Add a message scheduler for purging the stream key

  utkarshg6

  committed
  62db40f

  Copy full SHA for 62db40f

Commits on Jun 28, 2024

• GH-800: Improve the test handle_client_response_payload_purges_stream_keys_for_terminal_response

  utkarshg6

  committed
  e4199ae

  Copy full SHA for e4199ae

• GH-800: Make delay configurable via constant

  utkarshg6

  committed
  ee8f897

  Copy full SHA for ee8f897

Commits on Jul 2, 2024

• GH-800: introduce StreamSenders

  utkarshg6

  committed
  91323d4

  Copy full SHA for 91323d4

Commits on Jul 4, 2024

• GH-800: introduce channel for shutdown signal

  utkarshg6

  committed
  7cc2fbb

  Copy full SHA for 7cc2fbb

Commits on Jul 6, 2024

• GH-800: add test connection_shutdown_test.rs

  utkarshg6

  committed
  d784157

  Copy full SHA for d784157

Commits on Jul 10, 2024

• GH-800: test drive the shutdown signal in StreamReader

  utkarshg6

  committed
  14a5de3

  Copy full SHA for 14a5de3

• GH-800: refactor test stream_reader_shuts_down_when_it_receives_the_shutdown_signal

  utkarshg6

  committed
  d8d1f10

  Copy full SHA for d8d1f10

• GH-800: some refactor inside the file stream_reader

  utkarshg6

  committed
  ddf7d9c

  Copy full SHA for ddf7d9c

• GH-800: some more refactoring

  utkarshg6

  committed
  a6f2538

  Copy full SHA for a6f2538

Commits on Jul 11, 2024

• GH-800: trying_to_write_a_test_for_stream_senders was a success

  utkarshg6

  committed
  130a37c

  Copy full SHA for 130a37c

Commits on Jul 12, 2024

• GH-800: did some refactoring for trying_to_write_a_test_for_stream_senders

  utkarshg6

  committed
  6db4c0c

  Copy full SHA for 6db4c0c

Commits on Jul 18, 2024

• GH-800: stream_handler_pool_sends_shutdown_signal_when_last_data_is_true passes for the first time

  utkarshg6

  committed
  c3cc6a8

  Copy full SHA for c3cc6a8

• GH-800: Minor refactor for the test stream_handler_pool_sends_shutdown_signal_when_last_data_is_true

  utkarshg6

  committed
  75edd8f

  Copy full SHA for 75edd8f

• GH-800: more refactoring of the test stream_handler_pool_sends_shutdown_signal_when_last_data_is_true

  utkarshg6

  committed
  296f449

  Copy full SHA for 296f449

• GH-800: stream_handler_pool_sends_shutdown_signal_when_last_data_is_true is working fine

  utkarshg6

  committed
  a2c763d

  Copy full SHA for a2c763d

• GH-800: some more todos removed

  utkarshg6

  committed
  3c223ea

  Copy full SHA for 3c223ea

Commits on Jul 19, 2024

• GH-800: clean_up_dead_streams_logs_when_the_shutdown_channel_is_down is passing

  utkarshg6

  committed
  4605d83

  Copy full SHA for 4605d83

• GH-800: tests are passing in StreamHandlerPool

  utkarshg6

  committed
  e1417c8

  Copy full SHA for e1417c8

• GH-800: Wrote a test for the case when the shutdown signal channel is gone

  utkarshg6

  committed
  6e28ff1

  Copy full SHA for 6e28ff1

Commits on Jul 22, 2024

• GH-800: make it easier to understand who experiences the write error

  utkarshg6

  committed
  6849db6

  Copy full SHA for 6849db6

• GH-800: trying to write test while_housekeeping_the_stream_senders_are_received_by_stream_handler_pool

  utkarshg6

  committed
  af09d25

  Copy full SHA for af09d25

Commits on Jul 26, 2024

• GH-800: add test add_new_streams_works

  utkarshg6

  committed
  b896db6

  Copy full SHA for b896db6

• GH-800: wip: add the log

  utkarshg6

  committed
  acf2c89

  Copy full SHA for acf2c89

Commits on Jul 31, 2024

• GH-800: test proxy_client_stream_reader_dies_when_client_stream_is_killed_integration is passing

  utkarshg6

  committed
  deb1535

  Copy full SHA for deb1535

• GH-800: change the channel from crossbeam to tokio

  utkarshg6

  committed
  2ecfebc

  Copy full SHA for 2ecfebc

Commits on Aug 6, 2024

• GH-800: Add fn send_shutdown_signal_to_stream_reader

  utkarshg6

  committed
  3b387a7

  Copy full SHA for 3b387a7

Commits on Aug 7, 2024

• GH-800: wip: fixing 2 tests

  utkarshg6

  committed
  f94c8d3

  Copy full SHA for f94c8d3

• GH-800: stream_handler_pool_sends_shutdown_signal_when_last_data_is_true is passing

  utkarshg6

  committed
  54040ae

  Copy full SHA for 54040ae

Commits on Aug 16, 2024

• GH-800: all tests in stream_handler_pool.rs are passing

  utkarshg6

  committed
  31db7c4

  Copy full SHA for 31db7c4

Commits on Aug 27, 2024

• GH-800: add test for the logs; all tests passing

  utkarshg6

  committed
  4f8c141

  Copy full SHA for 4f8c141

• GH-800: remove lookup_ip() mock fns from a test

  utkarshg6

  committed
  1880006

  Copy full SHA for 1880006

• GH-800: remove warnings

  utkarshg6

  committed
  d81c2f0

  Copy full SHA for d81c2f0

• GH-800: use fn send_shutdown_signal_to_stream_reader in clean_up_dead_streams()

  utkarshg6

  committed
  ae08930

  Copy full SHA for ae08930

Commits on Sep 4, 2024

• Revert "GH-800: use fn send_shutdown_signal_to_stream_reader in clean_up_dead_streams()"

  Show description for 23fc9ab
  utkarshg6

  committed
  23fc9ab

  Copy full SHA for 23fc9ab

• Revert "GH-800: remove warnings"

  Show description for f9491e7
  utkarshg6

  committed
  f9491e7

  Copy full SHA for f9491e7

• Revert "GH-800: remove lookup_ip() mock fns from a test"

  Show description for 3e3fa71
  utkarshg6

  committed
  3e3fa71

  Copy full SHA for 3e3fa71

• Revert "GH-800: add test for the logs; all tests passing"

  Show description for d4e8075
  utkarshg6

  committed
  d4e8075

  Copy full SHA for d4e8075

• Revert "GH-800: all tests in stream_handler_pool.rs are passing"

  Show description for 5aa1107
  utkarshg6

  committed
  5aa1107

  Copy full SHA for 5aa1107

• Revert "GH-800: stream_handler_pool_sends_shutdown_signal_when_last_data_is_true is passing"

  Show description for f2dbe7b
  utkarshg6

  committed
  f2dbe7b

  Copy full SHA for f2dbe7b

• Revert "GH-800: wip: fixing 2 tests"

  Show description for a24dcda
  utkarshg6

  committed
  a24dcda

  Copy full SHA for a24dcda

• Revert "GH-800: Add fn send_shutdown_signal_to_stream_reader"

  Show description for c61cc5a
  utkarshg6

  committed
  c61cc5a

  Copy full SHA for c61cc5a

• Revert "GH-800: change the channel from crossbeam to tokio"

  Show description for af9a673
  utkarshg6

  committed
  af9a673

  Copy full SHA for af9a673

• GH-800: reverted the channel to crossbeam; remove warnings

  utkarshg6

  committed
  5ba55df

  Copy full SHA for 5ba55df

• GH-800: solve some TODOs

  utkarshg6

  committed
  5579c12

  Copy full SHA for 5579c12

• GH-800: add refactored fn send_shutdown_signal_to_stream_reader; crtitical integration test passing

  utkarshg6

  committed
  3f34e83

  Copy full SHA for 3f34e83

• GH-800: write_failure_for_nonexistent_stream_generates_termination_message is improved

  utkarshg6

  committed
  681a79f

  Copy full SHA for 681a79f

Commits on Sep 5, 2024

• GH-800: everything is tested

  utkarshg6

  committed
  0811b5e

  Copy full SHA for 0811b5e

Commits on Sep 6, 2024

• GH-800: fix proxy_server_receives_terminal_response_from_hopper

  utkarshg6

  committed
  d86918e

  Copy full SHA for d86918e

Commits on Sep 10, 2024

• GH-800: trigger actions

  utkarshg6

  committed
  53eadfa

  Copy full SHA for 53eadfa

• GH-800: assert on a different error on non-mac os

  utkarshg6

  committed
  74eb857

  Copy full SHA for 74eb857

• Merge branch 'master' into GH-800

  utkarshg6

  authored
  92d46cd

  Copy full SHA for 92d46cd

Commits on Sep 11, 2024

• GH-80: add changes of self-review

  utkarshg6

  committed
  ce0d3c5

  Copy full SHA for ce0d3c5

• GH-800: some other missed changes

  utkarshg6

  committed
  7afe4c7

  Copy full SHA for 7afe4c7

Commits on Sep 17, 2024

• GH-800: add review 1 changes

  utkarshg6

  committed
  87a9e20

  Copy full SHA for 87a9e20

Commits on Sep 19, 2024

• GH-800: add review 2 changes

  utkarshg6

  committed
  34a42dc

  Copy full SHA for 34a42dc

Commits on Sep 20, 2024

• GH-800: add review 3 changes

  utkarshg6

  committed
  434fb5b

  Copy full SHA for 434fb5b

Commits on Sep 24, 2024

• GH-800: add review 4 changes

  utkarshg6

  committed
  1bfcfd8

  Copy full SHA for 1bfcfd8

Commits on Oct 8, 2024

• Merge branch 'master' into GH-800

  utkarshg6

  authored
  4bfe788

  Copy full SHA for 4bfe788

Commits on Oct 17, 2024

• Merge branch 'master' into GH-800

  utkarshg6

  authored
  cb50b90

  Copy full SHA for cb50b90

• GH-800: add better logging

  utkarshg6

  committed
  36f08df

  Copy full SHA for 36f08df

Commits on Oct 28, 2024

• GH-800: delay purge when the report_to_counterpart is false

  utkarshg6

  committed
  540d259

  Copy full SHA for 540d259

Commits on Oct 29, 2024

• GH-800: final changes

  utkarshg6

  committed
  9dfd4ea

  Copy full SHA for 9dfd4ea

Commits on Nov 18, 2024

• GH-800: review changes

  utkarshg6

  committed
  e7aaa34

  Copy full SHA for e7aaa34

Commits on Nov 25, 2024

• GH-800: fix the final comment discussion changes

  utkarshg6

  committed
  7e616e2

  Copy full SHA for 7e616e2

• GH-800: fix multiple_stream_zero_hop_test

  utkarshg6

  committed
  0a7d8b8

  Copy full SHA for 0a7d8b8

Commits on Nov 29, 2024

• Merge branch 'master' into GH-800

  utkarshg6

  authored
  328c24e

  Copy full SHA for 328c24e