| 16 | } |
| 17 | |
| 18 | bool res_callback::read_callback(char* data, int len) |
| 19 | { |
| 20 | if (req_ == NULL) |
| 21 | { |
| 22 | logger_warn("client peer disconnected!"); |
| 23 | return false; |
| 24 | } |
| 25 | |
| 26 | // ȡ�ÿͻ����������������ӷ���˷���������д�� |
| 27 | acl::aio_socket_stream& peer = req_->get_conn(); |
| 28 | peer.write(data, len); |
| 29 | |
| 30 | // ������ͬʱд�뱾����Ӧ�����ļ� |
| 31 | if (res_fp_) |
| 32 | res_fp_->write(data, len); |
| 33 | |
| 34 | return true; |
| 35 | } |
| 36 | |
| 37 | void res_callback::close_callback() |
| 38 | { |