-
Notifications
You must be signed in to change notification settings - Fork 301
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
HPCC-18241 Remove unwanted spinlock in UDP collation #10399
HPCC-18241 Remove unwanted spinlock in UDP collation #10399
Conversation
12ca636
to
f8bcb96
Compare
d8c480a
to
2c33b0a
Compare
https://track.hpccsystems.com/browse/HPCC-18241 |
Should you also delete the streamingSupported boolean and the associated code? Is this something that would be worth adding back at some point? |
2c33b0a
to
0ccc7f9
Compare
streamingSupported is not directly related but seems like it is unused (probably has been for some time) so I'll remove at the same time. Should we add it back in? Possibly but would need a complete rethink about how to do it, and would probably make sense only as part of a migration of udplib to some other protocol or library. |
@ghalliday Ready to merge I think. Mark has tested on the FutureRoxie POC. |
roxie/udplib/udpmsgpk.cpp
Outdated
@@ -539,16 +532,15 @@ class CMessageCollator : implements IMessageCollator, public CInterface | |||
isNew = true; |
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.
minor: isNew is no longer used.
Semaphore is not signalled until the value is ready to safely read. If the value being read was liable to change after it was read, logic elsewhere would be wrong. Signed-off-by: Richard Chapman <rchapman@hpccsystems.com>
10004f6
to
14735a5
Compare
Automated Smoketest: ✅
Install hpccsystems-platform-community_6.4.2-rc2.el7.x86_64.rpm Unit tests result:
Regression test result:
HPCC Stop: OK |
Type of change:
Checklist:
Testing:
TBD