diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Decoder.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Decoder.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/cluster/Decoder.cpp b/cpp/src/qpid/cluster/Decoder.cpp index 6f65b3852a..a57edb3b7f 100644 --- a/cpp/src/qpid/cluster/Decoder.cpp +++ b/cpp/src/qpid/cluster/Decoder.cpp @@ -57,4 +57,9 @@ void Decoder::erase(const ConnectionId& c) { map.erase(c); } +framing::FrameDecoder& Decoder::get(const ConnectionId& c) { + sys::Mutex::ScopedLock l(lock); + return map[c]; +} + }} // namespace qpid::cluster |