| 40 | } |
| 41 | |
| 42 | uint64_t DispatchQueue::pre_dispatch(const ref_t<Message>& m) |
| 43 | { |
| 44 | ldout(cct,1) << "<== " << m->get_source_inst() |
| 45 | << " " << m->get_seq() |
| 46 | << " ==== " << *m |
| 47 | << " ==== " << m->get_payload().length() |
| 48 | << "+" << m->get_middle().length() |
| 49 | << "+" << m->get_data().length() |
| 50 | << " (" << ceph_con_mode_name(m->get_connection()->get_con_mode()) |
| 51 | << " " << m->get_footer().front_crc << " " |
| 52 | << m->get_footer().middle_crc |
| 53 | << " " << m->get_footer().data_crc << ")" |
| 54 | << " " << m << " con " << m->get_connection() |
| 55 | << dendl; |
| 56 | uint64_t msize = m->get_dispatch_throttle_size(); |
| 57 | m->set_dispatch_throttle_size(0); // clear it out, in case we requeue this message. |
| 58 | return msize; |
| 59 | } |
| 60 | |
| 61 | void DispatchQueue::post_dispatch(const ref_t<Message>& m, uint64_t msize) |
| 62 | { |
nothing calls this directly
no test coverage detected