| 875 | } |
| 876 | |
| 877 | CtPtr ProtocolV1::handle_message_data(char *buffer, int r) { |
| 878 | ldout(cct, 20) << __func__ << " r=" << r << dendl; |
| 879 | |
| 880 | if (r < 0) { |
| 881 | ldout(cct, 1) << __func__ << " read data error " << dendl; |
| 882 | return _fault(); |
| 883 | } |
| 884 | |
| 885 | auto bp = data_blp.get_current_ptr(); |
| 886 | unsigned read_len = std::min(bp.length(), msg_left); |
| 887 | ceph_assert(read_len < |
| 888 | static_cast<unsigned>(std::numeric_limits<int>::max())); |
| 889 | data_blp += read_len; |
| 890 | data.append(bp, 0, read_len); |
| 891 | msg_left -= read_len; |
| 892 | |
| 893 | return CONTINUE(read_message_data); |
| 894 | } |
| 895 | |
| 896 | CtPtr ProtocolV1::read_message_footer() { |
| 897 | ldout(cct, 20) << __func__ << dendl; |
nothing calls this directly
no test coverage detected