gfwleak/tango-tsg-service-chaining-engine
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bypass_traffic只在nf_sce网卡生效

Browse Source
This commit is contained in:
luwenpeng
2023-11-24 18:53:58 +08:00
parent eedd18183e
commit 699be92862
1 changed files with 0 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
platform/src/packet_io.cpp
View File

@@ -1570,20 +1570,6 @@ int packet_io_thread_polling_endpoint_l3(struct packet_io *handle, struct thread
return 0; return 0;
} }
if (handle->config.bypass_traffic == 1)
{
for (int j = 0; j < nr_recv; j++)
{
int raw_len = marsio_buff_datalen(rx_buffs[j]);
THROUGHPUT_METRICS_INC(&(thread_metrics->endpoint_vxlan_rx), 1, raw_len);
THROUGHPUT_METRICS_INC(&(thread_metrics->endpoint_vxlan_tx), 1, raw_len);
}
marsio_send_burst(handle->dev_endpoint_l3.mr_path, thread_index, rx_buffs, nr_recv);
return nr_recv;
}
for (int j = 0; j < nr_recv; j++) for (int j = 0; j < nr_recv; j++)
{ {
marsio_buff_t *rx_buff = rx_buffs[j]; marsio_buff_t *rx_buff = rx_buffs[j];
@@ -1620,20 +1606,6 @@ int packet_io_thread_polling_endpoint_l2(struct packet_io *handle, struct thread
return 0; return 0;
} }
if (handle->config.bypass_traffic == 1)
{
for (int j = 0; j < nr_recv; j++)
{
int raw_len = marsio_buff_datalen(rx_buffs[j]);
THROUGHPUT_METRICS_INC(&(thread_metrics->endpoint_vlan_rx), 1, raw_len);
THROUGHPUT_METRICS_INC(&(thread_metrics->endpoint_vlan_tx), 1, raw_len);
}
marsio_send_burst(handle->dev_endpoint_l2.mr_path, thread_index, rx_buffs, nr_recv);
return nr_recv;
}
for (int j = 0; j < nr_recv; j++) for (int j = 0; j < nr_recv; j++)
{ {
marsio_buff_t *rx_buff = rx_buffs[j]; marsio_buff_t *rx_buff = rx_buffs[j];