-
-
Notifications
You must be signed in to change notification settings - Fork 5.5k
Commit
- Loading branch information
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -30,6 +30,7 @@ export | |
BitArray, | ||
BitMatrix, | ||
BitVector, | ||
BufferStream, | ||
CartesianIndex, | ||
CartesianRange, | ||
CFILE, | ||
|
@@ -1218,6 +1219,7 @@ export | |
nprocs, | ||
nworkers, | ||
pmap, | ||
process_messages, | ||
This comment has been minimized.
Sorry, something went wrong.
This comment has been minimized.
Sorry, something went wrong.
amitmurthy
Author
Contributor
|
||
procs, | ||
put!, | ||
remotecall, | ||
|
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,27 @@ | ||
This is a proof-of-concept that uses ZeroMQ as transport. | ||
It uses a star topology as opposed to the native mesh network. | ||
|
||
Package ZMQ must be installed. All workers only run on localhost. | ||
|
||
All Julia nodes only connect to a "broker" process that listens on known ports | ||
8100 and 8101 via ZMQ sockets. | ||
|
||
|
||
All commands must be run from `examples/clustermanager/0mq` directory | ||
|
||
First, start the broker. In a new console type: | ||
julia broker.jl | ||
|
||
This does not return. | ||
|
||
Next, start a Julia REPL and type: | ||
include("ZMQCM.jl") | ||
ZMQCM.start_master(4) # start with four workers | ||
|
||
|
||
Alternatively, head.jl, a test script could be run. It just launches the requested number of workers, | ||
executes a simple command on all of them and exits. | ||
julia head.jl 4 | ||
|
||
NOTE: As stated this is a proof-of-concept. A real Julia cluster using ZMQ will probably use | ||
different ZMQ socket types and optimize the transport. |
This doesn't seem like a great function to have exported. The manual tells you to call it for every connection --- is there a way to automate that so the API requires less boilerplate?
Also, the functions
init_worker
,launch
,manage
, andprocess_messages
need help entries.