| 197 | } |
| 198 | |
| 199 | void InputMessageClosure::reset(InputMessageBase* m) { |
| 200 | if (_msg) { |
| 201 | ProcessInputMessage(_msg); |
| 202 | } |
| 203 | _msg = m; |
| 204 | } |
| 205 | |
| 206 | int InputMessenger::ProcessNewMessage( |
| 207 | Socket* m, ssize_t bytes, bool read_eof, |
no test coverage detected