github_mirrors/attachment
3
0
Fork 1
mirror of https://github.com/openappsec/attachment.git synced 2025-08-13 13:25:59 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix crash in k8s

Browse Source
This commit is contained in:
wiaamm 2025-07-07 14:33:41 +03:00
parent 760b1cbeb7
commit b3382fcd23
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
attachments/kong/nano_ffi.lua
View File

@ -189,8 +189,7 @@ end
function nano.init_attachment() function nano.init_attachment()
local worker_id = ngx.worker.id() local worker_id = ngx.worker.id()
local attachment, err local attachment, err
local retries = 5 -- Increased retries local retries = 3 -- Reduced retries for init_worker phase
local base_delay = 1 -- Start with 1 second delay
for attempt = 1, retries do for attempt = 1, retries do
attachment, err = nano_attachment.init_nano_attachment(worker_id, nano.num_workers) attachment, err = nano_attachment.init_nano_attachment(worker_id, nano.num_workers)
@ -199,20 +198,13 @@ function nano.init_attachment()
end end
kong.log.err("Worker ", worker_id, " failed to initialize attachment (attempt ", attempt, "/", retries, "): ", err) kong.log.err("Worker ", worker_id, " failed to initialize attachment (attempt ", attempt, "/", retries, "): ", err)
local delay = base_delay * (2 ^ (attempt - 1)) + math.random(0, 1000) / 1000
kong.log.info("Worker ", worker_id, " retrying attachment initialization in ", delay, " seconds...")
ngx.sleep(delay)
end end
if not attachment then if not attachment then
kong.log.crit("Worker ", worker_id, " CRITICAL: Failed to initialize attachment after ", retries, " attempts. Worker will operate in fail-open mode.") kong.log.err("Worker ", worker_id, " failed to initialize attachment after ", retries, " attempts. Worker will operate in fail-open mode.")
-- Don't store nil attachment - let other functions handle the missing attachment gracefully
return false
else else
nano.attachments[worker_id] = attachment nano.attachments[worker_id] = attachment
kong.log.info("Worker ", worker_id, " successfully initialized nano_attachment.") kong.log.info("Worker ", worker_id, " successfully initialized nano_attachment.")
return true
end end
end end
@ -222,8 +214,14 @@ function nano.init_session(session_id)
local attachment = nano.attachments[worker_id] local attachment = nano.attachments[worker_id]
if not attachment then if not attachment then
kong.log.warn("Cannot initialize session: Attachment not available for worker ", worker_id, " - failing open") kong.log.warn("Attachment not found for worker ", worker_id, ", attempting to reinitialize...")
return nil nano.init_attachment()
attachment = nano.attachments[worker_id]
if not attachment then
kong.log.warn("Cannot initialize session: Attachment still not available for worker ", worker_id, " - failing open")
return nil
end
end end
local session_data, err = nano_attachment.init_session(attachment, session_id) local session_data, err = nano_attachment.init_session(attachment, session_id)