-
Notifications
You must be signed in to change notification settings - Fork 59
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
Remove conn.mux #173
Remove conn.mux #173
Conversation
c8b4c29
to
89d356a
Compare
There's a failure in our websockets negotiation, I have a draft PR with my branch that merges in your changes: |
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.
Some intermediate comments, still reviewing.
d8c6e5e
to
30a8de2
Compare
9975484
to
ada9e2b
Compare
ada9e2b
to
101ebb6
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.
A few comments. There's enough here now that it's worth running the live tests against this version of go-amqp. I can walk you through that when you're ready.
Test |
Test bug, fix pending. |
0e27105
to
f0007e0
Compare
f0007e0
to
c2c1d89
Compare
Switching back to draft for now as I want to wait to merge this until after the API clean-up changes are in and released. |
c2c1d89
to
17cf732
Compare
17cf732
to
d5013f2
Compare
14e0e7b
to
07fd837
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.
It's really looking good to me. It's in the heart of the AMQP stack though, so we should probably come up with some more extreme cases for testing as well since SB and EH don't necessarily push the boundaries too much in normal operation.
I also left some comments in spots where there might be perf bottlenecks that we could investigate as well.
conn.connReader() dispatches frames directly to sessions now. Added conn.NextSession() and conn.DeleteSession() for deterministic session management. Channel numbers are now recycled immediately which prompted a fix for TestSessionClose. Fixed various tests to handle close frame (the error was being swallowed before). Tests that utilize testconn were silently failing due to a bug in Conn.Read which has been fixed.
fixed propagation of RemoteErr on close
23e4d07
to
e23e655
Compare
conn.connReader() dispatches frames directly to sessions now.
Added conn.NextSession() and conn.DeleteSession() for deterministic
session management.
Channel numbers are now recycled immediately which prompted a fix for
TestSessionClose.
Fixed various tests to handle close frame (the error was being swallowed
before).
Tests that utilize testconn were silently failing due to a bug in
Conn.Read which has been fixed.
Fixes #164