| 89 | } |
| 90 | |
| 91 | bool HTTPWriter::send(shared_ptr<HTTPSender>& pSender) { |
| 92 | Exception ex; |
| 93 | if (pSender->newHeaders()) { |
| 94 | if (!_requestCount) |
| 95 | return false; |
| 96 | if(--_requestCount==0) |
| 97 | _pRequest.reset(); |
| 98 | } |
| 99 | _pThread = _session.send<HTTPSender>(ex, qos(),pSender,_pThread); |
| 100 | if (ex) |
| 101 | ERROR("HTTPSender flush, ", ex.error()) |
| 102 | pSender.reset(); |
| 103 | return true; |
| 104 | } |
| 105 | |
| 106 | bool HTTPWriter::flush() { |
| 107 |
nothing calls this directly
no test coverage detected