diff options
| author | fumingwei <[email protected]> | 2020-10-17 17:35:46 +0800 |
|---|---|---|
| committer | fumingwei <[email protected]> | 2020-10-17 17:35:46 +0800 |
| commit | 3f20d93a4a35633ddb5c21752cb1868f4f09ba87 (patch) | |
| tree | 6911c67cd21c3ef1f2c3438f62e9cc75a156f526 | |
| parent | 39252e79c32e645fb2faef7e358f572723ba53b2 (diff) | |
修改kni_polling_all_entry 返回值v20.10.20201019
| -rw-r--r-- | entry/src/kni_entry.cpp | 6 |
1 files 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; } } } |