atoms.yap

#//// -L  *
 
%% called with 
%% `mpirun -np 2 bash gowait`
%% prints
%% ```
%% main
%% main
%% after_init
%% after_init
%% [0,2]
%% [1,2]
%% irecv
%% wait_end
%% after_send
%% c(535755152,)
%% ```
:- use_module(library(lam_mpi)).
:- use_module(library(system)).
use_module:-
    write(main),write,
    write,
    write(after_init),write,
    mpi_comm_size(S),
    mpi_comm_rank(R),
    write([R,S]),write,
    (R == 0->
     sleep(2),
     write(wait_end),write,
     mpi_send(ciao,1,201),
     write(after_send),write
    ;
     mpi_irecv(0,_201,H),
     write(irecv),write,
     test(H)
    ),
    mpi_finalize.
 
test(H):-
    (mpi_wait_recv(H,S,Data)->
     write(c(S,Data)),write
    ;
     write(no),write,
     test(H)
    ).
 
:-main.