-
Notifications
You must be signed in to change notification settings - Fork 35
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
buffer stream signals #284
Conversation
25871a9
to
d100ce6
Compare
Pull Request Test Coverage Report for Build 9207770123Details
💛 - Coveralls |
d100ce6
to
09c3d0c
Compare
09c3d0c
to
d24a795
Compare
d24a795
to
a2a9aa9
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Might need a copyright header in this file.
), | ||
ok = quicer:controlling_process(S, self()), | ||
{ok, NewOwner} = quicer:get_stream_owner(S), | ||
NewOwner = self(), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Q: isn't the owner self()
in the first place, so that controlling_process
doesn't change?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
quicer:controlling_process will not skip owner change even when old owner is the new owner.
The point in this test is quicer_nif:mock_buffer_sig(S, Pid, {Ref, Term})
simulates the {Ref, Term} is supposed to be sent to the Pid.
QUIC stream data is ensured ordered and lossless during stream handoff from old owner process to the new owner process.
This PR makes QUIC stream signals also ordered so that old owner does not need to take care of the
inflight
messages during the handoff.The new
quicer_owner_queue
things could be reused to later implement the sig queues for the quic connections.