diff options
Diffstat (limited to 'app/src/rawio.c')
| -rw-r--r-- | app/src/rawio.c | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/app/src/rawio.c b/app/src/rawio.c index d322b49..4a17e4f 100644 --- a/app/src/rawio.c +++ b/app/src/rawio.c @@ -23,8 +23,8 @@ static inline unsigned int packet_total_len(struct rte_mbuf * mbufs[], unsigned return total_len; } -int mrapp_packet_fast_send_burst(struct mr_instance * instance, - struct vdev_instance * vdi, queue_id_t qid, struct rte_mbuf * mbufs[], int nr_mbufs) +int mrapp_packet_fast_send_burst(struct mr_instance * instance, struct vdev_instance * vdi, queue_id_t qid, + struct rte_mbuf * mbufs[], int nr_mbufs) { hash_t mbufs_hash[MR_BURST_MAX]; for (int i = 0; i < nr_mbufs; i++) @@ -103,10 +103,10 @@ int marsio_recv_burst(struct mr_vdev * vdev, queue_id_t qid, marsio_buff_t * mbu { mbufs[i] = rx_buffer->mbufs[rx_buffer->curser + i]; - if (unlikely(marsio_dp_trace_record_can_emit(mbufs[i]))) + if (unlikely(marsio_dp_trace_measurements_can_emit(vdev->instance, mbufs[i], DP_TRACE_MEASUREMENT_TYPE_TRACE))) { - marsio_dp_trace_record_emit_fmt(vdev->instance, mbufs[i], "marsio_recv", "packet rx, dev=%s, qid=%u", - vdev->devsym, qid); + marsio_dp_trace_measurement_emit_fmt(vdev->instance, mbufs[i], DP_TRACE_MEASUREMENT_TYPE_TRACE, + "marsio_recv", "packet rx, dev=%s, qid=%u", vdev->devsym, qid); } } @@ -142,10 +142,11 @@ int marsio_send_buffer_flush(struct mr_vdev * vdev, queue_id_t sid) for (int i = 0; i < tx_buffer->length; i++) { hash[i] = tx_buffer->mbufs[i]->hash.usr; - if (marsio_dp_trace_record_can_emit(tx_buffer->mbufs[i])) + if (marsio_dp_trace_measurements_can_emit(instance, tx_buffer->mbufs[i], DP_TRACE_MEASUREMENT_TYPE_TRACE)) { - marsio_dp_trace_record_emit_fmt(vdev->instance, tx_buffer->mbufs[i], "marsio_send", - "packet tx, dev=%s , qid=%u, hash=%u", vdev->devsym, sid, hash[i]); + marsio_dp_trace_measurement_emit_fmt(vdev->instance, tx_buffer->mbufs[i], DP_TRACE_MEASUREMENT_TYPE_TRACE, + "marsio_send", "packet tx, dev=%s , qid=%u, hash=%u", vdev->devsym, + sid, hash[i]); } } |