| 232 | |
| 233 | struct TLink: public TAtomicRefCount<TLink> { |
| 234 | inline TLink(TServer* parent, const TAcceptFull& a) |
| 235 | : P(parent) |
| 236 | , MQ(Executor()) |
| 237 | { |
| 238 | S.Swap(*a.S); |
| 239 | SetNoDelay(S, true); |
| 240 | |
| 241 | RemoteHost = PrintHostByRfc(*GetPeerAddr(S)); |
| 242 | |
| 243 | TLinkRef self(this); |
| 244 | |
| 245 | Executor()->Create<TLink, &TLink::RecvCycle>(this, "recv"); |
| 246 | Executor()->Create<TLink, &TLink::SendCycle>(this, "send"); |
| 247 | |
| 248 | Executor()->Running()->Yield(); |
| 249 | } |
| 250 | |
| 251 | inline void Enqueue(TResponcePtr res) { |
| 252 | MQ.Enqueue(res); |
nothing calls this directly
no test coverage detected