| 199 | vector<std::string> ContentTypeHandler::_content_type_allowlist; |
| 200 | |
| 201 | bool |
| 202 | InterceptData::init(TSVConn vconn) |
| 203 | { |
| 204 | if (initialized) { |
| 205 | LOG_ERROR("InterceptData already initialized!"); |
| 206 | return false; |
| 207 | } |
| 208 | |
| 209 | net_vc = vconn; |
| 210 | |
| 211 | input.buffer = TSIOBufferCreate(); |
| 212 | input.reader = TSIOBufferReaderAlloc(input.buffer); |
| 213 | input.vio = TSVConnRead(net_vc, contp, input.buffer, INT64_MAX); |
| 214 | |
| 215 | req_hdr_bufp = TSMBufferCreate(); |
| 216 | req_hdr_loc = TSHttpHdrCreate(req_hdr_bufp); |
| 217 | TSHttpHdrTypeSet(req_hdr_bufp, req_hdr_loc, TS_HTTP_TYPE_REQUEST); |
| 218 | |
| 219 | fetcher = new HttpDataFetcherImpl(contp, creq.client_addr, "combohandler_fetcher"); |
| 220 | |
| 221 | initialized = true; |
| 222 | LOG_DEBUG("InterceptData initialized!"); |
| 223 | return true; |
| 224 | } |
| 225 | |
| 226 | void |
| 227 | InterceptData::setupWrite() |
no test coverage detected