@@ -289,7 +289,7 @@ workloads = Int[sum(ids .== i) for i in 2:nprocs()]
289
289
290
290
# Testing buffered and unbuffered reads
291
291
# This large array should write directly to the socket
292
- a = ones ( 10 ^ 6 )
292
+ a = fill ( 1 , 10 ^ 6 )
293
293
@test a == remotecall_fetch ((x)-> x, id_other, a)
294
294
295
295
# Not a bitstype, should be buffered
@@ -1118,7 +1118,7 @@ for i in 1:5
1118
1118
end
1119
1119
1120
1120
# Different global bindings to the same object
1121
- global v3 = ones ( 10 )
1121
+ global v3 = fill ( 1. , 10 )
1122
1122
global v4 = v3
1123
1123
@test remotecall_fetch (()-> v3, id_other) == remotecall_fetch (()-> v4, id_other)
1124
1124
@test remotecall_fetch (()-> isdefined (Main, :v3 ), id_other)
@@ -1188,8 +1188,8 @@ end
1188
1188
@test testsercnt_d[object_id (tsc)] == n
1189
1189
1190
1190
# Multiple references in a closure should be serialized only once.
1191
- global mrefs = TestSerCnt (ones ( 10 ))
1192
- @test remotecall_fetch (()-> (mrefs. v, 2 * mrefs. v, 3 * mrefs. v), id_other) == (ones ( 10 ), 2 * ones ( 10 ), 3 * ones ( 10 ))
1191
+ global mrefs = TestSerCnt (fill ( 1. , 10 ))
1192
+ @test remotecall_fetch (()-> (mrefs. v, 2 * mrefs. v, 3 * mrefs. v), id_other) == (fill ( 1. , 10 ), fill ( 2. , 10 ), fill ( 3. , 10 ))
1193
1193
@test testsercnt_d[object_id (mrefs)] == 1
1194
1194
1195
1195
@@ -1201,7 +1201,7 @@ v = rand()
1201
1201
@test remotecall_fetch (x-> f2 (x), id_other, v) == v
1202
1202
1203
1203
# consts
1204
- const c1 = ones ( 10 )
1204
+ const c1 = fill ( 1. , 10 )
1205
1205
@test remotecall_fetch (()-> c1, id_other) == c1
1206
1206
@test remotecall_fetch (()-> isconst (Main, :c1 ), id_other)
1207
1207
@@ -1234,7 +1234,7 @@ end
1234
1234
wrapped_var_ser_tests ()
1235
1235
1236
1236
# Test internal data structures being cleaned up upon gc.
1237
- global ids_cleanup = ones ( 6 )
1237
+ global ids_cleanup = fill ( 1. , 6 )
1238
1238
global ids_func = ()-> ids_cleanup
1239
1239
1240
1240
clust_ser = (Distributed. worker_from_id (id_other)). w_serializer
@@ -1449,8 +1449,8 @@ npids = addprocs_with_testenv(WorkerArgTester(`--worker=foobar`, false))
1449
1449
# Must be run on a new cluster, i.e., all workers must be in the same state.
1450
1450
rmprocs (workers ())
1451
1451
p1,p2 = addprocs_with_testenv (2 )
1452
- @everywhere f22865 (p) = remotecall_fetch (x-> x.* 2 , p, ones ( 2 ))
1453
- @test ones ( 2 ) .* 2 == remotecall_fetch (f22865, p1, p2)
1452
+ @everywhere f22865 (p) = remotecall_fetch (x-> x.* 2 , p, fill ( 1. , 2 ))
1453
+ @test fill ( 2. , 2 ) == remotecall_fetch (f22865, p1, p2)
1454
1454
1455
1455
function reuseport_tests ()
1456
1456
# Run the test on all processes.
0 commit comments