kbarros

(venv) darwin-fe2 ~/test/dask-mpi $ mpirun -np 4 python dask_mpi/tests/core_basic.py
distributed.scheduler - INFO - Clear task state
distributed.dashboard.proxy - INFO - To route to workers diagnostics web server please install jupyter-server-proxy: pip install jupyter-server-proxy
distributed.scheduler - INFO -   Scheduler at: tcp://128.165.148.250:8786
distributed.scheduler - INFO -       bokeh at:                     :8787
distributed.scheduler - INFO - Receive client connection: Client-690660e2-9ece-11e9-8c68-000f5330dcf0
distributed.core - INFO - Starting established connection
distributed.diskutils - INFO - Found stale lock file and directory '/home/kbarros/test/dask-mpi/worker-sy1aeqmb', purging
distributed.diskutils - INFO - Found stale lock file and directory '/home/kbarros/test/dask-mpi/worker-7aaj8eqg', purging
distributed.diskutils - INFO - Found stale lock file and directory '/home/kbarros/test/dask-mpi/worker-37o871em', purging

kbarros

(venv) darwin-fe2 ~/test/dask-mpi $ mpirun -np 4 python dask_mpi/tests/core_basic.py
distributed.scheduler - INFO - Clear task state
distributed.scheduler - INFO -   Scheduler at: tcp://128.165.148.250:8786
distributed.scheduler - INFO - Receive client connection: Client-86a19126-9e96-11e9-8908-000f5330dcf0
distributed.core - INFO - Starting established connection
distributed.worker - INFO -       Start worker at: tcp://128.165.148.250:34289
distributed.worker - INFO -          Listening to:               tcp://:34289
distributed.worker - INFO - Waiting to connect to: tcp://128.165.148.250:8786
distributed.worker - INFO - -------------------------------------------------
distributed.worker - INFO -               Threads:                          1

kbarros

15:05:17 [~] brew --config
HOMEBREW_VERSION: 0.9.5
ORIGIN: https://github.com/Homebrew/homebrew.git
HEAD: d612a58c3086c6ba11fb796258a708cb71354be2
HOMEBREW_PREFIX: /usr/local
HOMEBREW_CELLAR: /usr/local/Cellar
CPU: quad-core 64-bit haswell
OS X: 10.8.5-x86_64
Xcode: 5.1.1
CLT: 5.1.0.0.1.1396320587

kbarros

//
// Java wrapper for FFTW3 using Java Native Access (JNA)
// Author: Kipton Barros
//

package fftw3;

// This file was automatically generated with JNAerator the command:
//   java -jar jnaerator-0.9.7.jar -library FFTW3 /usr/local/include/fftw3.h -o . -v -noJar -noComp -noPrimitiveArrays -noMangling -structsInLibrary -runtime JNA -sizeAsLong -Dfftw_complex=double -Dfftwf_complex=float
// I made some small manual modifications, essentially to remove unneeded JNAerator dependencies

kbarros

  lazy val mkrunner = task {
    val jlineJar = runClasspath.get.find(_.toString.contains("jline"))
    val toolClasspathStr = Path.makeString(buildScalaJars.get ++ jlineJar)
    val runClasspathStr  = Path.makeString(runClasspath.get)
    val scalaHomeStr = buildLibraryJar.asFile.getParentFile.getParent
    val scalaRunner =
"""[ -n "$JAVA_OPTS" ] || JAVA_OPTS="-Xmx256M -Xms32M"
for i
do
  case "$i" in