Skip to content

Commit ca310e8

Browse files
committed
improvements to serializer
1 parent 68d08d2 commit ca310e8

File tree

5 files changed

+269
-156
lines changed

5 files changed

+269
-156
lines changed

base/distributed/clusterserialize.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ mutable struct ClusterSerializer{I<:IO} <: AbstractSerializer
1010
io::I
1111
counter::Int
1212
table::ObjectIdDict
13+
pending_refs::Vector{Int}
1314

1415
pid::Int # Worker we are connected to.
1516
tn_obj_sent::Set{UInt64} # TypeName objects sent
@@ -19,7 +20,7 @@ mutable struct ClusterSerializer{I<:IO} <: AbstractSerializer
1920
anonfunc_id::UInt64
2021

2122
function ClusterSerializer{I}(io::I) where I<:IO
22-
new(io, 0, ObjectIdDict(), Base.worker_id_from_socket(io),
23+
new(io, 0, ObjectIdDict(), Int[], Base.worker_id_from_socket(io),
2324
Set{UInt64}(), Dict{UInt64, UInt64}(), Dict{UInt64, Vector{Symbol}}(), 0)
2425
end
2526
end

0 commit comments

Comments
 (0)