summaryrefslogtreecommitdiffstats
path: root/src/stateless/rx
diff options
context:
space:
mode:
authorimarom <imarom@cisco.com>2017-01-24 14:11:32 +0200
committerimarom <imarom@cisco.com>2017-01-24 14:11:32 +0200
commit19df06349d311377ca1ef10f91ef1f786b41418b (patch)
tree3c5fa2e76fd5dd0dff370df7013e757e289b1ac5 /src/stateless/rx
parent418fd3d0a7169f2d8934e8be82d11e1a388d681c (diff)
code review cleanups - C++
Signed-off-by: imarom <imarom@cisco.com>
Diffstat (limited to 'src/stateless/rx')
-rw-r--r--src/stateless/rx/trex_stateless_capture.cpp8
-rw-r--r--src/stateless/rx/trex_stateless_capture.h15
-rw-r--r--src/stateless/rx/trex_stateless_rx_port_mngr.cpp2
3 files changed, 16 insertions, 9 deletions
diff --git a/src/stateless/rx/trex_stateless_capture.cpp b/src/stateless/rx/trex_stateless_capture.cpp
index f0d4e806..7b020444 100644
--- a/src/stateless/rx/trex_stateless_capture.cpp
+++ b/src/stateless/rx/trex_stateless_capture.cpp
@@ -157,14 +157,14 @@ TrexStatelessCaptureMngr::start(const CaptureFilter &filter, uint64_t limit, Tre
int new_id = m_id_counter++;
- TrexStatelessCapture *new_buffer = new TrexStatelessCapture(new_id, limit, filter);
- m_captures.push_back(new_buffer);
+ TrexStatelessCapture *new_capture = new TrexStatelessCapture(new_id, limit, filter);
+ m_captures.push_back(new_capture);
/* update global filter */
update_global_filter();
/* result */
- rc.set_new_id(new_id);
+ rc.set_rc(new_id, new_capture->get_start_ts());
}
void
@@ -176,7 +176,7 @@ TrexStatelessCaptureMngr::stop(capture_id_t capture_id, TrexCaptureRCStop &rc) {
}
capture->stop();
- rc.set_count(capture->get_pkt_count());
+ rc.set_rc(capture->get_pkt_count());
}
void
diff --git a/src/stateless/rx/trex_stateless_capture.h b/src/stateless/rx/trex_stateless_capture.h
index 0f98fd95..852aee2a 100644
--- a/src/stateless/rx/trex_stateless_capture.h
+++ b/src/stateless/rx/trex_stateless_capture.h
@@ -83,23 +83,30 @@ public:
class TrexCaptureRCStart : public TrexCaptureRC {
public:
- void set_new_id(capture_id_t new_id) {
- m_capture_id = new_id;
- m_rc = RC_OK;
+ void set_rc(capture_id_t new_id, dsec_t start_ts) {
+ m_capture_id = new_id;
+ m_start_ts = start_ts;
+ m_rc = RC_OK;
+
}
capture_id_t get_new_id() const {
return m_capture_id;
}
+ dsec_t get_start_ts() const {
+ return m_start_ts;
+ }
+
private:
capture_id_t m_capture_id;
+ dsec_t m_start_ts;
};
class TrexCaptureRCStop : public TrexCaptureRC {
public:
- void set_count(uint32_t pkt_count) {
+ void set_rc(uint32_t pkt_count) {
m_pkt_count = pkt_count;
m_rc = RC_OK;
}
diff --git a/src/stateless/rx/trex_stateless_rx_port_mngr.cpp b/src/stateless/rx/trex_stateless_rx_port_mngr.cpp
index ede86062..b01665ec 100644
--- a/src/stateless/rx/trex_stateless_rx_port_mngr.cpp
+++ b/src/stateless/rx/trex_stateless_rx_port_mngr.cpp
@@ -492,7 +492,7 @@ RXServer::duplicate_mbuf(const rte_mbuf_t *m) {
}
/* copy data */
- copy_mbuf(dest, m);
+ mbuf_to_buffer(dest, m);
return clone_mbuf;
}