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

修正解密流量转发中部分回调函数没有正确传线程号，导致线程竞争访问的问题。

Browse Source
This commit is contained in:
luqiuwen
2019-08-13 13:55:39 +08:00
committed by 陆秋文
parent 9eb1efe047
commit 1e869c3ded
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/business/traffic-mirror/src/entry.cpp
View File

@@ -635,7 +635,7 @@ enum tfe_stream_action traffic_mirror_on_data_cb(const struct tfe_stream * strea
enum tfe_conn_dir dir, const unsigned char * data, size_t len, void ** pme) enum tfe_conn_dir dir, const unsigned char * data, size_t len, void ** pme)
{ {
struct traffic_mirror_me * me = (struct traffic_mirror_me *)(*pme); struct traffic_mirror_me * me = (struct traffic_mirror_me *)(*pme);
traffic_mirror_rebuild_data(me->rebuild_ctx, 0, (const char *) data, (size_t) len, dir); traffic_mirror_rebuild_data(me->rebuild_ctx, thread_id, (const char *) data, (size_t) len, dir);
return ACTION_FORWARD_DATA; return ACTION_FORWARD_DATA;
} }
@@ -643,7 +643,7 @@ void traffic_mirror_on_close_cb(const struct tfe_stream * stream, unsigned int t
enum tfe_stream_close_reason reason, void ** pme) enum tfe_stream_close_reason reason, void ** pme)
{ {
struct traffic_mirror_me * me = (struct traffic_mirror_me *)(*pme); struct traffic_mirror_me * me = (struct traffic_mirror_me *)(*pme);
traffic_mirror_rebuild_farewell(me->rebuild_ctx, 0); traffic_mirror_rebuild_farewell(me->rebuild_ctx, thread_id);
traffic_mirror_rebuild_destroy(me->rebuild_ctx); traffic_mirror_rebuild_destroy(me->rebuild_ctx);
profile_table_ex_data_free(me->profile_ex_data); profile_table_ex_data_free(me->profile_ex_data);