| 24 | namespace brpc { |
| 25 | |
| 26 | inline bool Socket::MoreReadEvents(int* progress) { |
| 27 | // Fail to CAS means that new events arrived. |
| 28 | return !_nevent.compare_exchange_strong( |
| 29 | *progress, 0, butil::memory_order_release, |
| 30 | butil::memory_order_acquire); |
| 31 | } |
| 32 | |
| 33 | inline void Socket::SetLogOff() { |
| 34 | if (!_logoff_flag.exchange(true, butil::memory_order_relaxed)) { |