From 3f20d93a4a35633ddb5c21752cb1868f4f09ba87 Mon Sep 17 00:00:00 2001 From: fumingwei Date: Sat, 17 Oct 2020 17:35:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9kni=5Fpolling=5Fall=5Fentry?= =?UTF-8?q?=20=E8=BF=94=E5=9B=9E=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- entry/src/kni_entry.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/entry/src/kni_entry.cpp b/entry/src/kni_entry.cpp index 524e74a..9751217 100644 --- a/entry/src/kni_entry.cpp +++ b/entry/src/kni_entry.cpp @@ -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){ void *logger = g_kni_handle->local_logger; MESA_htable_handle tuple2stream_htable = g_kni_handle->threads_handle[thread_seq].tuple2stream_htable; - int flag = 0; + int flag = POLLING_STATE_IDLE; //normal mode if(g_kni_handle->deploy_mode == KNI_DEPLOY_MODE_NORMAL){ //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++){ struct ethhdr *ether_hdr = (struct ethhdr*)marsio_buff_mtod(rx_buffs[j]); 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); } @@ -1761,7 +1761,7 @@ extern "C" char kni_polling_all_entry(const struct streaminfo *stream, void** pm if(ret > 0){ struct ethhdr *ether_hdr = (struct ethhdr*)buff; tuple2stream_htable_search(tuple2stream_htable, ether_hdr, thread_seq); - flag = 1; + flag = POLLING_STATE_WORK; } } }