16f0e4534e
move them to yio.yap, where they belong. git-svn-id: https://yap.svn.sf.net/svnroot/yap/trunk@161 b08c6af1-5177-4d33-ba66-4b1c6b8b522a
1265 lines
33 KiB
Prolog
1265 lines
33 KiB
Prolog
/*************************************************************************
|
|
* *
|
|
* YAP Prolog *
|
|
* *
|
|
* Yap Prolog was developed at NCCUP - Universidade do Porto *
|
|
* *
|
|
* Copyright L.Damas, V.S.Costa and Universidade do Porto 1985-1997 *
|
|
* *
|
|
**************************************************************************
|
|
* *
|
|
* File: boot.yap *
|
|
* Last rev: 8/2/88 *
|
|
* mods: *
|
|
* comments: boot file for Prolog *
|
|
* *
|
|
*************************************************************************/
|
|
|
|
%
|
|
% This one should come first so that disjunctions and long distance
|
|
% cuts are compiled right with co-routining.
|
|
%
|
|
true :- true. % otherwise, $$compile will ignore this clause.
|
|
|
|
'$live' :-
|
|
'$init_system',
|
|
repeat,
|
|
'$set_input'(user),'$set_output'(user),
|
|
'$current_module'(Module),
|
|
( Module=user ->
|
|
'$compile_mode'(_,0)
|
|
;
|
|
'$format'(user_error,"[~w]~n", [Module])
|
|
),
|
|
'$system_catch'('$enter_top_level',Error,user:'$Error'(Error)).
|
|
|
|
|
|
'$init_system' :-
|
|
(
|
|
'$access_yap_flags'(15, 0) ->
|
|
'$version'
|
|
;
|
|
true
|
|
),
|
|
'$set_yap_flags'(10,0),
|
|
'$set_value'('$gc',on),
|
|
'$init_catch',
|
|
prompt(' ?- '),
|
|
(
|
|
'$get_value'('$break',0)
|
|
->
|
|
'$set_read_error_handler'(fail),
|
|
% after an abort, make sure all spy points are gone.
|
|
'$clean_debugging_info',
|
|
% simple trick to find out if this is we are booting from Prolog.
|
|
'$get_value'('$user_module',V),
|
|
( V = [] ->
|
|
'$current_module'(_,prolog)
|
|
;
|
|
'$current_module'(_,V), '$compile_mode'(_,0),
|
|
( exists('~/.yaprc') -> [-'~/.yaprc'] ; true ),
|
|
( exists('~/.prologrc') -> [-'~/.prologrc'] ; true ),
|
|
( exists('~/prolog.ini') -> [-'~/prolog.ini'] ; true )
|
|
),
|
|
'$clean_catch_and_throw',
|
|
'$db_clean_queues'(0),
|
|
'$startup_reconsult',
|
|
'$startup_goals'
|
|
;
|
|
true
|
|
).
|
|
|
|
'$init_catch' :-
|
|
% initialise access to the catch queue
|
|
( '$has_static_array'('$catch_queue') ->
|
|
true
|
|
;
|
|
static_array('$catch_queue',2, term)
|
|
),
|
|
update_array('$catch_queue', 0, '$'),
|
|
update_array('$catch_queue', 1, '$').
|
|
|
|
|
|
%
|
|
% encapsulate $cut_by because of co-routining.
|
|
%
|
|
'$cut_by'(X) :- '$$cut_by'(X).
|
|
|
|
% Start file for yap
|
|
|
|
/* I/O predicates */
|
|
|
|
/* meaning of flags for '$write' is
|
|
1 quote illegal atoms
|
|
2 ignore operator declarations
|
|
4 output '$VAR'(N) terms as A, B, C, ...
|
|
8 use portray(_)
|
|
*/
|
|
|
|
/* main execution loop */
|
|
'$read_vars'(Stream,T,V) :-
|
|
current_input(Old),
|
|
'$set_input'(Stream),
|
|
'$read'(true,T,V),
|
|
'$set_input'(Old).
|
|
|
|
% reset alarms when entering top-level.
|
|
'$enter_top_level' :-
|
|
'$alarm'(0, _),
|
|
fail.
|
|
'$enter_top_level' :-
|
|
'$clean_up_dead_clauses',
|
|
fail.
|
|
'$enter_top_level' :-
|
|
'$recorded'('$restore_goal',G,R),
|
|
erase(R),
|
|
prompt(_,' | '),
|
|
'$system_catch'('$do_yes_no'((G->true)),Error,user:'$Error'(Error)),
|
|
fail.
|
|
'$enter_top_level' :-
|
|
( '$get_value'('$trace', 1) ->
|
|
'$set_value'(spy_sl,0),
|
|
'$format'(user_error, "[trace]~n", [])
|
|
;
|
|
'$get_value'(debug, 1) ->
|
|
'$format'(user_error, "[debug]~n", [])
|
|
),
|
|
fail.
|
|
'$enter_top_level' :-
|
|
prompt(_,' ?- '),
|
|
prompt(' | '),
|
|
'$read_vars'(user_input,Command,Varnames),
|
|
'$set_value'(spy_sl,0),
|
|
'$set_value'(spy_fs,0),
|
|
'$set_value'(spy_sp,0),
|
|
'$set_value'(spy_gn,1),
|
|
( '$get_value'('$trace', 1) ->
|
|
'$set_yap_flags'(10,1)
|
|
;
|
|
'$set_yap_flags'(10,0)
|
|
),
|
|
'$set_value'(spy_cl,1),
|
|
'$set_value'(spy_leap,0),
|
|
'$setflop'(0),
|
|
prompt(_,' |: '),
|
|
'$run_toplevel_hooks',
|
|
'$command'((?-Command),Varnames,top),
|
|
'$sync_mmapped_arrays',
|
|
'$set_value'('$live',false).
|
|
|
|
'$startup_goals' :-
|
|
'$recorded'('$startup_goal',G,_),
|
|
'$system_catch'('$query'((G->true), []),Error,user:'$Error'(Error)),
|
|
fail.
|
|
'$startup_goals'.
|
|
|
|
'$startup_reconsult' :-
|
|
'$get_value'('$consult_on_boot',X), X \= [], !,
|
|
'$do_startup_reconsult'(X).
|
|
'$startup_reconsult'.
|
|
|
|
%
|
|
% remove any debugging info after an abort.
|
|
%
|
|
'$clean_debugging_info' :-
|
|
'$recorded'('$spy',_,R),
|
|
erase(R),
|
|
fail.
|
|
'$clean_debugging_info'.
|
|
|
|
'$erase_sets' :-
|
|
eraseall('$'),
|
|
eraseall('$$set'),
|
|
eraseall('$$one'),
|
|
eraseall('$reconsulted'), fail.
|
|
'$erase_sets' :- \+ '$recorded'('$path',_,_), '$recorda'('$path',"",_).
|
|
'$erase_sets'.
|
|
|
|
'$version' :-
|
|
'$get_value'('$version_name',VersionName),
|
|
'$format'(user_error, "[ YAP version ~w ]~n", [VersionName]),
|
|
fail.
|
|
'$version' :- '$recorded'('$version',VersionName,_),
|
|
'$format'(user_error, "~w~n", [VersionName]),
|
|
fail.
|
|
'$version'.
|
|
|
|
repeat :- '$repeat'.
|
|
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat'.
|
|
'$repeat' :- '$repeat'.
|
|
|
|
'$start_corouts' :- '$recorded'('$corout','$corout'(Name,_,_),R), Name \= main, finish_corout(R),
|
|
fail.
|
|
'$start_corouts' :-
|
|
eraseall('$corout'),
|
|
eraseall('$result'),
|
|
eraseall('$actual'),
|
|
fail.
|
|
'$start_corouts' :- '$recorda'('$actual',main,_),
|
|
'$recordz'('$corout','$corout'(main,main,'$corout'([],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[])),_Ref),
|
|
'$recorda'('$result',going,_).
|
|
|
|
'$command'(C,VL,Con) :-
|
|
'$access_yap_flags'(9,1), !,
|
|
'$execute_command'(C,VL,Con).
|
|
'$command'(C,VL,Con) :-
|
|
( (Con = top ; var(C) ; C = [_|_]) ->
|
|
'$execute_command'(C,VL,Con) ;
|
|
expand_term(C, EC),
|
|
'$execute_commands'(EC,VL,Con)
|
|
).
|
|
|
|
%
|
|
% Hack in case expand_term has created a list of commands.
|
|
%
|
|
'$execute_commands'(V,VL,Con) :- var(V), !,
|
|
throw(error(instantiation_error,meta_call(C))).
|
|
'$execute_commands'([],_,_) :- !, fail.
|
|
'$execute_commands'([C|_],VL,Con) :-
|
|
'$execute_command'(C,VL,Con).
|
|
'$execute_commands'([_|Cs],VL,Con) :- !,
|
|
'$execute_commands'(Cs,VL,Con).
|
|
'$execute_commands'(C,VL,Con) :-
|
|
'$execute_command'(C,VL,Con).
|
|
|
|
%
|
|
%
|
|
%
|
|
|
|
'$execute_command'(C,_,top) :- var(C), !,
|
|
throw(error(instantiation_error,meta_call(C))).
|
|
'$execute_command'(end_of_file,_,_).
|
|
'$execute_command'(C,_,top) :- number(C), !,
|
|
throw(error(type_error(callable,C),meta_call(C))).
|
|
'$execute_command'(R,_,top) :- db_reference(R), !,
|
|
throw(error(type_error(callable,R),meta_call(R))).
|
|
'$execute_command'((:-G),_,Option) :- !,
|
|
'$process_directive'(G, Option),
|
|
fail.
|
|
'$execute_command'((?-G),V,_) :- !,
|
|
'$execute_command'(G,V,top).
|
|
'$execute_command'((Mod:G),V,Option) :- !,
|
|
'$mod_switch'(Mod,'$execute_command'(G,V,Option)).
|
|
'$execute_command'(G,V,Option) :- '$continue_with_command'(Option,V,G).
|
|
|
|
%
|
|
% This command is very different depending on the language mode we are in.
|
|
%
|
|
% ISO only wants directives in files
|
|
% SICStus accepts everything in files
|
|
% YAP accepts everything everywhere
|
|
%
|
|
'$process_directive'(G, top) :-
|
|
'$access_yap_flags'(8, 0), !, % YAP mode, go in and do it,
|
|
'$process_directive'(G, consult).
|
|
'$process_directive'(G, top) :- !,
|
|
throw(error(context_error((:- G),clause),query)).
|
|
%
|
|
% always allow directives.
|
|
%
|
|
'$process_directive'(D, Mode) :-
|
|
'$directive'(D), !,
|
|
( '$exec_directive'(D, Mode) -> true ; true ).
|
|
%
|
|
% allow multiple directives
|
|
%
|
|
'$process_directive'((G1,G2), Mode) :-
|
|
'$all_directives'(G1),
|
|
'$all_directives'(G2), !,
|
|
'$exec_directives'(G1, Mode),
|
|
'$exec_directives'(G2, Mode).
|
|
%
|
|
% ISO does not allow goals (use initialization).
|
|
%
|
|
'$process_directive'(D, _) :-
|
|
'$access_yap_flags'(8, 1), !, % ISO Prolog mode, go in and do it,
|
|
throw(error(context_error((:- D),query),directive)).
|
|
%
|
|
% but YAP and SICStus does.
|
|
%
|
|
'$process_directive'(G, _) :-
|
|
'$current_module'(M),
|
|
( '$do_yes_no'(M:G) -> true ; '$format'(user_error,":- ~w:~w failed.~n",[M,G]) ).
|
|
|
|
'$all_directives'((G1,G2)) :- !,
|
|
'$all_directives'(G1),
|
|
'$all_directives'(G2).
|
|
'$all_directives'(G) :- !,
|
|
'$directive'(G).
|
|
|
|
'$continue_with_command'(reconsult,V,G) :-
|
|
'$go_compile_clause'(G,V,5),
|
|
fail.
|
|
'$continue_with_command'(consult,V,G) :-
|
|
'$go_compile_clause'(G,V,5),
|
|
fail.
|
|
'$continue_with_command'(top,V,G) :-
|
|
'$query'(G,V).
|
|
|
|
%
|
|
% not 100% compatible with SICStus Prolog, as SICStus Prolog would put
|
|
% module prefixes all over the place, although unnecessarily so.
|
|
%
|
|
'$go_compile_clause'(M:G,V,N) :- !,
|
|
'$mod_switch'(M,'$go_compile_clause'(G,V,N)).
|
|
'$go_compile_clause'((M:G :- B),V,N) :- !,
|
|
'$current_module'(M1),
|
|
(M1 = M ->
|
|
NG = (G :- B)
|
|
;
|
|
'$preprocess_clause_before_mod_change'((G:-B),M1,M,NG)
|
|
),
|
|
'$mod_switch'(M,'$go_compile_clause'(NG,V,N)).
|
|
'$go_compile_clause'(G,V,N) :-
|
|
'$prepare_term'(G,V,G0,G1),
|
|
'$$compile'(G1,G0,N).
|
|
|
|
'$prepare_term'(G,V,G0,G1) :-
|
|
( '$get_value'('$syntaxcheckflag',on) ->
|
|
'$check_term'(G,V) ; true ),
|
|
'$precompile_term'(G, G0, G1).
|
|
|
|
% proccess an input clause
|
|
'$$compile'(G,G0,L) :-
|
|
'$head_and_body'(G,H,_),
|
|
'$inform_of_clause'(H,L),
|
|
'$flags'(H, Fl, Fl),
|
|
( Fl /\ 16'002008 =\= 0 -> '$assertz_dynamic'(L,G,G0) ;
|
|
'$$compile_stat'(G,G0,L,H) ).
|
|
|
|
% process a clause for a static predicate
|
|
'$$compile_stat'(G,G0,L,H) :-
|
|
'$compile'(G,L),
|
|
% first occurrence of this predicate in this file,
|
|
% check if we need to erase the source and if
|
|
% it is a multifile procedure.
|
|
'$flags'(H,Fl,Fl),
|
|
( '$get_value'('$abol',true)
|
|
->
|
|
( Fl /\ 16'400000 =\= 0 -> '$erase_source'(H) ; true ),
|
|
( Fl /\ 16'040000 =\= 0 -> '$check_multifile_pred'(H,Fl) ; true )
|
|
;
|
|
true
|
|
),
|
|
( Fl /\ 16'400000 =:= 0 -> % is this procedure in source mode?
|
|
% no, just ignore
|
|
true
|
|
;
|
|
% and store our clause
|
|
'$store_stat_clause'(G0, H, L)
|
|
).
|
|
|
|
'$store_stat_clause'(G0, H, L) :-
|
|
'$head_and_body'(G0,H0,B0),
|
|
'$record_stat_source'(H,(H0:-B0),L,R),
|
|
functor(H, Na, Ar),
|
|
( '$is_multifile'(Na,Ar) ->
|
|
'$get_value'('$consulting_file',F),
|
|
'$current_module'(M),
|
|
'$recordz'('$multifile'(_,_,_), '$mf'(Na,Ar,M,F,R), _)
|
|
;
|
|
true
|
|
).
|
|
|
|
'$erase_source'(G) :- functor(G, Na, A),
|
|
'$is_multifile'(Na,A), !,
|
|
'$erase_mf_source'(Na,A).
|
|
'$erase_source'(G) :- '$recordedp'(G,_,R), erase(R), fail.
|
|
'$erase_source'(_).
|
|
|
|
'$erase_mf_source'(Na,A) :-
|
|
'$get_value'('$consulting_file',F),
|
|
'$current_module'(M),
|
|
'$recorded'('$multifile'(_,_,_), '$mf'(Na,A,M,F,R), R1),
|
|
erase(R1),
|
|
erase(R),
|
|
fail.
|
|
'$erase_mf_source'(Na,A) :-
|
|
'$get_value'('$consulting_file',F),
|
|
'$current_module'(M),
|
|
'$recorded'('$multifile_dynamic'(_,_,_), '$mf'(Na,A,M,F,R), R1),
|
|
erase(R1),
|
|
erase(R),
|
|
fail.
|
|
'$erase_mf_source'(_,_).
|
|
|
|
'$check_if_reconsulted'(N,A) :-
|
|
'$recorded'('$reconsulted',X,_),
|
|
( X = N/A , !;
|
|
X = '$', !, fail;
|
|
fail
|
|
).
|
|
|
|
'$inform_as_reconsulted'(N,A) :-
|
|
'$recorda'('$reconsulted',N/A,_).
|
|
|
|
'$clear_reconsulting' :-
|
|
'$recorded'('$reconsulted',X,Ref),
|
|
erase(Ref),
|
|
X == '$', !,
|
|
( '$recorded'('$reconsulting',_,R) -> erase(R) ).
|
|
|
|
/* Executing a query */
|
|
|
|
'$query'(end_of_file,V).
|
|
|
|
% ***************************
|
|
% * -------- YAPOR -------- *
|
|
% ***************************
|
|
|
|
'$query'(G,V) :-
|
|
\+ '$undefined'('$yapor_on'),
|
|
'$yapor_on',
|
|
\+ '$undefined'('$start_yapor'),
|
|
'$parallelizable'(G), !,
|
|
'$parallel_query'(G,V),
|
|
fail.
|
|
|
|
% end of YAPOR
|
|
|
|
'$query'(G,[]) :- !,
|
|
'$yes_no'(G,(?-)).
|
|
'$query'(G,V) :-
|
|
( '$execute'(G),
|
|
'$extract_goal_vars_for_dump'(V,LIV),
|
|
'$show_frozen'(G,LIV,LGs),
|
|
'$write_answer'(V, LGs, Written),
|
|
'$write_query_answer_true'(Written),
|
|
'$another',
|
|
!, fail ;
|
|
'$present_answer'(_, no),
|
|
fail
|
|
).
|
|
|
|
'$yes_no'(G,C) :-
|
|
'$do_yes_no'(G),
|
|
'$show_frozen'(G, [], LGs),
|
|
'$write_answer'([], LGs, Written),
|
|
( Written = [] ->
|
|
!,'$present_answer'(C, yes);
|
|
'$another', !
|
|
),
|
|
fail.
|
|
'$yes_no'(_,_) :-
|
|
'$present_answer'(_, no),
|
|
fail.
|
|
|
|
|
|
'$do_yes_no'([X|L]) :- !, '$csult'([X|L]).
|
|
'$do_yes_no'(G) :- '$execute'(G).
|
|
|
|
'$extract_goal_vars_for_dump'([],[]).
|
|
'$extract_goal_vars_for_dump'([[_|V]|VL],[V|LIV]) :-
|
|
'$extract_goal_vars_for_dump'(VL,LIV).
|
|
|
|
'$write_query_answer_true'([]) :- !,
|
|
'$format'(user_error,"~ntrue",[]).
|
|
'$write_query_answer_true'(_).
|
|
|
|
'$show_frozen'(G,V,LGs) :-
|
|
'$all_frozen_goals'(LGs0), LGs0 = [_|_], !,
|
|
'$all_attvars'(LAV),
|
|
'$convert_to_list_of_frozen_goals'(LGs0,V,LAV,G,LGs).
|
|
'$show_frozen'(_,_,[]).
|
|
|
|
%
|
|
% present_answer has three components. First it flushes the streams,
|
|
% then it presents the goals, and last it shows any goals frozen on
|
|
% the arguments.
|
|
%
|
|
'$present_answer'(_,_):-
|
|
'$flush_all_streams',
|
|
fail.
|
|
'$present_answer'((?-), Answ) :-
|
|
'$format'(user_error,"~n", []),
|
|
'$get_value'('$break',BL),
|
|
( BL \= 0 -> '$format'(user_error, "[~p] ",[BL]) ;
|
|
true ),
|
|
( '$recorded'('$print_options','$toplevel'(Opts),_) ->
|
|
write_term(user_error,Answ,Opts) ;
|
|
'$format'(user_error,"~w",[Answ])
|
|
),
|
|
'$format'(user_error,"~n", []).
|
|
|
|
'$another' :-
|
|
'$format'(user_error," ? ",[]),
|
|
'$get0'(user_input,C),
|
|
( C==59 ->
|
|
'$skip'(user_input,10),fail;
|
|
C==10 -> '$format'(user_error,"~n", [])
|
|
;
|
|
'$skip'(user_input,10), '$ask_again_for_another'
|
|
).
|
|
|
|
'$ask_again_for_another' :-
|
|
'$format'(user_error,"Action (\";\" for more choices, <return> for exit)", []),
|
|
'$another'.
|
|
|
|
'$write_answer'(_,_,_) :-
|
|
'$flush_all_streams',
|
|
fail.
|
|
'$write_answer'(Vs, LBlk, LAnsw) :-
|
|
'$purge_dontcares'(Vs,NVs),
|
|
'$prep_answer_var_by_var'(NVs, LAnsw, LBlk),
|
|
'$name_vars_in_goals'(LAnsw, Vs, NLAnsw),
|
|
'$write_vars_and_goals'(NLAnsw).
|
|
|
|
'$purge_dontcares'([],[]).
|
|
'$purge_dontcares'([[[95|_]|_]|Vs],NVs) :- !,
|
|
'$purge_dontcares'(Vs,NVs).
|
|
'$purge_dontcares'([V|Vs],[V|NVs]) :-
|
|
'$purge_dontcares'(Vs,NVs).
|
|
|
|
|
|
'$prep_answer_var_by_var'([], L, L).
|
|
'$prep_answer_var_by_var'([[Name|Value]|L], LF, L0) :-
|
|
'$delete_identical_answers'(L, Value, NL, Names),
|
|
'$prep_answer_var'([Name|Names], Value, LF, LI),
|
|
'$prep_answer_var_by_var'(NL, LI, L0).
|
|
|
|
% fetch all cases that have the same solution.
|
|
'$delete_identical_answers'([], _, [], []).
|
|
'$delete_identical_answers'([[Name|Value]|L], Value0, FL, [Name|Names]) :-
|
|
Value == Value0, !,
|
|
'$delete_identical_answers'(L, Value0, FL, Names).
|
|
'$delete_identical_answers'([VV|L], Value0, [VV|FL], Names) :-
|
|
'$delete_identical_answers'(L, Value0, FL, Names).
|
|
|
|
% now create a list of pairs that will look like goals.
|
|
'$prep_answer_var'(Names, Value, LF, L0) :- var(Value), !,
|
|
'$prep_answer_unbound_var'(Names, LF, L0).
|
|
'$prep_answer_var'(Names, Value, [nonvar(Names,Value)|L0], L0).
|
|
|
|
% ignore unbound variables
|
|
'$prep_answer_unbound_var'([_], L, L) :- !.
|
|
'$prep_answer_unbound_var'(Names, [var(Names)|L0], L0).
|
|
|
|
'$gen_name_string'(I,L,[C|L]) :- I < 26, !, C is I+65.
|
|
'$gen_name_string'(I,L0,LF) :-
|
|
I1 is I mod 26,
|
|
I2 is I // 26,
|
|
C is I1+65,
|
|
'$gen_name_string'(I2,[C|L0],LF).
|
|
|
|
'$write_vars_and_goals'([]).
|
|
'$write_vars_and_goals'([G1|LG]) :-
|
|
'$write_goal_output'(G1),
|
|
'$write_remaining_vars_and_goals'(LG).
|
|
|
|
'$write_remaining_vars_and_goals'([]).
|
|
'$write_remaining_vars_and_goals'([G1|LG]) :-
|
|
'$format'(user_error,",",[]),
|
|
'$write_goal_output'(G1),
|
|
'$write_remaining_vars_and_goals'(LG).
|
|
|
|
'$write_goal_output'(var([V|VL])) :-
|
|
'$format'(user_error,"~n~s",[V]),
|
|
'$write_output_vars'(VL).
|
|
'$write_goal_output'(nonvar([V|VL],B)) :-
|
|
'$format'(user_error,"~n~s",[V]),
|
|
'$write_output_vars'(VL),
|
|
'$format'(user_error," = ", []),
|
|
( '$recorded'('$print_options','$toplevel'(Opts),_) ->
|
|
write_term(user_error,B,Opts) ;
|
|
'$format'(user_error,"~w",[B])
|
|
).
|
|
|
|
'$write_goal_output'(_-G) :-
|
|
'$format'(user_error,"~n",[]),
|
|
( '$recorded'('$print_options','$toplevel'(Opts),_) ->
|
|
write_term(user_error,G,Opts) ;
|
|
'$format'(user_error,"~w",[G])
|
|
).
|
|
|
|
'$name_vars_in_goals'(G, VL0, NG) :-
|
|
'$copy_term_but_not_constraints'(G+VL0, NG+NVL0),
|
|
'$name_well_known_vars'(NVL0),
|
|
'$variables_in_term'(NG, [], NGVL),
|
|
'$name_vars_in_goals1'(NGVL, 0, _).
|
|
|
|
'$name_well_known_vars'([]).
|
|
'$name_well_known_vars'([[Name|V]|NVL0]) :-
|
|
var(V), !,
|
|
V = '$VAR'(Name),
|
|
'$name_well_known_vars'(NVL0).
|
|
'$name_well_known_vars'([_|NVL0]) :-
|
|
'$name_well_known_vars'(NVL0).
|
|
|
|
'$name_vars_in_goals1'([], I, I).
|
|
'$name_vars_in_goals1'(['$VAR'([95|Name])|NGVL], I0, IF) :-
|
|
I is I0+1,
|
|
'$gen_name_string'(I0,[],Name), !,
|
|
'$name_vars_in_goals1'(NGVL, I, IF).
|
|
'$name_vars_in_goals1'([NV|NGVL], I0, IF) :-
|
|
nonvar(NV),
|
|
'$name_vars_in_goals1'(NGVL, II, IF).
|
|
|
|
'$write_output_vars'([]).
|
|
'$write_output_vars'([V|VL]) :-
|
|
'$format'(user_error," = ~s",[V]),
|
|
'$write_output_vars'(VL).
|
|
|
|
call(G) :- '$execute'(G).
|
|
|
|
incore(G) :- '$execute'(G).
|
|
|
|
%
|
|
% standard meta-call, called if $execute could not do everything.
|
|
%
|
|
'$meta_call'(G) :-
|
|
'$save_current_choice_point'(CP),
|
|
'$call'(G, CP, G).
|
|
|
|
%
|
|
% do it in ISO mode.
|
|
%
|
|
'$meta_call'(G,_ISO) :-
|
|
'$iso_check_goal'(G,G),
|
|
'$save_current_choice_point'(CP),
|
|
'$call'(G, CP, G).
|
|
|
|
'$meta_call'(G, CP, G0) :-
|
|
'$call'(G, CP,G0).
|
|
|
|
'$spied_meta_call'(G) :-
|
|
'$save_current_choice_point'(CP),
|
|
'$spied_call'(G, CP, G).
|
|
|
|
'$spied_meta_call'(G, CP, G0) :-
|
|
'$spied_call'(G, CP, G0).
|
|
|
|
'$call'(G, CP, G0, _) :- /* iso version */
|
|
'$iso_check_goal'(G,G0),
|
|
'$call'(G, CP,G0).
|
|
|
|
'$call'(M:_,_,G0) :- var(M), !,
|
|
throw(error(instantiation_error,call(G0))).
|
|
'$call'(M:G,CP,G0) :- !,
|
|
'$mod_switch'(M,'$call'(G,CP,G0)).
|
|
'$call'((A,B),CP,G0) :- !,
|
|
'$execute_within'(A,CP,G0),
|
|
'$execute_within'(B,CP,G0).
|
|
'$call'((X->Y),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(X,CP,G0)
|
|
->
|
|
'$execute_within'(Y,CP,G0)
|
|
).
|
|
'$call'((X->Y; Z),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(X,CP,G0)
|
|
->
|
|
'$execute_within'(Y,CP,G0)
|
|
;
|
|
'$execute_within'(Z,CP,G0)
|
|
).
|
|
'$call'((A;B),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(A,CP,G0)
|
|
;
|
|
'$execute_within'(B,CP,G0)
|
|
).
|
|
'$call'((A|B),CP, G0) :- !,
|
|
(
|
|
'$execute_within'(A,CP,G0)
|
|
;
|
|
'$execute_within'(B,CP,G0)
|
|
).
|
|
'$call'(\+ X, _, _) :- !,
|
|
\+ '$execute'(X).
|
|
'$call'(not(X), _, _) :- !,
|
|
\+ '$execute'(X).
|
|
'$call'(!, CP, _) :- !,
|
|
'$$cut_by'(CP).
|
|
'$call'([A|B],_, _) :- !,
|
|
'$csult'([A|B]).
|
|
'$call'(A, _, _) :-
|
|
(
|
|
% goal_expansion is defined, or
|
|
'$pred_goal_expansion_on'
|
|
;
|
|
% this is a meta-predicate
|
|
'$flags'(A,F,_), F /\ 0x200000 =:= 0x200000
|
|
), !,
|
|
'$current_module'(CurMod),
|
|
'$exec_with_expansion'(A, CurMod, CurMod).
|
|
'$call'(A, _, _) :-
|
|
'$execute0'(A).
|
|
|
|
'$spied_call'(M:_,_,G0) :- var(M), !,
|
|
throw(error(instantiation_error,call(G0))).
|
|
'$spied_call'(M:G,CP,G0) :- !,
|
|
'$mod_switch'(M,'$spied_call'(G,CP,G0)).
|
|
'$spied_call'((A,B),CP,G0) :- !,
|
|
'$execute_within'(A,CP,G0),
|
|
'$execute_within'(B,CP,G0).
|
|
'$spied_call'((X->Y),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(X,CP,G0)
|
|
->
|
|
'$execute_within'(Y,CP,G0)
|
|
).
|
|
'$spied_call'((X->Y; Z),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(X,CP,G0)
|
|
->
|
|
'$execute_within'(Y,CP,G0)
|
|
;
|
|
'$execute_within'(Z,CP,G0)
|
|
).
|
|
'$spied_call'((A;B),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(A,CP,G0)
|
|
;
|
|
'$execute_within'(B,CP,G0)
|
|
).
|
|
'$spied_call'((A|B),CP,G0) :- !,
|
|
(
|
|
'$execute_within'(A,CP,G0)
|
|
;
|
|
'$execute_within'(B,CP,G0)
|
|
).
|
|
'$spied_call'(\+ X,_,_) :- !,
|
|
\+ '$execute'(X).
|
|
'$spied_call'(not X,_,_) :- !,
|
|
\+ '$execute'(X).
|
|
'$spied_call'(!,CP,_) :-
|
|
'$$cut_by'(CP).
|
|
'$spied_call'([A|B],_,_) :- !,
|
|
'$csult'([A|B]).
|
|
'$spied_call'(A, _CP, _G0) :-
|
|
(
|
|
% goal_expansion is defined, or
|
|
'$pred_goal_expansion_on'
|
|
;
|
|
% this is a meta-predicate
|
|
'$flags'(A,F,_), F /\ 0x200000 =:= 0x200000
|
|
), !,
|
|
'$current_module'(CurMod),
|
|
'$exec_with_expansion'(A, CurMod, CurMod).
|
|
'$spied_call'(A,CP,G0) :-
|
|
( '$undefined'(A) ->
|
|
functor(A,F,N), '$current_module'(M),
|
|
( '$recorded'('$import','$import'(S,M,F,N),_) ->
|
|
'$spied_call'(S:A,CP,G0) ;
|
|
'$spy'(A)
|
|
)
|
|
;
|
|
'$spy'(A)
|
|
).
|
|
|
|
'$check_callable'(V,G) :- var(V), !,
|
|
'$current_module'(Mod),
|
|
throw(error(instantiation_error,Mod:G)).
|
|
'$check_callable'(A,G) :- number(A), !,
|
|
'$current_module'(Mod),
|
|
throw(error(type_error(callable,A),Mod:G)).
|
|
'$check_callable'(R,G) :- db_reference(R), !,
|
|
'$current_module'(Mod),
|
|
throw(error(type_error(callable,R),Mod:G)).
|
|
'$check_callable'(_,_).
|
|
|
|
% Called by the abstract machine, if no clauses exist for a predicate
|
|
'$undefp'([M|G]) :-
|
|
functor(G,F,N),
|
|
'$recorded'('$import','$import'(S,M,F,N),_),
|
|
S \= M, % can't try importing from the module itself.
|
|
!,
|
|
'$exec_with_expansion'(G, S, M).
|
|
'$undefp'([M|G]) :-
|
|
\+ '$undefined'(user:unknown_predicate_handler(_,_,_)),
|
|
user:unknown_predicate_handler(G,M,NG), !,
|
|
'$execute'(M:NG).
|
|
'$undefp'([_|G]) :- '$is_dynamic'(G), !, fail.
|
|
'$undefp'([M|G]) :-
|
|
'$recorded'('$unknown','$unknown'(M:G,US),_), !,
|
|
'$execute'(user:US).
|
|
|
|
|
|
/* This is the break predicate,
|
|
it saves the importante data about current streams and
|
|
debugger state */
|
|
|
|
break :- '$get_value'('$break',BL), NBL is BL+1,
|
|
'$get_value'(spy_sl,SPY_SL),
|
|
'$get_value'(spy_fs,SPY_FS),
|
|
'$get_value'(spy_sp,SPY_SP),
|
|
'$get_value'(spy_gn,SPY_GN),
|
|
'$access_yap_flags'(10,SPY_CREEP),
|
|
'$get_value'(spy_cl,SPY_CL),
|
|
'$get_value'(spy_leap,_Leap),
|
|
'$set_value'('$break',NBL),
|
|
current_output(OutStream), current_input(InpStream),
|
|
'$format'(user_error, "[ Break (level ~w) ]~n", [NBL]),
|
|
'$live',
|
|
!,
|
|
'$set_value'('$live',true),
|
|
'$set_value'(spy_sl,SPY_SL),
|
|
'$get_value'(spy_fs,SPY_FS),
|
|
'$set_value'(spy_sp,SPY_SP),
|
|
'$set_value'(spy_gn,SPY_GN),
|
|
'$set_yap_flags'(10,SPY_CREEP),
|
|
'$set_value'(spy_cl,SPY_CL),
|
|
'$set_value'(spy_leap,_Leap),
|
|
'$set_input'(InpStream), '$set_output'(OutStream),
|
|
'$set_value'('$break',BL).
|
|
|
|
|
|
'$csult'(V) :- var(V), !,
|
|
throw(error(instantiation_error,consult(V))).
|
|
'$csult'([]) :- !.
|
|
'$csult'([-F|L]) :- !, '$reconsult'(F), '$csult'(L).
|
|
'$csult'([F|L]) :- '$consult'(F), '$csult'(L).
|
|
|
|
'$consult'(V) :- var(V), !,
|
|
throw(error(instantiation_error,consult(V))).
|
|
'$consult'([]) :- !.
|
|
'$consult'([F|Fs]) :- !,
|
|
'$consult'(F),
|
|
'$consult'(Fs).
|
|
'$consult'(X) :- atom(X), !,
|
|
'$find_in_path'(X,Y),
|
|
( '$open'(Y,'$csult',Stream,0), !,
|
|
'$record_loaded'(Stream),
|
|
'$consult'(X,Stream),
|
|
'$close'(Stream)
|
|
;
|
|
throw(error(permission_error(input,stream,Y),consult(X)))
|
|
).
|
|
'$consult'(M:X) :- !,
|
|
'$mod_switch'(M,'$consult'(X)).
|
|
'$consult'(library(X)) :- !,
|
|
'$find_in_path'(library(X),Y),
|
|
( '$open'(Y,'$csult',Stream,0), !,
|
|
'$record_loaded'(Stream),
|
|
'$consult'(library(X),Stream), '$close'(Stream)
|
|
;
|
|
throw(error(permission_error(input,stream,library(X)),consult(library(X))))
|
|
).
|
|
'$consult'(V) :-
|
|
throw(error(type_error(atom,V),consult(V))).
|
|
|
|
|
|
'$consult'(F,Stream) :-
|
|
'$access_yap_flags'(8, 2), % SICStus Prolog compatibility
|
|
!,
|
|
'$reconsult'(F,Stream).
|
|
'$consult'(F,Stream) :-
|
|
'$getcwd'(OldD),
|
|
'$get_value'('$consulting_file',OldF),
|
|
'$set_consulting_file'(Stream),
|
|
H0 is heapused, T0 is cputime,
|
|
current_stream(File,_,Stream),
|
|
'$start_consult'(consult,File,LC),
|
|
'$get_value'('$consulting',Old),
|
|
'$set_value'('$consulting',true),
|
|
'$recorda'('$initialisation','$',_),
|
|
( '$get_value'('$verbose',on) ->
|
|
tab(user_error,LC),
|
|
'$format'(user_error, "[ consulting ~w... ]~n", [F])
|
|
; true ),
|
|
'$loop'(Stream,consult),
|
|
'$end_consult',
|
|
( LC == 0 -> prompt(_,' |: ') ; true),
|
|
( '$get_value'('$verbose',on) ->
|
|
tab(user_error,LC) ;
|
|
true ),
|
|
H is heapused-H0, T is cputime-T0,
|
|
( '$get_value'('$verbose',off) ->
|
|
true
|
|
;
|
|
'$format'(user_error, "[ ~w consulted ~w bytes in ~g seconds ]~n", [F,H,T])
|
|
),
|
|
'$set_value'('$consulting',Old),
|
|
'$set_value'('$consulting_file',OldF),
|
|
'$cd'(OldD),
|
|
!.
|
|
|
|
|
|
'$record_loaded'(user).
|
|
'$record_loaded'(user_input).
|
|
'$record_loaded'(Stream) :-
|
|
'$loaded'(Stream), !.
|
|
'$record_loaded'(Stream) :-
|
|
'$file_name'(Stream,F),
|
|
'$file_age'(F,Age),
|
|
'$recorda'('$loaded','$loaded'(F,Age),_).
|
|
|
|
'$set_consulting_file'(user) :- !,
|
|
'$set_value'('$consulting_file',user_input).
|
|
'$set_consulting_file'(user_input) :- !,
|
|
'$set_value'('$consulting_file',user_input).
|
|
'$set_consulting_file'(Stream) :-
|
|
'$file_name'(Stream,F),
|
|
'$set_value'('$consulting_file',F),
|
|
'$set_consulting_dir'(F).
|
|
|
|
%
|
|
% Use directory where file exists
|
|
%
|
|
'$set_consulting_dir'(F) :-
|
|
atom_codes(F,S),
|
|
'$strip_file_for_scd'(S,Dir,Unsure,Unsure),
|
|
'$cd'(Dir).
|
|
|
|
%
|
|
% The algorithm: I have two states, one for what I am sure will be an answer,
|
|
% the other for what I have found so far.
|
|
%
|
|
'$strip_file_for_scd'([], [], _, _).
|
|
'$strip_file_for_scd'([D|L], Out, Out, Cont) :-
|
|
'$dir_separator'(D), !,
|
|
'$strip_file_for_scd'(L, Cont, [D|C2], C2).
|
|
'$strip_file_for_scd'([F|L], Out, Cont, [F|C2]) :-
|
|
'$strip_file_for_scd'(L, Out, Cont, C2).
|
|
|
|
|
|
'$loop'(Stream,Status) :-
|
|
'$current_module'(OldModule),
|
|
'$change_alias_to_stream'('$loop_stream',Stream),
|
|
repeat,
|
|
( current_stream(_,_,Stream) -> true
|
|
; '$current_module'(_,OldModule), '$abort_loop'(Stream)
|
|
),
|
|
prompt('| '), prompt(_,'| '),
|
|
'$system_catch'('$enter_command'(Stream,Status), Error,
|
|
user:'$LoopError'(Error)),
|
|
!,
|
|
'$exec_initialisation_goals',
|
|
'$current_module'(_,OldModule).
|
|
|
|
'$enter_command'(Stream,Status) :-
|
|
'$read_vars'(Stream,Command,Vars),
|
|
'$command'(Command,Vars,Status).
|
|
|
|
'$abort_loop'(Stream) :-
|
|
throw(permission_error(input,closed_stream,Stream), loop).
|
|
|
|
/* General purpose predicates */
|
|
|
|
'$append'([], L, L) .
|
|
'$append'([H|T], L, [H|R]) :-
|
|
'$append'(T, L, R).
|
|
|
|
'$head_and_body'((H:-B),H,B) :- !.
|
|
'$head_and_body'(H,H,true).
|
|
|
|
%
|
|
% split head and body, generate an error if body is unbound.
|
|
%
|
|
'$check_head_and_body'((H:-B),H,B,P) :- !,
|
|
'$check_head'(H,P).
|
|
'$check_head_and_body'(H,H,true,P) :-
|
|
'$check_head'(H,P).
|
|
|
|
'$check_head'(H,P) :- var(H), !,
|
|
throw(error(instantiation_error,P)).
|
|
'$check_head'(H,P) :- number(H), !,
|
|
throw(error(type_error(callable,H),P)).
|
|
'$check_head'(H,P) :- db_reference(H), !,
|
|
throw(error(type_error(callable,H),P)).
|
|
'$check_head'(_,_).
|
|
|
|
% Path predicates
|
|
|
|
'$exists'(F,Mode) :- '$get_value'(fileerrors,V), '$set_value'(fileerrors,0),
|
|
( '$open'(F,Mode,S,0), !, '$close'(S), '$set_value'(fileerrors,V);
|
|
'$set_value'(fileerrors,V), fail).
|
|
|
|
|
|
'$find_in_path'(user,user_input) :- !.
|
|
'$find_in_path'(user_input,user_input) :- !.
|
|
'$find_in_path'(library(File),NewFile) :- !,
|
|
'$find_library_in_path'(File, NewFile).
|
|
'$find_in_path'(File,File) :- '$exists'(File,'$csult'), !.
|
|
'$find_in_path'(File,NewFile) :- name(File,FileStr),
|
|
'$search_in_path'(FileStr,NewFile),!.
|
|
'$find_in_path'(File,File).
|
|
|
|
'$find_library_in_path'(File, NewFile) :-
|
|
user:library_directory(Dir),
|
|
atom_codes(File,FileS),
|
|
atom_codes(Dir,DirS),
|
|
'$dir_separator'(A),
|
|
'$append'(DirS,[A|FileS],NewS),
|
|
atom_codes(NewFile,NewS),
|
|
'$exists'(NewFile,'$csult'), !.
|
|
'$find_library_in_path'(File, NewFile) :-
|
|
'$getenv'('YAPLIBDIR', LibDir),
|
|
'$dir_separator'(A),
|
|
atom_codes(File,FileS),
|
|
atom_codes(LibDir,Dir1S),
|
|
'$append'(Dir1S,[A|"library"],DirS),
|
|
'$append'(DirS,[A|FileS],NewS),
|
|
atom_codes(NewFile,NewS),
|
|
'$exists'(NewFile,'$csult'), !.
|
|
'$find_library_in_path'(File, File).
|
|
|
|
'$search_in_path'(File,New) :-
|
|
'$recorded'('$path',Path,_), '$append'(Path,File,NewStr),
|
|
name(New,NewStr),'$exists'(New,'$csult').
|
|
|
|
path(Path) :- findall(X,'$in_path'(X),Path).
|
|
|
|
'$in_path'(X) :- '$recorded'('$path',S,_),
|
|
( S == "" -> X = '.' ;
|
|
name(X,S) ).
|
|
|
|
add_to_path(New) :- add_to_path(New,last).
|
|
|
|
add_to_path(New,Pos) :- '$check_path'(New,Str), '$add_to_path'(Str,Pos).
|
|
|
|
'$add_to_path'(New,_) :- '$recorded'('$path',New,R), erase(R), fail.
|
|
'$add_to_path'(New,last) :- !, '$recordz'('$path',New,_).
|
|
'$add_to_path'(New,first) :- '$recorda'('$path',New,_).
|
|
|
|
remove_from_path(New) :- '$check_path'(New,Path),
|
|
'$recorded'('$path',Path,R), erase(R).
|
|
|
|
'$check_path'(At,SAt) :- atom(At), !, name(At,S), '$check_path'(S,SAt).
|
|
'$check_path'([],[]).
|
|
'$check_path'([Ch],[Ch]) :- '$dir_separator'(Ch), !.
|
|
'$check_path'([Ch],[Ch,A]) :- !, integer(Ch), '$dir_separator'(A).
|
|
'$check_path'([N|S],[N|SN]) :- integer(N), '$check_path'(S,SN).
|
|
|
|
|
|
% term expansion
|
|
%
|
|
% return two arguments: Expanded0 is the term after "USER" expansion.
|
|
% Expanded is the final expanded term.
|
|
%
|
|
'$precompile_term'(Term, Expanded0, Expanded) :-
|
|
(
|
|
'$access_yap_flags'(9,1) /* strict_iso on */
|
|
->
|
|
'$expand_term_modules'(Term, Expanded0, Expanded),
|
|
'$check_iso_strict_clause'(Expanded0)
|
|
;
|
|
'$expand_term_modules'(Term, Expanded0, ExpandedI),
|
|
'$expand_array_accesses_in_term'(ExpandedI,Expanded)
|
|
).
|
|
|
|
expand_term(Term,Expanded) :-
|
|
( \+ '$undefined'(user:term_expansion(_,_)),
|
|
user:term_expansion(Term,Expanded)
|
|
;
|
|
'$expand_term_grammar'(Term,Expanded)
|
|
),
|
|
!.
|
|
|
|
|
|
%
|
|
% Grammar Rules expansion
|
|
%
|
|
'$expand_term_grammar'((A-->B), C) :-
|
|
'$translate_rule'((A-->B),C), !.
|
|
'$expand_term_grammar'(A, A).
|
|
|
|
%
|
|
% Arithmetic expansion
|
|
%
|
|
'$expand_term_arith'(G1, G2) :-
|
|
'$get_value'('$c_arith',true),
|
|
'$c_arith'(G1, G2), !.
|
|
'$expand_term_arith'(G,G).
|
|
|
|
|
|
%
|
|
% Arithmetic expansion
|
|
%
|
|
'$expand_array_accesses_in_term'(Expanded0,ExpandedF) :-
|
|
'$array_refs_compiled',
|
|
'$c_arrays'(Expanded0,ExpandedF), !.
|
|
'$expand_array_accesses_in_term'(Expanded,Expanded).
|
|
|
|
%
|
|
% Module system expansion
|
|
%
|
|
'$expand_term_modules'(A,B,C) :- '$module_expansion'(A,B,C), !.
|
|
'$expand_term_modules'(A,A,A).
|
|
|
|
|
|
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
|
|
% catch/throw implementation
|
|
|
|
catch(G,C,A) :- var(G), !,
|
|
throw(error(instantiation_error,catch(G,C,A))).
|
|
catch(G,C,A) :- number(G), !,
|
|
throw(error(type_error(callable,G),catch(G,C,A))).
|
|
catch(R,C,A) :- db_reference(R), !,
|
|
throw(error(type_error(callable,R),catch(R,C,A))).
|
|
catch(G,C,A) :-
|
|
'$catch'(G,C,A).
|
|
|
|
'$catch'(G,C,A) :-
|
|
'$get_value'('$catch', I),
|
|
I1 is I+1,
|
|
'$set_value'('$catch', I1),
|
|
'$current_module'(M),
|
|
'$catch'(G,C,A,I,M).
|
|
|
|
'$catch'(G,_,_,I,_) :-
|
|
% on entry we push the catch choice point
|
|
X is '$last_choice_pt',
|
|
'$catch_call'(X,G,I, NX),
|
|
(X = NX -> !, '$erase_catch_elements'(I) ; true).
|
|
% someone sent us a throw.
|
|
'$catch'(_,C,A,_,M) :-
|
|
array_element('$catch_queue', 1, X), X \= '$',
|
|
update_array('$catch_queue', 1, '$'),
|
|
array_element('$catch_queue', 0, catch(_,Lev,Q)), !,
|
|
update_array('$catch_queue', 0, Q),
|
|
'$db_clean_queues'(Lev),
|
|
'$erase_catch_elements'(Lev),
|
|
( C=X -> '$current_module'(_,M), '$execute'(A) ; throw(X)).
|
|
% normal exit: make sure we only erase what we should erase!
|
|
'$catch'(_,_,_,I,_) :-
|
|
'$erase_catch_elements'(I),
|
|
fail.
|
|
|
|
'$catch_call'(X,G,I,NX) :-
|
|
array_element('$catch_queue', 0, OldCatch),
|
|
update_array('$catch_queue', 0, catch(X,I,OldCatch)),
|
|
'$execute'(G),
|
|
NX is '$last_choice_pt',
|
|
(
|
|
array_element('$catch_queue', 0, catch(X,I,Catch)),
|
|
update_array('$catch_queue', 0, Catch)
|
|
;
|
|
% on backtracking reinstate the catch before backtracking to G
|
|
array_element('$catch_queue', 0, Catch),
|
|
update_array('$catch_queue', 0, catch(X,I,Catch)),
|
|
fail
|
|
).
|
|
|
|
%
|
|
% system_catch is like catch, but it avoids the overhead of a full
|
|
% meta-call by calling '$execute0' and '$mod_switch' instead of $execute.
|
|
% This way it
|
|
% also avoids module preprocessing and goal_expansion
|
|
%
|
|
'$system_catch'(G,C,A) :-
|
|
'$get_value'('$catch', I),
|
|
I1 is I+1,
|
|
'$set_value'('$catch', I1),
|
|
'$current_module'(M),
|
|
'$system_catch'(G,C,A,I,M).
|
|
|
|
'$system_catch'(G,_,_,I,_) :-
|
|
% on entry we push the catch choice point
|
|
X is '$last_choice_pt',
|
|
'$system_catch_call'(X,G,I,NX),
|
|
( X = NX -> !, '$erase_catch_elements'(I) ; true).
|
|
% someone sent us a throw.
|
|
'$system_catch'(_,C,A,_,M0) :-
|
|
array_element('$catch_queue', 1, X), X \= '$',
|
|
update_array('$catch_queue', 1, '$'),
|
|
array_element('$catch_queue', 0, catch(_,Lev,Q)), !,
|
|
update_array('$catch_queue', 0, Q),
|
|
'$db_clean_queues'(Lev),
|
|
'$erase_catch_elements'(Lev),
|
|
( C=X ->
|
|
'$current_module'(_,M0),
|
|
(A = M:G -> '$mod_switch'(M,G) ; '$mod_switch'(M0,A))
|
|
;
|
|
throw(X)
|
|
).
|
|
% normal exit: make sure we only erase what we should erase!
|
|
'$system_catch'(_,_,_,I,_) :-
|
|
'$erase_catch_elements'(I),
|
|
fail.
|
|
|
|
'$erase_catch_elements'(I) :-
|
|
array_element('$catch_queue', 0, OldCatch),
|
|
'$erase_catch_elements'(OldCatch, I, Catch),
|
|
update_array('$catch_queue', 0, Catch).
|
|
|
|
'$erase_catch_elements'(catch(X, J, P), I, Catch) :-
|
|
J >= I, !,
|
|
'$erase_catch_elements'(P, I, Catch).
|
|
'$erase_catch_elements'(Catch, _, Catch).
|
|
|
|
'$system_catch_call'(X,G,I, NX) :-
|
|
array_element('$catch_queue', 0, OldCatch),
|
|
update_array('$catch_queue', 0, catch(X,I,OldCatch)),
|
|
'$execute0'(G),
|
|
NX is '$last_choice_pt',
|
|
( % on exit remove the catch
|
|
array_element('$catch_queue', 0, catch(X,I,Catch)),
|
|
update_array('$catch_queue', 0, Catch)
|
|
;
|
|
% on backtracking reinstate the catch before backtracking to G
|
|
array_element('$catch_queue', 0, Catch),
|
|
update_array('$catch_queue', 0, catch(X,I,Catch)),
|
|
fail
|
|
).
|
|
|
|
throw(A) :-
|
|
% fetch the point to jump to
|
|
array_element('$catch_queue', 0, catch(X,_,_)), !,
|
|
% now explain why we are jumping.
|
|
update_array('$catch_queue', 1, A),
|
|
'$$cut_by'(X),
|
|
fail.
|
|
throw(G) :-
|
|
'$format'(user_error,"system_error_at(~w)",[G]),
|
|
abort.
|
|
|
|
'$check_list'(V, _) :- var(V), !.
|
|
'$check_list'([], _) :- !.
|
|
'$check_list'([_|B], T) :- !,
|
|
'$check_list'(B,T).
|
|
'$check_list'(S, T) :-
|
|
throw(error(type_error(list,S),T)).
|
|
|
|
'$clean_catch_and_throw' :-
|
|
'$set_value'('$catch', 0),
|
|
fail.
|
|
'$clean_catch_and_throw' :-
|
|
'$recorded'('$catch',_,R),
|
|
erase(R),
|
|
fail.
|
|
'$clean_catch_and_throw' :-
|
|
'$recorded'('$throw',_,R),
|
|
erase(R),
|
|
fail.
|
|
'$clean_catch_and_throw'.
|
|
|
|
'$exec_initialisation_goals' :-
|
|
'$recorded'('$blocking_code',_,R),
|
|
erase(R),
|
|
fail.
|
|
% system goals must be performed first
|
|
'$exec_initialisation_goals' :-
|
|
'$recorded'('$system_initialisation',G,R),
|
|
erase(R),
|
|
G \= '$',
|
|
call(G),
|
|
fail.
|
|
'$exec_initialisation_goals' :-
|
|
'$recorded'('$initialisation',G,R),
|
|
erase(R),
|
|
G \= '$',
|
|
'$system_catch'(once(G), Error, user:'$LoopError'(Error)),
|
|
fail.
|
|
'$exec_initialisation_goals'.
|
|
|
|
|
|
'$run_toplevel_hooks' :-
|
|
'$get_value'('$break',0),
|
|
'$recorded'('$toplevel_hooks',H,_), !,
|
|
( '$execute'(H) -> true ; true).
|
|
'$run_toplevel_hooks'.
|
|
|
|
|
|
|