| 72 | } |
| 73 | |
| 74 | inline void Socket::SetEOF() { |
| 75 | uint32_t nref = _ninprocess.fetch_or(EOF_FLAG, butil::memory_order_relaxed); |
| 76 | if ((nref & EOF_FLAG) == 0) { |
| 77 | // Release the additional reference in `_ninprocess' |
| 78 | CheckEOFInternal(); |
| 79 | } |
| 80 | } |
| 81 | |
| 82 | inline void Socket::reset_parsing_context(Destroyable* new_context) { |
| 83 | Destroyable* old_ctx = _parsing_context.exchange( |