Commit 532b8c01 authored by Maxim Georgiev's avatar Maxim Georgiev Committed by Facebook Github Bot

Allow error message callback cancellation regardless of socket state.

Summary: We should be able to reset error message callback in AsyncSocket evein if the socket is closed yet. It's common to keep callback installed while the socket is connected. Once the socket is closed, the deinitialization process starts. If the callback callee component gets deallocated before the socket object is deallocated, it should be able to cancel callbacks.

Reviewed By: yfeldblum

Differential Revision: D4897335

fbshipit-source-id: 8eee26f9ebcb78a01d55598be3aff6595a3ed852
parent 5da6f8de
...@@ -612,7 +612,7 @@ void AsyncSocket::setErrMessageCB(ErrMessageCallback* callback) { ...@@ -612,7 +612,7 @@ void AsyncSocket::setErrMessageCB(ErrMessageCallback* callback) {
<< ", fd=" << fd_ << ", callback=" << callback << ", fd=" << fd_ << ", callback=" << callback
<< ", state=" << state_; << ", state=" << state_;
// Short circuit if callback is the same as the existing timestampCallback_. // Short circuit if callback is the same as the existing errMessageCallback_.
if (callback == errMessageCallback_) { if (callback == errMessageCallback_) {
return; return;
} }
...@@ -625,6 +625,14 @@ void AsyncSocket::setErrMessageCB(ErrMessageCallback* callback) { ...@@ -625,6 +625,14 @@ void AsyncSocket::setErrMessageCB(ErrMessageCallback* callback) {
DestructorGuard dg(this); DestructorGuard dg(this);
assert(eventBase_->isInEventBaseThread()); assert(eventBase_->isInEventBaseThread());
if (callback == nullptr) {
// We should be able to reset the callback regardless of the
// socket state. It's important to have a reliable callback
// cancellation mechanism.
errMessageCallback_ = callback;
return;
}
switch ((StateEnum)state_) { switch ((StateEnum)state_) {
case StateEnum::CONNECTING: case StateEnum::CONNECTING:
case StateEnum::FAST_OPEN: case StateEnum::FAST_OPEN:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment