zmq

foreign(master_main, c, master_main(+integer,+integer,+integer,+address(zchunk_t),+address(zchunk_t),+string,+string,+string,+integer,[-integer])).

foreign(alloc_term, c, alloc_term(+address(char), +integer, [-address(zchunk_t)])).

foreign(setup_worker, c, setup_worker(+integer, +integer, +string, +string, +string)).

foreign(work_reactor, c, work_reactor([-integer])).

foreign(teardown_worker, c, teardown_worker).

foreign(new_results_message, c, new_results_message([-address(zmsg_t)])).

foreign(start_timer, c, start_timer).

foreign(stop_timer, c, stop_timer).

foreign(msg_put_str, c, msg_put_str(+address(zmsg_t), +string)).

foreign(put_succ, c, put_succ(+address(zmsg_t), +address(char), +integer, +integer)).

foreign(add_stats, c, add_stats(+address(zmsg_t))).

foreign(send_and_destroy_msg, c, send_and_destroy_msg(+address(zmsg_t))).

foreign_resource('zmq', [master_main, alloc_term,
    setup_worker, work_reactor, teardown_worker,
    new_results_message,
    start_timer, stop_timer,
    msg_put_str, put_succ,
    add_stats, send_and_destroy_msg]).

init_zmq :- is_initialised,!.

init_zmq :-
    safe_load_foreign_resource(zmq),
    assertz(is_initialised).

safe_load_foreign_resource(R) :-
    E=error(existence_error(_,_),_),
    % print(loading_foreign_resource(R)),nl,
    catch(load_foreign_resource(library(R)), E, (
    format(user_error,'~n! Could not load ~w library!~n! Check that it is available in the lib folder of ProB.~n~n',[R]),
    throw(E)
)).