| 15 | |
| 16 | protected: |
| 17 | void* run(void) |
| 18 | { |
| 19 | char* s = new char[len_ + 1]; |
| 20 | memset(s, 'x', len_); |
| 21 | s[len_] = 0; |
| 22 | |
| 23 | for (int i = 0; i < count_; i++) { |
| 24 | if (pool_.send(s, len_) == false) { |
| 25 | printf("send to %s error %s\r\n", |
| 26 | pool_.get_addr(), acl::last_serror()); |
| 27 | break; |
| 28 | } |
| 29 | } |
| 30 | |
| 31 | delete []s; |
| 32 | return NULL; |
| 33 | } |
| 34 | |
| 35 | private: |
| 36 | acl::tcp_pool& pool_; |
nothing calls this directly
no test coverage detected