| 401 | |
| 402 | |
| 403 | bool canSend(Exception& ex) { |
| 404 | lock_guard<mutex> lock(_mutexAsync); |
| 405 | return !_connecting && _senders.empty(); |
| 406 | } |
| 407 | |
| 408 | bool addSender(Exception& ex,const shared_ptr<SocketSender>& pSender) { |
| 409 | lock_guard<recursive_mutex> lock(_mutexManaged); |