(err error)
| 332 | } |
| 333 | |
| 334 | func (rp *http2RespWriter) WriteErrorResponse(err error) bool { |
| 335 | if rp.statusWritten { |
| 336 | return false |
| 337 | } |
| 338 | |
| 339 | if errors.Is(err, cfdflow.ErrTooManyActiveFlows) { |
| 340 | rp.setResponseMetaHeader(responseMetaHeaderCfdFlowRateLimited) |
| 341 | } else { |
| 342 | rp.setResponseMetaHeader(responseMetaHeaderCfd) |
| 343 | } |
| 344 | rp.w.WriteHeader(http.StatusBadGateway) |
| 345 | rp.statusWritten = true |
| 346 | |
| 347 | return true |
| 348 | } |
| 349 | |
| 350 | func (rp *http2RespWriter) setResponseMetaHeader(value string) { |
| 351 | rp.w.Header().Set(CanonicalResponseMetaHeader, value) |
no test coverage detected