MRP protocol state machine issues #22
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
lhoward
force-pushed
the
x460-interop-issue
branch
4 times, most recently
from
8702180 to
5924f73
Compare
lhoward
force-pushed
the
x460-interop-issue
branch
3 times, most recently
from
bcb7247 to
33368db
Compare
lhoward
force-pushed
the
x460-interop-issue
branch
17 times, most recently
from
06c1b4a to
f0241d7
Compare
lhoward
force-pushed
the
x460-interop-issue
branch
from
f0241d7 to
594e098
Compare
lhoward
force-pushed
the
x460-interop-issue
branch
19 times, most recently
from
a496e87 to
3a9288b
Compare
lhoward
force-pushed
the
x460-interop-issue
branch
from
3a9288b to
51af223
Compare
…teners When a TalkerFailed attribute is received from an upstream bridge and local listeners exist, the merged listener declaration must be listenerAskingFailed regardless of the current listener states.
* when leaveNow() is called, it should behave as if the leavetimer has
immediately expired (35.2.6)
* always GC attributes after running the state machine handler
* _findRegisteredAttributes() returns an array of registered attributes
matching the specified filter
* remove application event handlers, this can be handled inside the
{join,leave}Indicated notification functions
* ensure rLA state machine run after processing inbound LA PDU
* fix transmission opportunity requests to be state-driven (note:
point-to-point optimization will need to be re-added at some point)
* isolate registrar and applicant handlers to participant's actor
The _updateExistingListeners function accommodates the race condition where listeners arrive before talkers, but it did not guard against the opposite race where a talker arrives and then immediately departs before port parameters can be updated.
The mutual exclusion logic for ensuring only one talker attribute type (talkerAdvertise or talkerFailed) exists per stream appeared in two locations with nearly identical code: once when handling peer events and once when propagating to other ports. This change extracts the common pattern into a private _enforceTalkerMutualExclusion helper function that handles both deregister (for peer events) and leave (for propagation) operations.
The _findTalkerRegistration(for:) method that searches across all participants was declared as throwing but never actually throws any errors, instead returning nil when no talker is found.
lhoward
force-pushed
the
x460-interop-issue
branch
from
51af223 to
1a0d43f
Compare
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
We are seeing a number of state machine issues with stream persistence in the following topology:
XMOS listener <-> OpenSRP <-> Extreme x460 <-> MOTU 16A (2025)
This PR tracks fixes for them.