@@ -268,7 +268,8 @@ func (m Measurer) Run(ctx context.Context, args *model.ExperimentArgs) error {
268268 for i := range inputs {
269269 inputs [i ].Config .Tunnel = "torsf"
270270 }
271- for entry := range multi .CollectOverall (ctx , inputs , 1 , 20 , "riseupvpn" , callbacks ) {
271+
272+ for entry := range multi .CollectOverall (ctx , inputs , 5 , 20 , "riseupvpn" , callbacks ) {
272273 testkeys .UpdateProviderAPITestKeys (entry )
273274 }
274275 }
@@ -279,19 +280,25 @@ func (m Measurer) Run(ctx context.Context, args *model.ExperimentArgs) error {
279280 openvpnEndpoints := generateMultiInputs (gateways , "openvpn" )
280281 obfs4Endpoints := generateMultiInputs (gateways , "obfs4" )
281282 overallCount := 1 + len (inputs ) + len (openvpnEndpoints ) + len (obfs4Endpoints )
283+ startCount := 1 + len (inputs )
284+ if testkeys .APIStatus == "blocked" {
285+ startCount += len (inputs )
286+ overallCount += len (inputs )
287+ }
282288
283289 // measure openvpn in parallel
284290 for entry := range multi .CollectOverall (
285- ctx , openvpnEndpoints , 1 + len ( inputs ) , overallCount , "riseupvpn" , callbacks ) {
291+ ctx , openvpnEndpoints , startCount , overallCount , "riseupvpn" , callbacks ) {
286292 testkeys .AddGatewayConnectTestKeys (entry , "openvpn" )
287293 }
288294
295+ startCount += len (openvpnEndpoints )
289296 // measure obfs4 in parallel
290297 // TODO(bassosimone): when urlgetter is able to do obfs4 handshakes, here
291298 // can possibly also test for the obfs4 handshake.
292299 // See https://github.com/ooni/probe/issues/1463.
293300 for entry := range multi .CollectOverall (
294- ctx , obfs4Endpoints , 1 + len ( inputs ) + len ( openvpnEndpoints ) , overallCount , "riseupvpn" , callbacks ) {
301+ ctx , obfs4Endpoints , startCount , overallCount , "riseupvpn" , callbacks ) {
295302 testkeys .AddGatewayConnectTestKeys (entry , "obfs4" )
296303 }
297304
0 commit comments