32 lines
978 B
C
32 lines
978 B
C
|
diff --git a/src/stream/ngx_stream.h b/src/stream/ngx_stream.h
|
||
|
|
index 09d2459..de92724 100644
|
||
|
|
--- a/src/stream/ngx_stream.h
|
||
|
|
+++ b/src/stream/ngx_stream.h
|
||
|
|
@@ -303,4 +303,7 @@ typedef ngx_int_t (*ngx_stream_filter_pt)(ngx_stream_session_t *s,
|
||
|
|
extern ngx_stream_filter_pt ngx_stream_top_filter;
|
||
|
|
|
||
|
|
|
||
|
|
+#define HAS_NGX_STREAM_PROXY_GET_NEXT_UPSTREAM_TRIES_PATCH 1
|
||
|
|
+
|
||
|
|
+
|
||
|
|
#endif /* _NGX_STREAM_H_INCLUDED_ */
|
||
|
|
diff --git a/src/stream/ngx_stream_proxy_module.c b/src/stream/ngx_stream_proxy_module.c
|
||
|
|
index 0afde1c..3254ce1 100644
|
||
|
|
--- a/src/stream/ngx_stream_proxy_module.c
|
||
|
|
+++ b/src/stream/ngx_stream_proxy_module.c
|
||
|
|
@@ -2156,3 +2156,14 @@ ngx_stream_proxy_bind(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
|
||
|
|
|
||
|
|
return NGX_CONF_OK;
|
||
|
|
}
|
||
|
|
+
|
||
|
|
+
|
||
|
|
+ngx_uint_t
|
||
|
|
+ngx_stream_proxy_get_next_upstream_tries(ngx_stream_session_t *s)
|
||
|
|
+{
|
||
|
|
+ ngx_stream_proxy_srv_conf_t *pscf;
|
||
|
|
+
|
||
|
|
+ pscf = ngx_stream_get_module_srv_conf(s, ngx_stream_proxy_module);
|
||
|
|
+
|
||
|
|
+ return pscf->next_upstream_tries;
|
||
|
|
+}
|