style: fixed coding style.

zhuizhuhaomeng · zhuizhuhaomeng · commit 8df9125ad190 · 2025-06-08T16:47:10.000+08:00
diff --git a/src/api/ngx_stream_lua_api.h b/src/api/ngx_stream_lua_api.h
@@ -29,7 +29,7 @@
 /* Public API for other Nginx modules */
 
 
-#define ngx_stream_lua_version  16
+#define ngx_stream_lua_version    16
 
 
 typedef struct {
diff --git a/src/ngx_stream_lua_api.c b/src/ngx_stream_lua_api.c
@@ -42,8 +42,6 @@ ngx_stream_lua_get_global_state(ngx_conf_t *cf)
 }
 
 
-
-
 static ngx_int_t ngx_stream_lua_shared_memory_init(ngx_shm_zone_t *shm_zone,
     void *data);
 
@@ -275,7 +273,9 @@ ngx_stream_lua_ffi_req_dst_addr(ngx_stream_lua_request_t *r, char *buf,
                                "failed to get IPv4 origin addr") - errbuf;
             return NGX_ERROR;
         }
+
 #if (NGX_HAVE_INET6)
+
     } else if (family == AF_INET6) {
         /* IPv6 */
         opt_name = IP6T_SO_ORIGINAL_DST;
@@ -286,6 +286,7 @@ ngx_stream_lua_ffi_req_dst_addr(ngx_stream_lua_request_t *r, char *buf,
             return NGX_ERROR;
         }
 #endif
+
     } else {
         /* Unsupported address family */
         *errbuf_size
diff --git a/src/ngx_stream_lua_args.c b/src/ngx_stream_lua_args.c
@@ -156,6 +156,4 @@ ngx_stream_lua_parse_args(lua_State *L, u_char *buf, u_char *last, int max)
 }
 
 
-
-
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_common.h b/src/ngx_stream_lua_common.h
@@ -246,8 +246,6 @@ struct ngx_stream_lua_main_conf_s {
 };
 
 
-
-
 struct ngx_stream_lua_srv_conf_s {
 #if (NGX_STREAM_SSL)
     ngx_ssl_t              *ssl;  /* shared by SSL cosockets */
@@ -330,6 +328,7 @@ struct ngx_stream_lua_srv_conf_s {
 
 };
 
+
 typedef ngx_stream_lua_srv_conf_t ngx_stream_lua_loc_conf_t;
 
 
@@ -360,8 +359,6 @@ struct ngx_stream_lua_posted_thread_s {
 };
 
 
-
-
 struct ngx_stream_lua_co_ctx_s {
     void                    *data;      /* user state for cosockets */
 
@@ -527,12 +524,9 @@ typedef struct ngx_stream_lua_ctx_s {
 } ngx_stream_lua_ctx_t;
 
 
-
-
 extern ngx_module_t ngx_stream_lua_module;
 
 
-
 #endif /* _NGX_STREAM_LUA_COMMON_H_INCLUDED_ */
 
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_consts.c b/src/ngx_stream_lua_consts.c
@@ -47,5 +47,4 @@ ngx_stream_lua_inject_core_consts(lua_State *L)
 }
 
 
-
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_contentby.c b/src/ngx_stream_lua_contentby.c
@@ -208,8 +208,6 @@ ngx_stream_lua_content_handler(ngx_stream_session_t *s)
 }
 
 
-
-
 ngx_int_t
 ngx_stream_lua_content_handler_file(ngx_stream_lua_request_t *r)
 {
diff --git a/src/ngx_stream_lua_control.c b/src/ngx_stream_lua_control.c
@@ -40,8 +40,6 @@ ngx_stream_lua_inject_control_api(ngx_log_t *log, lua_State *L)
 }
 
 
-
-
 static int
 ngx_stream_lua_on_abort(lua_State *L)
 {
diff --git a/src/ngx_stream_lua_ctx.c b/src/ngx_stream_lua_ctx.c
@@ -55,7 +55,8 @@ ngx_stream_lua_ngx_set_ctx_helper(lua_State *L, ngx_stream_lua_request_t *r,
         lua_pop(L, 1);
 
         pool = r->pool;
-        if (ngx_stream_lua_ngx_ctx_add_cleanup(r, pool, ctx->ctx_ref) != NGX_OK) {
+        if (ngx_stream_lua_ngx_ctx_add_cleanup(r, pool, ctx->ctx_ref) != NGX_OK)
+        {
             return luaL_error(L, "no memory");
         }
 
@@ -160,8 +161,8 @@ ngx_stream_lua_ffi_set_ctx_ref(ngx_stream_lua_request_t *r, int ref)
 
 
 static ngx_int_t
-ngx_stream_lua_ngx_ctx_add_cleanup(ngx_stream_lua_request_t *r, ngx_pool_t *pool,
-    int ref)
+ngx_stream_lua_ngx_ctx_add_cleanup(ngx_stream_lua_request_t *r,
+    ngx_pool_t *pool, int ref)
 {
     lua_State                   *L;
     ngx_pool_cleanup_t          *cln;
diff --git a/src/ngx_stream_lua_directive.c b/src/ngx_stream_lua_directive.c
@@ -234,12 +234,6 @@ ngx_stream_lua_package_path(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
 }
 
 
-
-
-
-
-
-
 char *
 ngx_stream_lua_preread_by_lua_block(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf)
@@ -354,6 +348,7 @@ ngx_stream_lua_preread_by_lua(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
     return NGX_CONF_OK;
 }
 
+
 char *
 ngx_stream_lua_content_by_lua_block(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf)
@@ -597,8 +592,6 @@ ngx_stream_lua_log_by_lua(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
 }
 
 
-
-
 char *
 ngx_stream_lua_init_by_lua_block(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf)
@@ -727,8 +720,6 @@ ngx_stream_lua_init_worker_by_lua(ngx_conf_t *cf, ngx_command_t *cmd,
 }
 
 
-
-
 static u_char *
 ngx_stream_lua_gen_chunk_name(ngx_conf_t *cf, const char *tag, size_t tag_len,
     size_t *chunkname_len)
@@ -870,13 +861,15 @@ ngx_stream_lua_conf_lua_block_parse(ngx_conf_t *cf, ngx_command_t *cmd)
                 if (dst == NULL) {
                     return NGX_CONF_ERROR;
                 }
+
                 dst->len = len;
                 dst->len--;  /* skip the trailing '}' block terminator */
 
                 p = ngx_palloc(cf->pool, len);
                 if (p == NULL) {
                     return NGX_CONF_ERROR;
                 }
+
                 dst->data = p;
 
                 for (i = 0; i < cf->args->nelts; i++) {
diff --git a/src/ngx_stream_lua_initworkerby.c b/src/ngx_stream_lua_initworkerby.c
@@ -158,6 +158,7 @@ ngx_stream_lua_init_worker(ngx_cycle_t *cycle)
             if (part->next == NULL) {
                 break;
             }
+
             part = part->next;
             ofile = part->elts;
             i = 0;
diff --git a/src/ngx_stream_lua_log.c b/src/ngx_stream_lua_log.c
@@ -130,6 +130,7 @@ log_wrapper(ngx_log_t *log, const char *ident, ngx_uint_t level,
             if (*p == '/' || *p == '\\') {
                 name.data = p + 1;
             }
+
             p++;
         }
 
diff --git a/src/ngx_stream_lua_misc.c b/src/ngx_stream_lua_misc.c
@@ -32,8 +32,6 @@ ngx_stream_lua_ffi_get_resp_status(ngx_stream_lua_request_t *r)
 }
 
 
-
-
 int
 ngx_stream_lua_ffi_get_conf_env(u_char *name, u_char **env_buf,
     size_t *name_len)
diff --git a/src/ngx_stream_lua_module.c b/src/ngx_stream_lua_module.c
@@ -798,10 +798,6 @@ ngx_stream_lua_init_main_conf(ngx_conf_t *cf, void *conf)
 }
 
 
-
-
-
-
 static void *
 ngx_stream_lua_create_srv_conf(ngx_conf_t *cf)
 {
@@ -935,14 +931,15 @@ ngx_stream_lua_merge_srv_conf(ngx_conf_t *cf, void *parent, void *child)
 #ifdef LIBRESSL_VERSION_NUMBER
 
             ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
-                          "LibreSSL is not supported by ssl_certificate_by_lua*");
+                        "LibreSSL is not supported by ssl_certificate_by_lua*");
             return NGX_CONF_ERROR;
 
 #else
 
 #   if OPENSSL_VERSION_NUMBER >= 0x1000205fL
 
-            SSL_CTX_set_cert_cb(sscf->ssl.ctx, ngx_stream_lua_ssl_cert_handler, NULL);
+            SSL_CTX_set_cert_cb(sscf->ssl.ctx, ngx_stream_lua_ssl_cert_handler,
+                                NULL);
 
 #   else
 
@@ -1033,8 +1030,6 @@ ngx_stream_lua_merge_srv_conf(ngx_conf_t *cf, void *parent, void *child)
 }
 
 
-
-
 #if (NGX_STREAM_SSL)
 
 static ngx_int_t
@@ -1112,13 +1107,16 @@ ngx_stream_lua_set_ssl(ngx_conf_t *cf, ngx_stream_lua_srv_conf_t *lscf)
 
 #if (nginx_version >= 1019004)
     if (ngx_ssl_conf_commands(cf, lscf->ssl, lscf->ssl_conf_commands)
-        != NGX_OK) {
+        != NGX_OK)
+    {
         return NGX_ERROR;
     }
 #endif
+
     return NGX_OK;
 }
 
+
 #if (nginx_version >= 1019004)
 static char *
 ngx_stream_lua_ssl_conf_command_check(ngx_conf_t *cf, void *post, void *data)
diff --git a/src/ngx_stream_lua_output.c b/src/ngx_stream_lua_output.c
@@ -646,8 +646,6 @@ ngx_stream_lua_inject_output_api(lua_State *L)
 }
 
 
-
-
 ngx_int_t
 ngx_stream_lua_flush_resume_helper(ngx_stream_lua_request_t *r,
     ngx_stream_lua_ctx_t *ctx)
diff --git a/src/ngx_stream_lua_phase.c b/src/ngx_stream_lua_phase.c
@@ -94,6 +94,4 @@ ngx_stream_lua_inject_phase_api(lua_State *L)
 }
 
 
-
-
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_regex.c b/src/ngx_stream_lua_regex.c
@@ -208,7 +208,7 @@ ngx_stream_lua_regex_compile(ngx_stream_lua_regex_compile_t *rc)
         }
 
         lmcf = ngx_stream_cycle_get_module_main_conf(ngx_cycle,
-                                                   ngx_stream_lua_module);
+                                                     ngx_stream_lua_module);
         if (lmcf && lmcf->regex_match_limit > 0) {
             pcre2_set_match_limit(ngx_regex_match_context,
                                   lmcf->regex_match_limit);
@@ -749,7 +749,7 @@ ngx_stream_lua_ffi_exec_regex(ngx_stream_lua_regex_t *re, int flags,
 
     if (rc < 0) {
 #if (NGX_DEBUG)
-    ngx_log_debug4(NGX_LOG_DEBUG_STREAM, ngx_cycle->log, 0,
+        ngx_log_debug4(NGX_LOG_DEBUG_STREAM, ngx_cycle->log, 0,
                    "pcre2_match failed: flags 0x%05Xd, options 0x%08Xd, rc %d, "
                    "ovecpair %ui", flags, exec_opts, rc, ovecpair);
 #endif
@@ -835,7 +835,8 @@ ngx_stream_lua_ffi_exec_regex(ngx_stream_lua_regex_t *re, int flags,
         int ws[NGX_LUA_RE_DFA_MODE_WORKSPACE_COUNT];
         rc = ngx_stream_lua_regex_dfa_exec(re->regex, sd, &subj,
                                            (int) pos, cap, ovecsize, ws,
-                                           sizeof(ws) / sizeof(ws[0]), exec_opts);
+                                           sizeof(ws) / sizeof(ws[0]),
+                                           exec_opts);
 
 #else
 
diff --git a/src/ngx_stream_lua_semaphore.c b/src/ngx_stream_lua_semaphore.c
@@ -484,7 +484,8 @@ ngx_stream_lua_sema_handler(ngx_event_t *ev)
 
         sem->wait_count--;
 
-        wait_co_ctx = ngx_queue_data(q, ngx_stream_lua_co_ctx_t, sem_wait_queue);
+        wait_co_ctx = ngx_queue_data(q, ngx_stream_lua_co_ctx_t,
+                                     sem_wait_queue);
         wait_co_ctx->cleanup = NULL;
 
         if (wait_co_ctx->sleep.timer_set) {
diff --git a/src/ngx_stream_lua_shdict.c b/src/ngx_stream_lua_shdict.c
@@ -601,8 +601,6 @@ ngx_stream_lua_shdict_get_keys(lua_State *L)
 }
 
 
-
-
 static int
 ngx_stream_lua_shdict_lpush(lua_State *L)
 {
diff --git a/src/ngx_stream_lua_socket_tcp.c b/src/ngx_stream_lua_socket_tcp.c
@@ -211,6 +211,7 @@ enum {
     SOCKET_OP_RESUME_CONN
 };
 
+
 enum {
     NGX_STREAM_LUA_SOCKOPT_KEEPALIVE = 1,
     NGX_STREAM_LUA_SOCKOPT_REUSEADDR,
diff --git a/src/ngx_stream_lua_socket_udp.c b/src/ngx_stream_lua_socket_udp.c
@@ -405,6 +405,7 @@ ngx_stream_lua_socket_udp_setpeername(lua_State *L)
         ngx_log_debug0(NGX_LOG_DEBUG_STREAM, r->connection->log, 0,
                        "stream lua set UDP upstream with IP_TRANSPARENT");
     }
+
     lua_pop(L, 1);
 #endif
 
@@ -628,7 +629,8 @@ ngx_stream_lua_socket_resolve_handler(ngx_resolver_ctx_t *ctx)
         addr.data = text;
 
         for (i = 0; i < ctx->naddrs; i++) {
-            addr.len = ngx_sock_ntop(ur->addrs[i].sockaddr, ur->addrs[i].socklen,
+            addr.len = ngx_sock_ntop(ur->addrs[i].sockaddr,
+                                     ur->addrs[i].socklen,
                                      text, NGX_SOCKADDR_STRLEN, 0);
 
             ngx_log_debug1(NGX_LOG_DEBUG_STREAM, r->connection->log, 0,
diff --git a/src/ngx_stream_lua_ssl_certby.c b/src/ngx_stream_lua_ssl_certby.c
@@ -182,7 +182,8 @@ ngx_stream_lua_ssl_cert_by_lua(ngx_conf_t *cf, ngx_command_t *cmd,
 
         p = ngx_copy(p, "ssl_certificate_by_lua",
                      sizeof("ssl_certificate_by_lua") - 1);
-        p = ngx_copy(p, NGX_STREAM_LUA_INLINE_TAG, NGX_STREAM_LUA_INLINE_TAG_LEN);
+        p = ngx_copy(p, NGX_STREAM_LUA_INLINE_TAG,
+                     NGX_STREAM_LUA_INLINE_TAG_LEN);
         p = ngx_stream_lua_digest_hex(p, value[1].data, value[1].len);
         *p = '\0';
     }
diff --git a/src/ngx_stream_lua_string.c b/src/ngx_stream_lua_string.c
@@ -141,6 +141,7 @@ ngx_stream_lua_ngx_escape_sql_str(u_char *dst, u_char *src, size_t size)
                         break;
                 }
             }
+
             src++;
             size--;
         }
@@ -200,9 +201,11 @@ ngx_stream_lua_ngx_escape_sql_str(u_char *dst, u_char *src, size_t size)
                     *dst++ = *src;
                     break;
             }
+
         } else {
             *dst++ = *src;
         }
+
         src++;
         size--;
     } /* while (size) */
@@ -457,7 +460,4 @@ ngx_stream_lua_ffi_escape_uri(const u_char *src, size_t len, u_char *dst,
                               type);
 }
 
-
-
-
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_time.c b/src/ngx_stream_lua_time.c
@@ -99,6 +99,4 @@ ngx_stream_lua_ffi_utctime(u_char *buf)
 }
 
 
