File tree Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -361,11 +361,11 @@ local function _flush_buffer()
361
361
end
362
362
end
363
363
364
- local function _write_buffer (msg )
364
+ local function _write_buffer (msg , len )
365
365
log_buffer_index = log_buffer_index + 1
366
366
log_buffer_data [log_buffer_index ] = msg
367
367
368
- buffer_size = buffer_size + # msg
368
+ buffer_size = buffer_size + len
369
369
370
370
371
371
return buffer_size
@@ -505,28 +505,28 @@ function _M.log(msg)
505
505
msg = tostring (msg )
506
506
end
507
507
508
+ local msg_len = # msg
509
+
508
510
if (debug ) then
509
511
ngx .update_time ()
510
- ngx_log (DEBUG , ngx .now (), " :log message length: " .. # msg )
512
+ ngx_log (DEBUG , ngx .now (), " :log message length: " .. msg_len )
511
513
end
512
514
513
- local msg_len = # msg
514
-
515
515
-- response of "_flush_buffer" is not checked, because it writes
516
516
-- error buffer
517
517
if (is_exiting ()) then
518
518
exiting = true
519
- _write_buffer (msg )
519
+ _write_buffer (msg , msg_len )
520
520
_flush_buffer ()
521
521
if (debug ) then
522
522
ngx_log (DEBUG , " Nginx worker is exiting" )
523
523
end
524
524
bytes = 0
525
525
elseif (msg_len + buffer_size < flush_limit ) then
526
- _write_buffer (msg )
526
+ _write_buffer (msg , msg_len )
527
527
bytes = msg_len
528
528
elseif (msg_len + buffer_size <= drop_limit ) then
529
- _write_buffer (msg )
529
+ _write_buffer (msg , msg_len )
530
530
_flush_buffer ()
531
531
bytes = msg_len
532
532
else
You can’t perform that action at this time.
0 commit comments