Code

Response Channels#1534

Code

Merged

mikeb01 merged 41 commits intoaeron-io:masteraeron-io/aeron:masterfrom mikeb01:feature/response_channelsmikeb01/Aeron:feature/response_channelsCopy head branch name to clipboardJan 15, 2024

+2,691-176

Commits

Commits on Dec 27, 2023

• [Java] Initial work on response channels.

  mikeb01

  committed
  18067e3

  Copy full SHA for 18067e3

• [Java] Start adding more client based operations to the ClientUriStringBuilder and add initial parts of a system test.

  mikeb01

  committed
  bfc7bc5

  Copy full SHA for bfc7bc5

• [Java] Partial implementation of handling multiple publications on the same endpoint.

  mikeb01

  committed
  d384e73

  Copy full SHA for d384e73

• [Java] Use new ControlMode.RESPONSE to indicate response channels.

  mikeb01

  committed
  28520b9

  Copy full SHA for 28520b9

• [Java] Add test to cover multiple terms with response channels.

  mikeb01

  committed
  ced2cfa

  Copy full SHA for ced2cfa

• [Java] Small tidy-ups and TODO comment.

  mikeb01

  committed
  3bbd82a

  Copy full SHA for 3bbd82a

• [Java] First basic implementation of connecting response channels.

  mikeb01

  committed
  90a7807

  Copy full SHA for 90a7807

• [Java] Stop sending RSP_SETUP message once response channel it connected.

  mikeb01

  committed
  a96f873

  Copy full SHA for a96f873

• [Java] Ensure that new subscription is only added once.

  mikeb01

  committed
  acb3de5

  Copy full SHA for acb3de5

• [Java] Remove println

  mikeb01

  committed
  9e37a82

  Copy full SHA for 9e37a82

• [Java] Updating ResponseClient/Server.

  mikeb01

  committed
  483d6b0

  Copy full SHA for 483d6b0

• [Java] Test showing that messages will come back to individual sessions.

  mikeb01

  committed
  9300eaa

  Copy full SHA for 9300eaa

• [Java] Add additional validation for response channel settings and rewrite some tests.

  mikeb01

  committed
  db737d4

  Copy full SHA for db737d4

• [Java] Use the response correlation id as part of the matching criteria when finding existing publications.

  mikeb01

  committed
  cf00344

  Copy full SHA for cf00344

• [Java] Check that the subscription exists when setting the response-correlation-id on the request publication.

  mikeb01

  committed
  af4d1b1

  Copy full SHA for af4d1b1

• [Java] Remove TODO.

  mikeb01

  committed
  eebb98e

  Copy full SHA for eebb98e

• [Java] Fix CodeQL issues.

  mikeb01

  committed
  060de88

  Copy full SHA for 060de88

• [Java] Disable ResponseChannelsTest for C/C++ build.

  mikeb01

  committed
  4d09bd1

  Copy full SHA for 4d09bd1

• [Java] Test to show that multiple publications to the same response channel can be created.

  mikeb01

  committed
  8b4bc4d

  Copy full SHA for 8b4bc4d

• [Java] Update error message.

  mikeb01

  committed
  e2bf277

  Copy full SHA for e2bf277

• [Java] Change RSP_SETUP message type to allow for ATS messages. Add ATS constants to Java definitions for completeness.

  mikeb01

  committed
  941cc0f

  Copy full SHA for 941cc0f

• [C] Start adding C implementation for response channels. Add response setup message and constants.

  mikeb01

  committed
  debf879

  Copy full SHA for debf879

• [C] More progress toward response channels.

  mikeb01

  committed
  7972647

  Copy full SHA for 7972647

• [C] Additional error reporting. Only set SEND_RESPONSE_FLAG if the publication is not for a response channel.

  mikeb01

  committed
  89df7f0

  Copy full SHA for 89df7f0

• [C] Allow defaulting when parsing 64 bit uri parameters. Add additional validation to verify response-correlation-id uri parameters.

  mikeb01

  committed
  0bc5b7e

  Copy full SHA for 0bc5b7e

Commits on Dec 28, 2023

• [Java] Fix checkstyle.

  mikeb01

  committed
  253ccf6

  Copy full SHA for 253ccf6

Commits on Dec 29, 2023

• [Java] Add test to ensure that pending response subscription don't become connected before they should. Make sure that response SubscriptionLinks that having been linked to a publication don't match.

  mikeb01

  committed
  663f325

  Copy full SHA for 663f325

• [C] Make sure that response SubscriptionLinks that haven't been linked to a publication don't match.

  mikeb01

  committed
  6f56edb

  Copy full SHA for 6f56edb

• [Java] Start implementing dissector for RSP_SETUP frames.

  mikeb01

  committed
  ec0b453

  Copy full SHA for ec0b453

• [Java] Add dissector for RSP_SETUP frame.

  mikeb01

  committed
  47c1a8f

  Copy full SHA for 47c1a8f

Commits on Jan 3, 2024

• [C] Add dissector for RSP_SETUP frame.

  mikeb01

  committed
  b1cc283

  Copy full SHA for b1cc283

Commits on Jan 9, 2024

• [Java] Fix documentation.

  mikeb01

  committed
  ba5deb8

  Copy full SHA for ba5deb8

• [Java] Remove double read of volatile and reverse elements of condition.

  mikeb01

  committed
  04ce545

  Copy full SHA for 04ce545

• [C] Remove debug logging.

  mikeb01

  committed
  202590a

  Copy full SHA for 202590a

Commits on Jan 10, 2024

• [C] Remove test.

  mikeb01

  committed
  af8e3d5

  Copy full SHA for af8e3d5

Commits on Jan 11, 2024

• [Java] Add reference tracking on the ReceiveChannelEndpoint for unconnected response channels to prevent endpoints being closed at the wrong time.

  mikeb01

  committed
  91004ca

  Copy full SHA for 91004ca

Commits on Jan 12, 2024

• [Java] Reverse order of adding connected response stream and decrementing placeholder for the response stream.

  mikeb01

  committed
  27e395d

  Copy full SHA for 27e395d

• [C] Reverse order of adding connected response stream and decrementing placeholder for the response stream.

  mikeb01

  committed
  7621dcd

  Copy full SHA for 7621dcd

Commits on Jan 15, 2024

• [C] Resolve publication image before getting the network publication so failure doesn't result in leaking resources.

  mikeb01

  committed
  8731c44

  Copy full SHA for 8731c44

• [C] Delete udp_channel on failure.

  mikeb01

  committed
  fe88326

  Copy full SHA for fe88326

• [Java] Close session when removing in ResponseServer example.

  mikeb01

  committed
  3db5e74

  Copy full SHA for 3db5e74