source: CIVL/examples/messagePassing/commBad.cvl@ 6f5cd7f

#include<civlc.h>

$proc global;
$comm comm;
_Bool _start0 = $false;
_Bool _start1 = $false;

void mpi_proc0(int rank){
        void thread(tid){
                $message out;
                
                $when (initialized);
                out = $message_pack(rank, (rank+1)%NPROCS, TAG, &x, sizeof(double));
                $comm_enqueue(&MPI_COMM_WORLD, out);
        }
        
        $when(_start0);
        _
        $proc thread = $spawn thread(0);
        global = thread;
        _start1 = $true;
        $comm_add(&comm, thread, rank);
}

void mpi_proc1(int rank){
        $when(_start1);
        $comm_add(&comm, global, rank);
}

void main(){
        $proc procs[2];
        
        procs[0] = $spawn mpi_proc0(0);
        procs[1] = $spawn mpi_proc1(1);
        
        comm = $comm_create(2, procs);
        
        $wait procs[0];
        $wait procs[1];
}