Skip to content
Permalink
Browse files

Merge PR #3201: MurmurGRPCImpl.h: declare variable for QMutexLocker i…

…n RPCSingleStreamCall class.
  • Loading branch information...
mkrautz committed Jul 27, 2017
2 parents ec61c2b + daca82c commit 2724ff59489516caf834849c4f31e5f0a18c2626
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/murmur/MurmurGRPCImpl.h
@@ -206,7 +206,7 @@ class RPCSingleStreamCall : public RPCCall {
}

void write(const OutType &msg, void *tag) {
QMutexLocker(&RPCSingleStreamCall::m_writeLock);
QMutexLocker l(&m_writeLock);
if (m_writeQueue.size() > 0) {
m_writeQueue.enqueue(qMakePair(msg, tag));
} else {
@@ -222,7 +222,7 @@ class RPCSingleStreamCall : public RPCCall {
}

void writeCallback(bool ok) {
QMutexLocker(&RPCSingleStreamCall::m_writeLock);
QMutexLocker l(&m_writeLock);
auto processed = m_writeQueue.dequeue();
if (processed.second) {
auto cb = static_cast< ::boost::function<void(bool)> *>(processed.second);

0 comments on commit 2724ff5

Please sign in to comment.
You can’t perform that action at this time.