| 175 | |
| 176 | struct TRequest: public IRequest { |
| 177 | inline TRequest(const TLinkRef& link, IInputStream& in, size_t len) |
| 178 | : Link(link) |
| 179 | { |
| 180 | Buf.Proceed(len); |
| 181 | in.Load(Buf.Data(), Buf.Size()); |
| 182 | if ((ServiceBegin() - Buf.Data()) + ServiceLen() > Buf.Size()) { |
| 183 | throw yexception() << "invalid request (service len)"; |
| 184 | } |
| 185 | } |
| 186 | |
| 187 | TStringBuf Scheme() const override { |
| 188 | return TStringBuf("tcp"); |
nothing calls this directly
no test coverage detected