@@ -65,7 +65,7 @@ proxy_protocol_v1(Config) ->
6565 {ok , _Packet } = gen_tcp :recv (Socket , 0 , ? TIMEOUT ),
6666 ConnectionName = rabbit_ct_broker_helpers :rpc (Config , 0 ,
6767 ? MODULE , connection_name , []),
68- match = re :run (ConnectionName , <<" ^192.168.1.1:80 -> 192.168.1.2:81$ " >>, [{capture , none }]),
68+ match = re :run (ConnectionName , <<" ^192.168.1.1:80 -> 192.168.1.2:81 \\ ( \\ d \\ ) " >>, [{capture , none }]),
6969 gen_tcp :close (Socket ),
7070 ok .
7171
@@ -82,7 +82,7 @@ proxy_protocol_v1_tls(Config) ->
8282 timer :sleep (1000 ),
8383 ConnectionName = rabbit_ct_broker_helpers :rpc (Config , 0 ,
8484 ? MODULE , connection_name , []),
85- match = re :run (ConnectionName , <<" ^192.168.1.1:80 -> 192.168.1.2:81$" >>, [{capture , none }]),
85+ match = re :run (ConnectionName , <<" ^192.168.1.1:80 -> 192.168.1.2:81 \\ ( \\ d \\ ) $" >>, [{capture , none }]),
8686 gen_tcp :close (Socket ),
8787 ok .
8888
@@ -100,7 +100,7 @@ proxy_protocol_v2_local(Config) ->
100100 {ok , _Packet } = gen_tcp :recv (Socket , 0 , ? TIMEOUT ),
101101 ConnectionName = rabbit_ct_broker_helpers :rpc (Config , 0 ,
102102 ? MODULE , connection_name , []),
103- match = re :run (ConnectionName , <<" ^127.0.0.1:\\ d+ -> 127.0.0.1:\\ d+$" >>, [{capture , none }]),
103+ match = re :run (ConnectionName , <<" ^127.0.0.1:\\ d+ -> 127.0.0.1:\\ d+ \\ ( \\ d \\ ) $" >>, [{capture , none }]),
104104 gen_tcp :close (Socket ),
105105 ok .
106106
@@ -144,7 +144,9 @@ connection_name() ->
144144 end .
145145
146146connection_registered () ->
147- length (ets :tab2list (connection_created )) > 0 .
147+ I = ets :info (connection_created ),
148+ Size = proplists :get_value (size , I ),
149+ Size > 0 .
148150
149151retry (_Function , 0 ) ->
150152 false ;
0 commit comments