jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #405 from CopernicaMarketingSoftware/40362 

Check if the callback is null again after flush()
This commit is contained in:
Emiel Bruijntjes 2021-07-12 13:36:02 +02:00 committed by GitHub
parent 6df80e3b32 0e6a1c52a9
commit ead7b7962e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
include/amqpcpp/channelimpl.h
View File

@ -675,13 +675,16 @@ public:
// flush the queue, which will send the next operation if the current operation was synchronous // flush the queue, which will send the next operation if the current operation was synchronous
flush(); flush();
// we are going to call callbacks that could destruct the channel
Monitor monitor(this);
// copy the callback (so that it will not be destructed during // copy the callback (so that it will not be destructed during
// the "reportSuccess" call, if the channel is destructed during the call) // the "reportSuccess" call, if the channel is destructed during the call)
auto cb = _oldestCallback; auto cb = _oldestCallback;
// the call to flush might have caused the callback to have been invoked; check once more
if (!cb) return false;
// we are going to call callbacks that could destruct the channel
Monitor monitor(this);
// call the callback // call the callback
auto next = cb->reportSuccess(std::forward<Arguments>(parameters)...); auto next = cb->reportSuccess(std::forward<Arguments>(parameters)...);