FileRef default affinity should be all workers on the host where the …

…file resides
JuliaParallel · May 24, 2018 · 6ddaaa6 · 6ddaaa6
1 parent b26dc9f
commit 6ddaaa6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/chunks.jl b/src/chunks.jl
@@ -76,7 +76,7 @@ function affinity(r::FileRef)
     if haskey(MemPool.who_has_read, r.file)
         Pair{OSProc, UInt64}[OSProc(dref.owner) => r.size for dref in MemPool.who_has_read[r.file]]
     else
-        Pair{OSProc, UInt64}[]
+        Pair{OSProc, UInt64}[OSProc(w) => r.size for w in MemPool.get_workers_at(r.host)]
     end
 end