This commit is contained in:
Vítor Santos Costa 2014-09-09 23:55:47 -05:00
parent 87e36bcfe2
commit 9e7257978c
7 changed files with 12 additions and 5 deletions

View File

@ -3143,7 +3143,6 @@ FILE *Yap_FileDescriptorFromStream(Term t)
X_API int X_API int
PL_raise(int sig) PL_raise(int sig)
{ {
CACHE_REGS
Yap_signal(YAP_INT_SIGNAL); Yap_signal(YAP_INT_SIGNAL);
return 1; return 1;
} }
@ -3152,7 +3151,6 @@ int
raiseSignal(PL_local_data_t *ld, int sig) raiseSignal(PL_local_data_t *ld, int sig)
{ {
#if THREADS #if THREADS
CACHE_REGS
if (sig == SIG_THREAD_SIGNAL) { if (sig == SIG_THREAD_SIGNAL) {
Yap_signal(YAP_ITI_SIGNAL); Yap_signal(YAP_ITI_SIGNAL);
return TRUE; return TRUE;

View File

@ -1025,7 +1025,7 @@ init_mpi(void) {
YAP_UserCPredicate( "mpi_test_rcv", mpi_test_recv,3); // mpi_test(+Handle,-Status,-Data). YAP_UserCPredicate( "mpi_test_rcv", mpi_test_recv,3); // mpi_test(+Handle,-Status,-Data).
YAP_UserCPredicate( "mpi_bcast", mpi_bcast,2); // mpi_bcast(Root,Term) YAP_UserCPredicate( "mpi_bcast", mpi_bcast,2); // mpi_bcast(Root,Term)
YAP_UserCPredicate( "mpi_bcast2", mpi_bcast2,2); // mpi_bcast2(Root,Term) YAP_UserCPredicate( "mpi_bcast2", mpi_bcast2,2); // mpi_bcast2(Root,Term)
YAP_UserCPredicate( "mpi_bcast2", mpi_bcast3,3); // mpi_bcast2(Root,Term,Tag) YAP_UserCPredicate( "mpi_bcast3", mpi_bcast3,3); // mpi_bcast3(Root,Term,Tag)
YAP_UserCPredicate( "mpi_ibcast", mpi_ibcast2,2); // mpi_ibcast(Root,Term) YAP_UserCPredicate( "mpi_ibcast", mpi_ibcast2,2); // mpi_ibcast(Root,Term)
YAP_UserCPredicate( "mpi_ibcast", mpi_ibcast3,3); // mpi_ibcast(Root,Term,Tag) YAP_UserCPredicate( "mpi_ibcast", mpi_ibcast3,3); // mpi_ibcast(Root,Term,Tag)
YAP_UserCPredicate( "mpi_barrier", mpi_barrier,0); // mpi_barrier/0 YAP_UserCPredicate( "mpi_barrier", mpi_barrier,0); // mpi_barrier/0

View File

@ -11,7 +11,7 @@
copy_line/2, copy_line/2,
filter/3, filter/3,
file_filter/3, file_filter/3,
file_filter_with_init/5, file_filter_with_initialization/5,
process/2 process/2
]). ]).
@ -142,7 +142,7 @@ file_filter(Inp, Out, Command) :-
close(StreamInp), close(StreamInp),
close(StreamOut). close(StreamOut).
file_filter_with_init(Inp, Out, Command, FormatString, Parameters) :- file_filter_with_initialization(Inp, Out, Command, FormatString, Parameters) :-
open(Inp, read, StreamInp), open(Inp, read, StreamInp),
open(Out, write, StreamOut), open(Out, write, StreamOut),
format(StreamOut, FormatString, Parameters), format(StreamOut, FormatString, Parameters),

View File

@ -2,6 +2,7 @@
%% konstant@let.rug.nl, Thu Jan 24 2002 %% konstant@let.rug.nl, Thu Jan 24 2002
%% %%
:- use_module(library(mpi)).
% make the `floor' operator return integer values % make the `floor' operator return integer values
:- set_prolog_flag(language, iso). :- set_prolog_flag(language, iso).

View File

@ -6,6 +6,10 @@
%% %%
%% This file is in the Public Domain. %% This file is in the Public Domain.
:- use_module(library(mpi)).
:- use_module(library(mpe)).
%% demo1_mpe.pl is the same as demo1.pl, except %% demo1_mpe.pl is the same as demo1.pl, except
%% that MPE is used to log MPI activity. %% that MPE is used to log MPI activity.

View File

@ -2,6 +2,8 @@
%% konstant@let.rug.nl, Tue Feb 12 2002 %% konstant@let.rug.nl, Tue Feb 12 2002
%% %%
:- use_module(library(mpi)).
%% %%
%% This the calculation that needs to be performed, in this case %% This the calculation that needs to be performed, in this case
%% the sum of [From..To] %% the sum of [From..To]

View File

@ -103,3 +103,5 @@ peer_to_client(ip(A,B,C,D), Client) :-
maplist(atom_number, Parts, Numbers), maplist(atom_number, Parts, Numbers),
Numbers = [A,B,C,D]. Numbers = [A,B,C,D].
socket_select(_,_,_,_,_) :-
format( user_error, "Unsupported in this version, please use wait_for_input/3~n", []).