Skip to content

Various micro perf fixes and cleanup found while implementing CN overrides so far #818

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.

Sign up for GitHub

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

Merged
merged 16 commits into from
Aug 3, 2018
Merged

Various micro perf fixes and cleanup found while implementing CN overrides so far #818

Show file tree
Hide file tree
Changes from 5 commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
fd06a69
Microperf: Use lock_guard instead of unique_lock.
BillyONeal Jul 26, 2018
ccf8e16
Bill hates lock_guard more.
BillyONeal Jul 26, 2018
f1a1678
Ref them connections.
BillyONeal Jul 26, 2018
0c16592
Demacroize.
BillyONeal Jul 26, 2018
a36e368
Commonize port and merge some CRLFs into adjacent string literals.
BillyONeal Jul 26, 2018
0ff6d4a
Add missing template keyword.
BillyONeal Jul 27, 2018
719e40d
Avoid stringstream in constructing the proxy_str.
BillyONeal Jul 27, 2018
34d85cf
Remove unused forward declarations of some HTTP things.
BillyONeal Jul 30, 2018
3d9b3f8
Use NOMINMAX instead of undef min and max everywhere.
BillyONeal Jul 30, 2018
6a55deb
Bunch of inheritance hygiene.
BillyONeal Jul 30, 2018
0f86d9e
What do you mean you want examples to compile?
BillyONeal Jul 30, 2018
3ab08a5
More CR comments from Robert.
BillyONeal Jul 30, 2018
beb660c
Add static.
BillyONeal Jul 30, 2018
6788781
Use existing to_string_t.
BillyONeal Jul 31, 2018
12ea5ce
Merge remote-tracking branch 'upstream/master' into perf_fixes
BillyONeal Aug 1, 2018
cc9daf0
Merge remote-tracking branch 'upstream/master' into perf_fixes
BillyONeal Aug 2, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions Release/libs/websocketpp/examples/broadcast_server/broadcast_server.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ using websocketpp::lib::bind;

using websocketpp::lib::thread;
using websocketpp::lib::mutex;
using websocketpp::lib::unique_lock;
using websocketpp::lib::lock_guard;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is part of the vendored copy of websocketpp, so we should avoid modifying it.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I see, I'll revert changes in this example.

using websocketpp::lib::condition_variable;

/* on_open insert connection_hdl into channel
Expand Down Expand Up @@ -71,15 +71,15 @@ class broadcast_server {
}

void on_open(connection_hdl hdl) {
unique_lock<mutex> lock(m_action_lock);
lock_guard<mutex> lock(m_action_lock);
//std::cout << "on_open" << std::endl;
m_actions.push(action(SUBSCRIBE,hdl));
lock.unlock();
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hmmm apparently this isn't built?

m_action_cond.notify_one();
}

void on_close(connection_hdl hdl) {
unique_lock<mutex> lock(m_action_lock);
lock_guard<mutex> lock(m_action_lock);
//std::cout << "on_close" << std::endl;
m_actions.push(action(UNSUBSCRIBE,hdl));
lock.unlock();
Expand All @@ -88,7 +88,7 @@ class broadcast_server {

void on_message(connection_hdl hdl, server::message_ptr msg) {
// queue message up for sending by processing thread
unique_lock<mutex> lock(m_action_lock);
lock_guard<mutex> lock(m_action_lock);
//std::cout << "on_message" << std::endl;
m_actions.push(action(MESSAGE,hdl,msg));
lock.unlock();
Expand All @@ -97,7 +97,7 @@ class broadcast_server {

void process_messages() {
while(1) {
unique_lock<mutex> lock(m_action_lock);
lock_guard<mutex> lock(m_action_lock);

while(m_actions.empty()) {
m_action_cond.wait(lock);
Expand All @@ -109,13 +109,13 @@ class broadcast_server {
lock.unlock();

if (a.type == SUBSCRIBE) {
unique_lock<mutex> con_lock(m_connection_lock);
lock_guard<mutex> con_lock(m_connection_lock);
m_connections.insert(a.hdl);
} else if (a.type == UNSUBSCRIBE) {
unique_lock<mutex> con_lock(m_connection_lock);
lock_guard<mutex> con_lock(m_connection_lock);
m_connections.erase(a.hdl);
} else if (a.type == MESSAGE) {
unique_lock<mutex> con_lock(m_connection_lock);
lock_guard<mutex> con_lock(m_connection_lock);

con_list::iterator it;
for (it = m_connections.begin(); it != m_connections.end(); ++it) {
Expand Down
Loading