| 445 | } |
| 446 | |
| 447 | HttpMessage::~HttpMessage() { |
| 448 | if (_body_reader) { |
| 449 | ProgressiveReader* saved_body_reader = _body_reader; |
| 450 | _body_reader = NULL; |
| 451 | // Successfully ended message is ended in OnMessageComplete() or |
| 452 | // SetBodyReader() and _body_reader should be null-ed. Non-null |
| 453 | // _body_reader here just means the socket is broken before completion |
| 454 | // of the message. |
| 455 | saved_body_reader->OnEndOfMessage( |
| 456 | butil::Status(ECONNRESET, "The socket was broken")); |
| 457 | } |
| 458 | } |
| 459 | |
| 460 | ssize_t HttpMessage::ParseFromArray(const char *data, const size_t length) { |
| 461 | if (Completed()) { |
nothing calls this directly
no test coverage detected