| 1584 | } |
| 1585 | |
| 1586 | void TServer::TRequest::SendReply(TData& data) { |
| 1587 | do { |
| 1588 | if (AtomicCas(&Replied_, 1, 0)) { |
| 1589 | Conn->SendResponse(RequestHeader().Id, data); |
| 1590 | return; |
| 1591 | } |
| 1592 | } while (AtomicGet(Replied_) == 0); |
| 1593 | } |
| 1594 | |
| 1595 | class TProtocol: public IProtocol { |
| 1596 | public: |
no test coverage detected