@@ -271,10 +271,9 @@ ngx_http_lua_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
271
271
/* continue to call ngx_http_next_body_filter to process cached data */
272
272
}
273
273
274
- if (in != NULL ) {
275
- if (ngx_chain_add_copy (r -> pool , & ctx -> filter_in_bufs , in ) != NGX_OK ) {
276
- return NGX_ERROR ;
277
- }
274
+ if (in != NULL
275
+ && ngx_chain_add_copy (r -> pool , & ctx -> filter_in_bufs , in ) != NGX_OK ) {
276
+ return NGX_ERROR ;
278
277
}
279
278
280
279
if (ctx -> filter_busy_bufs != NULL
@@ -299,14 +298,13 @@ ngx_http_lua_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
299
298
ngx_chain_update_chains (r -> pool ,
300
299
& ctx -> free_bufs , & ctx -> filter_busy_bufs , & out ,
301
300
(ngx_buf_tag_t ) & ngx_http_lua_module );
302
- if (rc != NGX_OK ) {
303
- if (ctx -> filter_busy_bufs != NULL
304
- && (r -> connection -> buffered
305
- & (NGX_HTTP_LOWLEVEL_BUFFERED | NGX_LOWLEVEL_BUFFERED ))) {
306
- ngx_log_debug0 (NGX_LOG_DEBUG_HTTP , r -> connection -> log , 0 ,
307
- "waiting body filter busy buffer to be sent" );
308
- return NGX_AGAIN ;
309
- }
301
+ if (rc != NGX_OK
302
+ && ctx -> filter_busy_bufs != NULL
303
+ && (r -> connection -> buffered
304
+ & (NGX_HTTP_LOWLEVEL_BUFFERED | NGX_LOWLEVEL_BUFFERED ))) {
305
+ ngx_log_debug0 (NGX_LOG_DEBUG_HTTP , r -> connection -> log , 0 ,
306
+ "waiting body filter busy buffer to be sent" );
307
+ return NGX_AGAIN ;
310
308
}
311
309
312
310
/* continue to process bufs in ctx->filter_in_bufs */
0 commit comments