-
-
 /* vi:set ft=c ts=4 sw=4 et fdm=marker: */
diff --git a/src/ngx_stream_lua_timer.c b/src/ngx_stream_lua_timer.c
diff --git a/src/ngx_stream_lua_util.h b/src/ngx_stream_lua_util.h
diff --git a/src/ngx_stream_lua_variable.c b/src/ngx_stream_lua_variable.c

Original file line number	Diff line number	Diff line change
`@@ -156,6 +156,4 @@ ngx_stream_lua_parse_args(lua_State L, u_char buf, u_char *last, int max)`
`156`	`156`	`}`
`157`	`157`
`158`	`158`
`159`		`-`
`160`		`-`
`161`	`159`	`/* vi:set ft=c ts=4 sw=4 et fdm=marker: */`
Original file line number	Diff line number	Diff line change
`@@ -47,5 +47,4 @@ ngx_stream_lua_inject_core_consts(lua_State *L)`
`47`	`47`	`}`
`48`	`48`
`49`	`49`
`50`		`-`
`51`	`50`	`/* vi:set ft=c ts=4 sw=4 et fdm=marker: */`
Original file line number	Diff line number	Diff line change
`@@ -208,8 +208,6 @@ ngx_stream_lua_content_handler(ngx_stream_session_t *s)`
`208`	`208`	`}`
`209`	`209`
`210`	`210`
`211`		`-`
`212`		`-`
`213`	`211`	`ngx_int_t`
`214`	`212`	`ngx_stream_lua_content_handler_file(ngx_stream_lua_request_t *r)`
`215`	`213`	`{`
Original file line number	Diff line number	Diff line change
`@@ -40,8 +40,6 @@ ngx_stream_lua_inject_control_api(ngx_log_t log, lua_State L)`
`40`	`40`	`}`
`41`	`41`
`42`	`42`
`43`		`-`
`44`		`-`
`45`	`43`	`static int`
`46`	`44`	`ngx_stream_lua_on_abort(lua_State *L)`
`47`	`45`	`{`
Original file line number	Diff line number	Diff line change
`@@ -158,6 +158,7 @@ ngx_stream_lua_init_worker(ngx_cycle_t *cycle)`
`158`	`158`	`if (part->next == NULL) {`
`159`	`159`	`break;`
`160`	`160`	`}`
	`161`	`+`
`161`	`162`	`part = part->next;`
`162`	`163`	`ofile = part->elts;`
`163`	`164`	`i = 0;`