@@ -62,9 +62,9 @@ test_that("using the proxy without pool and forward", {
62
62
addr = m $ listen(" tcp://127.0.0.1:*" )
63
63
p = parallel :: mcparallel(ssh_proxy(sub(" .*:" , " " , addr )))
64
64
65
- m $ proxy_submit_cmd(list (n_jobs = 1 ), 5000L )
65
+ m $ proxy_submit_cmd(list (n_jobs = 1 ), 10000L )
66
66
m $ add_pending_workers(1L )
67
- expect_null(m $ recv(1000L )) # worker 1 up
67
+ expect_null(m $ recv(2000L )) # worker 1 up
68
68
m $ send(5 + 2 )
69
69
expect_equal(m $ recv(500L ), 7 ) # collect results
70
70
@@ -86,9 +86,9 @@ test_that("using the proxy without pool and forward, 2 workers", {
86
86
addr = m $ listen(" tcp://127.0.0.1:*" )
87
87
p = parallel :: mcparallel(ssh_proxy(sub(" .*:" , " " , addr )))
88
88
89
- m $ proxy_submit_cmd(list (n_jobs = 2 ), 5000L )
89
+ m $ proxy_submit_cmd(list (n_jobs = 2 ), 10000L )
90
90
m $ add_pending_workers(2L )
91
- expect_null(m $ recv(1000L )) # worker 1 up
91
+ expect_null(m $ recv(2000L )) # worker 1 up
92
92
m $ send({ Sys.sleep(0.5 ); 5 + 2 })
93
93
expect_null(m $ recv(500L )) # worker 2 up
94
94
m $ send({ Sys.sleep(0.5 ); 3 + 1 })
0 commit comments