gfwleak/tango-kni
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改kni_polling_all_entry 返回值

Browse Source
This commit is contained in:
fumingwei
2020-10-17 17:35:46 +08:00
parent 39252e79c3
commit 3f20d93a4a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
entry/src/kni_entry.cpp
View File

@@ -1729,7 +1729,7 @@ int tuple2stream_htable_search(MESA_htable_handle handle, struct ethhdr *ether_h
extern "C" char kni_polling_all_entry(const struct streaminfo *stream, void** pme, int thread_seq, const void* a_packet){ extern "C" char kni_polling_all_entry(const struct streaminfo *stream, void** pme, int thread_seq, const void* a_packet){
void *logger = g_kni_handle->local_logger; void *logger = g_kni_handle->local_logger;
MESA_htable_handle tuple2stream_htable = g_kni_handle->threads_handle[thread_seq].tuple2stream_htable; MESA_htable_handle tuple2stream_htable = g_kni_handle->threads_handle[thread_seq].tuple2stream_htable;
int flag = 0; int flag = POLLING_STATE_IDLE;
//normal mode //normal mode
if(g_kni_handle->deploy_mode == KNI_DEPLOY_MODE_NORMAL){ if(g_kni_handle->deploy_mode == KNI_DEPLOY_MODE_NORMAL){
//polling tfe //polling tfe
@@ -1745,7 +1745,7 @@ extern "C" char kni_polling_all_entry(const struct streaminfo *stream, void** pm
for(int j = 0; j < nr_recv; j++){ for(int j = 0; j < nr_recv; j++){
struct ethhdr *ether_hdr = (struct ethhdr*)marsio_buff_mtod(rx_buffs[j]); struct ethhdr *ether_hdr = (struct ethhdr*)marsio_buff_mtod(rx_buffs[j]);
tuple2stream_htable_search(tuple2stream_htable, ether_hdr, thread_seq); tuple2stream_htable_search(tuple2stream_htable, ether_hdr, thread_seq);
flag = 1; flag = POLLING_STATE_WORK;
} }
marsio_buff_free(g_kni_handle->marsio_handle->instance, rx_buffs, nr_recv, 0, 0); marsio_buff_free(g_kni_handle->marsio_handle->instance, rx_buffs, nr_recv, 0, 0);
} }
@@ -1761,7 +1761,7 @@ extern "C" char kni_polling_all_entry(const struct streaminfo *stream, void** pm
if(ret > 0){ if(ret > 0){
struct ethhdr *ether_hdr = (struct ethhdr*)buff; struct ethhdr *ether_hdr = (struct ethhdr*)buff;
tuple2stream_htable_search(tuple2stream_htable, ether_hdr, thread_seq); tuple2stream_htable_search(tuple2stream_htable, ether_hdr, thread_seq);
flag = 1; flag = POLLING_STATE_WORK;
} }
} }
} }