Skip to content

Commit

Permalink
Apply the patch provided in #46640 for typos (#46641)
Browse files Browse the repository at this point in the history
Apply the patch provided in #46640 by @spaette for typos

Co-authored-by: spaette <[email protected]>
  • Loading branch information
ViralBShah and spaette committed Sep 6, 2022
1 parent e998593 commit c297457
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/cluster.jl
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ Some are used by the cluster manager to add workers to an already-initialized ho
* `count` -- the number of workers to be launched on the host
* `exename` -- the path to the Julia executable on the host, defaults to `"\$(Sys.BINDIR)/julia"` or
`"\$(Sys.BINDIR)/julia-debug"`
* `exeflags` -- flags to use when lauching Julia remotely
* `exeflags` -- flags to use when launching Julia remotely
The `userdata` field is used to store information for each worker by external managers.
Expand Down
2 changes: 1 addition & 1 deletion src/remotecall.jl
Original file line number Diff line number Diff line change
Expand Up @@ -321,7 +321,7 @@ function process_worker(rr)
w = worker_from_id(rr.where)::Worker
msg = (remoteref_id(rr), myid())

# Needs to aquire a lock on the del_msg queue
# Needs to acquire a lock on the del_msg queue
T = Threads.@spawn begin
publish_del_msg!($w, $msg)
end
Expand Down
2 changes: 1 addition & 1 deletion src/workerpool.jl
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ wp_local_length(pool::AbstractWorkerPool) = length(pool.workers)
wp_local_isready(pool::AbstractWorkerPool) = isready(pool.channel)

function wp_local_put!(pool::AbstractWorkerPool, w::Int)
# In case of default_worker_pool, the master is implictly considered a worker, i.e.,
# In case of default_worker_pool, the master is implicitly considered a worker, i.e.,
# it is not present in pool.workers.
# Confirm the that the worker is part of a pool before making it available.
w in pool.workers && put!(pool.channel, w)
Expand Down
2 changes: 1 addition & 1 deletion test/distributed_exec.jl
Original file line number Diff line number Diff line change
Expand Up @@ -993,7 +993,7 @@ end
let
@test_throws RemoteException remotecall_fetch(()->LocalFoo.foo, 2)

bad_thunk = ()->NonexistantModule.f()
bad_thunk = ()->NonexistentModule.f()
@test_throws RemoteException remotecall_fetch(bad_thunk, 2)

# Test that the stream is still usable
Expand Down

0 comments on commit c297457

Please sign in to comment.