Merge branch 'master' of https://github.com/cloudozer/BWT

apps/worker_bwt_app/src/worker_bwt_app_sup.erl

@@ -25,7 +25,7 @@ start_link() ->
 init([]) ->
     {ok, { {one_for_one, 5, 10}, [
 
-        {worker_bwt, {worker_bwt, start_link, [{master, 'master@45.55.245.10'}]}, permanent, 5000, worker, [worker_bwt]}
+        {worker_bwt, {worker_bwt, start_link, [{master, 'master@erlangonxen.org'}]}, permanent, 5000, worker, [worker_bwt]}
 
     ]} }.
 

start_cluster.sh

@@ -0,0 +1,23 @@
+#!/usr/bin/env escript
+%% -*- erlang -*-
+%%! -pa ebin deps/lager/ebin deps/goldrush/ebin -setcookie secret_gc -name client@localhost -attached
+
+main([MasterIpStr, WorkersNumStr]) ->
+  main(["GL000193.1", MasterIpStr, WorkersNumStr]);
+
+main([Chromosome, MasterIpStr, WorkersNumStr]) ->
+  MasterPid = rpc:call(list_to_atom("master@" ++ MasterIpStr), erlang, whereis,[master]),
+  WorkersNum = list_to_integer(WorkersNumStr),
+  process_flag(trap_exit, true),
+  true = link(MasterPid),
+  ok = gen_server:call(MasterPid , {run, "bwt_files/SRR770176_1.fastq", Chromosome, WorkersNum}),
+  receive_cigars().
+
+receive_cigars() ->
+  receive
+    {cigar, SeqName, Chromosome, Pos, CigarValue, CigarRate, SeqValue} ->
+      io:format("~s      ~s      ~b      ~s      ~b      ~s~n", [SeqName, Chromosome, Pos, CigarValue, CigarRate, SeqValue]),
+      receive_cigars();
+
+    Error -> io:format("Error: ~p~n", [Error])
+  end.

start_local.sh

@@ -3,5 +3,5 @@
 %%! -pa ebin deps/lager/ebin deps/goldrush/ebin -setcookie secret_gc -name master@localhost -attached
 
 main([]) ->
-  master:test_local(),
+  master:test(),
   receive stop -> ok end.