Erlang/OTP Forums

-module (toto).

-export([run/1, run/2]).

run(FileName) ->
  run(40, FileName).

run(N, FileName) ->
    { ok, Fd   } = file:open(FileName, [ binary, read_ahead ]),
    { ok, _Log } = disk_log:open([{name, my_log_file}, {format,external}, {file, "dump.log"}]),
    init_group(N),
    read_final(Fd),
    join().

join () ->
    Fun = fun (Worker) ->
              Worker ! { stop, self() },
              receive
                  ok -> ok
              end
          end,                 
    lists:foreach(Fun, pg2:get_members(decoder_group)).

init_group (N) ->
    pg2:create(decoder_group),
    Fun = fun(_X) ->
            spawn(fun init_worker/0)
          end,
    lists:foreach(Fun, lists:seq(1,N)).

init_worker () ->
    pg2:join(decoder_group, self()),
    worker_loop().

worker_loop () ->
    receive
        { stop, Pid } ->
            Pid ! ok;
        Data ->
            decode_frame(Data),
            worker_loop()
    end.

read_final (Fd) ->
    case file:read(Fd, 1) of
        { ok, <<Data:8>> } ->
            pg2:get_closest_pid(decoder_group) ! Data,
            read_final(Fd);
        eof ->
            ok
    end.
   
decode_frame (_Binary) ->   
    disk_log:balog(my_log_file, ".").

> toto:run("my_file.txt").

** exception error: bad argument
     in function  toto:read_final/1
     in call from toto:run/2