github_mirrors/attachment
3
0
Fork 1
mirror of https://github.com/openappsec/attachment.git synced 2025-06-28 16:41:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #4 from openappsec/Mar_26_2023-Dev

Browse Source 
Mar 26th 2023 Dev
This commit is contained in:
WrightNed 2023-03-27 19:39:11 +03:00 committed by GitHub
commit aa138e034c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
attachments/nginx/ngx_module/ngx_cp_hooks.c
View File

@ -152,7 +152,7 @@ ngx_http_cp_hold_verdict(struct ngx_http_cp_event_thread_ctx_t *ctx)
for (uint i = 0; i < 3; i++) { for (uint i = 0; i < 3; i++) {
sleep(1); sleep(1);
int res = ngx_cp_run_in_thread_timeout( int res = ngx_cp_run_in_thread_timeout(
ngx_http_cp_hold_verdict_thread, ngx_http_cp_hold_verdict_thread,
(void *)ctx, (void *)ctx,
waiting_for_verdict_thread_timeout_msec, waiting_for_verdict_thread_timeout_msec,
"ngx_http_cp_hold_verdict_thread" "ngx_http_cp_hold_verdict_thread"
@ -166,7 +166,7 @@ ngx_http_cp_hold_verdict(struct ngx_http_cp_event_thread_ctx_t *ctx)
); );
continue; continue;
} }
if (session_data_p->verdict != TRAFFIC_VERDICT_WAIT) { if (session_data_p->verdict != TRAFFIC_VERDICT_WAIT) {
// Verdict was updated. // Verdict was updated.
write_dbg( write_dbg(
@ -550,12 +550,15 @@ ngx_http_cp_req_body_filter(ngx_http_request_t *request, ngx_chain_t *request_bo
req_body_thread_timeout_msec, req_body_thread_timeout_msec,
"ngx_http_cp_req_body_filter_thread" "ngx_http_cp_req_body_filter_thread"
); );
if (!res) { if (!res || ctx.res == NGX_ERROR) {
// failed to execute thread task, or it timed out // failed to execute thread task, or it timed out
session_data_p->verdict = fail_mode_verdict == NGX_OK ? TRAFFIC_VERDICT_ACCEPT : TRAFFIC_VERDICT_DROP; session_data_p->verdict = fail_mode_verdict == NGX_OK ? TRAFFIC_VERDICT_ACCEPT : TRAFFIC_VERDICT_DROP;
write_dbg( write_dbg(
DBG_LEVEL_DEBUG, DBG_LEVEL_DEBUG,
"req_body_filter thread failed, returning default fail mode verdict. Session id: %d, verdict: %s", "req_body_filter thread failed, returning default fail mode verdict. "
"thread execution result: %d, nano service reply: %d, Session id: %d, verdict: %s",
res,
ctx.res,
session_data_p->session_id, session_data_p->session_id,
session_data_p->verdict == TRAFFIC_VERDICT_ACCEPT ? "accept" : "drop" session_data_p->verdict == TRAFFIC_VERDICT_ACCEPT ? "accept" : "drop"
); );