Merge branch 'master' of https://github.com/vscosta/yap-6.3
This commit is contained in:
commit
9dac6e9612
@ -1208,6 +1208,7 @@ Term Yap_UnknownFlag(Term mod) {
|
||||
Term getYapFlag(Term tflag) {
|
||||
FlagEntry *fv;
|
||||
flag_term *tarr;
|
||||
tflag = Deref(tflag);
|
||||
if (IsVarTerm(tflag)) {
|
||||
Yap_Error(INSTANTIATION_ERROR, tflag, "yap_flag/2");
|
||||
return (FALSE);
|
||||
@ -1234,6 +1235,10 @@ Term getYapFlag(Term tflag) {
|
||||
Yap_Error(TYPE_ERROR_ATOM, tflag, "yap_flag/2");
|
||||
return (FALSE);
|
||||
}
|
||||
if (tflag == TermSilent)
|
||||
{
|
||||
Yap_DebugPlWriteln(TermSilent);
|
||||
}
|
||||
fv = GetFlagProp(AtomOfTerm(tflag));
|
||||
if (!fv) {
|
||||
Term fl = GLOBAL_Flags[USER_FLAGS_FLAG].at;
|
||||
|
@ -1052,13 +1052,13 @@ X_API void YAP_Init(YAP_init_args *yap_init) {
|
||||
MkAtomTerm(Yap_LookupAtom(Yap_BOOTFILE)));
|
||||
setBooleanGlobalPrologFlag(SAVED_PROGRAM_FLAG, false);
|
||||
} else {
|
||||
if (yap_init->QuietMode) {
|
||||
setVerbosity(TermSilent);
|
||||
}
|
||||
Yap_Restore(Yap_INPUT_STARTUP);
|
||||
init_globals(yap_init);
|
||||
|
||||
start_modules();
|
||||
if (yap_init->QuietMode) {
|
||||
setVerbosity(TermSilent);
|
||||
}
|
||||
if (yap_init->install && Yap_OUTPUT_STARTUP) {
|
||||
setAtomicGlobalPrologFlag(RESOURCE_DATABASE_FLAG,
|
||||
MkAtomTerm(Yap_LookupAtom(Yap_INPUT_STARTUP)));
|
||||
|
@ -357,6 +357,8 @@ static inline bool verboseMode(void) {
|
||||
|
||||
static inline void setVerbosity(Term val) {
|
||||
GLOBAL_Flags[VERBOSE_FLAG].at = val;
|
||||
if (val == TermSilent)
|
||||
GLOBAL_Flags[VERBOSE_LOAD_FLAG].at = TermFalse;
|
||||
}
|
||||
|
||||
static inline bool setSyntaxErrorsFlag(Term val) {
|
||||
|
@ -579,12 +579,12 @@ and if it is bound to `off` disable them. The default for YAP is
|
||||
is `false` by default except if YAP is booted with the `-L`
|
||||
flag.
|
||||
*/
|
||||
YAP_FLAG(VERBOSE_LOAD_FLAG, "verbose_load", true, isatom, "normal", NULL),
|
||||
YAP_FLAG(VERBOSE_LOAD_FLAG, "verbose_load", true, booleanFlag, "true", NULL),
|
||||
/**< `verbose_load `
|
||||
|
||||
If `true` allow printing of informational messages when
|
||||
consulting files. If `false` disable printing these messages. It
|
||||
is `normal` by default except if YAP is booted with the `-L`
|
||||
is `true` by default except if YAP is booted with the `-L`
|
||||
flag.
|
||||
*/
|
||||
YAP_FLAG(VERSION_FLAG, "version", false, nat, YAP_NUMERIC_VERSION, NULL),
|
||||
|
@ -1,3 +1,9 @@
|
||||
2:- use_module( library(lineutils) ).
|
||||
3
|
||||
4main :-
|
||||
5 unix(argv[Dir,Out]),
|
||||
6 open(Out,write,O),
|
||||
|
||||
:- module( prolog, [] ).
|
||||
7 go(Dir,O).
|
||||
9go(Dir,O) :-
|
||||
|
||||
|
@ -27,13 +27,13 @@ ECLASS(RESOURCE_ERROR, "resource_error", 2)
|
||||
/// bad text
|
||||
ECLASS(SYNTAX_ERROR_CLASS, "syntax_error", 1)
|
||||
/// OS or internal
|
||||
ECLASS(SYSTEM_ERROR_CLASS, "system_error", 2)
|
||||
ECLASS(SYSTEM_ERROR_CLASS, "system_error", 1)
|
||||
/// bad typing
|
||||
ECLASS(TYPE_ERROR, "type_error", 2)
|
||||
/// should be unbound
|
||||
ECLASS(UNINSTANTIATION_ERROR_CLASS, "uninstantiation_error", 1)
|
||||
/// escape hatch
|
||||
ECLASS(EVENT, "event", 2)
|
||||
/// user defined escape hatch
|
||||
ECLASS(EVENT, "event", 1)
|
||||
|
||||
END_ERROR_CLASSES();
|
||||
|
||||
|
@ -65,7 +65,7 @@
|
||||
sumnodes_body(3,+,+,-,+,+),
|
||||
include(1,+,-),
|
||||
exclude(1,+,-),
|
||||
partition(2,+,-,-),
|
||||
partition(1,+,-,-),
|
||||
partition(2,+,-,-,-),
|
||||
foldl(3, +, +, -),
|
||||
foldl2(5, +, +, -, +, -),
|
||||
|
24
os/streams.c
24
os/streams.c
@ -316,7 +316,7 @@ bool Yap_SetCurInpPos(
|
||||
}
|
||||
|
||||
Atom Yap_guessFileName(FILE *file, int sno, size_t max) {
|
||||
size_t maxs = Yap_Max(1023, max-1);
|
||||
size_t maxs = Yap_Max(1023, max - 1);
|
||||
if (!file) {
|
||||
Atom at = Yap_LookupAtom("mem");
|
||||
return at;
|
||||
@ -329,7 +329,7 @@ Atom Yap_guessFileName(FILE *file, int sno, size_t max) {
|
||||
|
||||
int i = push_text_stack();
|
||||
#if __linux__
|
||||
char *path = Malloc(1024), *nameb = Malloc(maxs+1);
|
||||
char *path = Malloc(1024), *nameb = Malloc(maxs + 1);
|
||||
size_t len;
|
||||
if ((len = snprintf(path, 1023, "/proc/self/fd/%d", f)) >= 0 &&
|
||||
(len = readlink(path, nameb, maxs)) > 0) {
|
||||
@ -339,14 +339,16 @@ Atom Yap_guessFileName(FILE *file, int sno, size_t max) {
|
||||
return at;
|
||||
}
|
||||
#elif __APPLE__
|
||||
char *nameb = Malloc(maxs + 1);
|
||||
if (fcntl(f, F_GETPATH, nameb) != -1) {
|
||||
Atom at = Yap_LookupAtom(nameb);
|
||||
pop_text_stack(i);
|
||||
return at;
|
||||
}
|
||||
#else
|
||||
TCHAR *path = Malloc(MAX_PATH + 1);
|
||||
if (!GetFullPathName(path, MAX_PATH, path, NULL)) {
|
||||
TCHAR *path = Malloc(MAX_PATH + 1), *nameb = Malloc(MAX_PATH + 1);
|
||||
|
||||
if (!GetFullPathName(path, MAX_PATH, nameb, NULL)) {
|
||||
pop_text_stack(i);
|
||||
return NULL;
|
||||
} else {
|
||||
@ -1001,11 +1003,11 @@ static void CloseStream(int sno) {
|
||||
CACHE_REGS
|
||||
|
||||
// fflush(NULL);
|
||||
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "close stream <%d>",
|
||||
// sno);
|
||||
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "close stream <%d>",
|
||||
// sno);
|
||||
VFS_t *me;
|
||||
//fprintf( stderr, "- %d\n",sno);
|
||||
if ((me = GLOBAL_Stream[sno].vfs) != NULL &&
|
||||
// fprintf( stderr, "- %d\n",sno);
|
||||
if ((me = GLOBAL_Stream[sno].vfs) != NULL &&
|
||||
GLOBAL_Stream[sno].file == NULL) {
|
||||
if (me->close) {
|
||||
me->close(sno);
|
||||
@ -1043,7 +1045,8 @@ if ((me = GLOBAL_Stream[sno].vfs) != NULL &&
|
||||
GLOBAL_Stream[sno].vfs = NULL;
|
||||
GLOBAL_Stream[sno].file = NULL;
|
||||
GLOBAL_Stream[sno].status = Free_Stream_f;
|
||||
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "close stream <%d>", sno);
|
||||
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "close stream <%d>",
|
||||
// sno);
|
||||
|
||||
/* if (st->status == Socket_Stream_f|Input_Stream_f|Output_Stream_f) {
|
||||
Yap_CloseSocket();
|
||||
@ -1556,8 +1559,7 @@ FILE *Yap_FileDescriptorFromStream(Term t) {
|
||||
return rc;
|
||||
}
|
||||
|
||||
void Yap_InitBackIO(void)
|
||||
{
|
||||
void Yap_InitBackIO(void) {
|
||||
Yap_InitCPredBack("stream_property", 2, 2, stream_property,
|
||||
cont_stream_property, SafePredFlag | SyncPredFlag);
|
||||
}
|
||||
|
@ -826,20 +826,21 @@ gradient_descent :-
|
||||
format(Handle,"%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%~n",[]),
|
||||
format(Handle,"% Iteration, train/test, QueryID, Query, GroundTruth, Prediction %~n",[]),
|
||||
format(Handle,"%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%~n",[]),
|
||||
format_learning(2,'Gradient ',[]),
|
||||
findall(FactID,tunable_fact(FactID,GroundTruth),L), length(L,N),
|
||||
% leash(0),trace,
|
||||
lbfgs_initialize(N,X,0,Solver),
|
||||
forall(tunable_fact(FactID,GroundTruth),
|
||||
(XZ is 0.5, X[FactID] <== XZ,set_fact_probability(FactID,XZ))),
|
||||
(XZ is 0.0, X[FactID] <== XZ,sigmoid(XZ,Slope,Pr),set_fact_probability(FactID,Pr))),
|
||||
problog_flag(sigmoid_slope,Slope),
|
||||
lbfgs_run(Solver,BestF),
|
||||
format('~2nOptimization done~nWe found a minimum ~4f.~n',[BestF]),
|
||||
forall(tunable_fact(FactID,GroundTruth), set_tunable(FactID,X)),
|
||||
forall(tunable_fact(FactID,GroundTruth), set_tunable(FactID,Slope,X)),
|
||||
set_problog_flag(mse_trainset, BestF),
|
||||
lbfgs_finalize(Solver).
|
||||
|
||||
set_tunable(I,P) :-
|
||||
Pr <== P[I],
|
||||
set_tunable(I,Slope,P) :-
|
||||
X <== P[I],
|
||||
sigmoid(X,Slope,Pr),
|
||||
set_fact_probability(I,Pr).
|
||||
|
||||
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
|
||||
@ -848,12 +849,12 @@ set_tunable(I,P) :-
|
||||
user:evaluate(LLH_Training_Queries, X,Grad,N,_,_) :-
|
||||
%Handle = user_error,
|
||||
GradCount <== array[N] of ints,
|
||||
Probs <== array[N] of floats,
|
||||
problog_flag(sigmoid_slope,Slope),
|
||||
Probs = X,
|
||||
N1 is N-1,
|
||||
|
||||
forall(between(0,N1,I),
|
||||
(Grad[I] <== 0.0) %, sigmoid(X[I],Slope,Probs[I]) )
|
||||
(Grad[I] <== 0.0, S <== X[I], sigmoid(S,Slope, P), Probs[I] <== P)
|
||||
),
|
||||
findall(LL,
|
||||
compute_grad(Grad, GradCount, Probs, Slope, LL),
|
||||
@ -875,15 +876,16 @@ compute_grad(Grad, GradCount, Probs, Slope, LL) :-
|
||||
%writeln( qprobability(BDD,Slope,BDDProb) ),
|
||||
forall(
|
||||
member(I-_, MapList),
|
||||
gradientpair(I, BDD,Slope,BDDProb, QueryProb, Grad, GradCount)
|
||||
gradientpair(I, BDD,Slope,BDDProb, QueryProb, Grad, Probs, GradCount)
|
||||
).
|
||||
|
||||
gradientpair(I, BDD,Slope,BDDProb, QueryProb, Grad, GradCount) :-
|
||||
gradientpair(I, BDD,Slope,BDDProb, QueryProb, Grad, Probs, GradCount) :-
|
||||
qgradient(I, BDD, Slope, FactID, GradValue),
|
||||
% writeln(FactID),
|
||||
G0 <== Grad[FactID],
|
||||
Prob <== Probs[FactID],
|
||||
%writeln( GN is G0-GradValue*(QueryProb-BDDProb)),
|
||||
GN is G0-GradValue*2*(QueryProb-BDDProb),
|
||||
GN is G0-GradValue*2*Prob*(1-Prob)*(QueryProb-BDDProb),
|
||||
%writeln(FactID:(G0->GN)),
|
||||
GC <== GradCount[FactID],
|
||||
GC1 is GC+1,
|
||||
@ -977,10 +979,10 @@ bind_maplist([Node-Pr|MapList], Slope, X) :-
|
||||
% stop calculate gradient
|
||||
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
|
||||
user:progress(FX,X,_G,X_Norm,G_Norm,Step,_N,Iteration,Ls,0) :-
|
||||
% problog_flag(sigmoid_slope,Slope),
|
||||
X0 <== X[0],
|
||||
X1 <== X[1],
|
||||
format('~d. Iteration : (x0,x1)=(~4f,~4f) f(X)=~4f |X|=~4f |X\'|=~4f Step=~4f Ls=~4f~n',[Iteration,X0 ,X1,FX,X_Norm,G_Norm,Step,Ls]).
|
||||
problog_flag(sigmoid_slope,Slope),
|
||||
X0 <== X[0], sigmoid(X0,Slope,P0),
|
||||
X1 <== X[1], sigmoid(X1,Slope,P1),
|
||||
format('~d. Iteration : (x0,x1)=(~4f,~4f) f(X)=~4f |X|=~4f |X\'|=~4f Step=~4f Ls=~4f~n',[Iteration,P0 ,P1,FX,X_Norm,G_Norm,Step,Ls]).
|
||||
|
||||
|
||||
%========================================================================
|
||||
|
@ -411,8 +411,8 @@ load_files(Files0,Opts) :-
|
||||
Val == large -> true ;
|
||||
'$do_error'(domain_error(unknown_option,qcompile(Val)),Call) ).
|
||||
'$process_lf_opt'(silent, Val, Call) :-
|
||||
( Val == false -> yap_flag(verbose_load, full) ;
|
||||
Val == true -> yap_flag(verbose_load, silent) ;
|
||||
( Val == false -> yap_flag(verbose_load, true) ;
|
||||
Val == true -> yap_flag(verbose_load, false) ;
|
||||
'$do_error'(domain_error(out_of_domain_option,silent(Val)),Call) ).
|
||||
'$process_lf_opt'(skip_unix_header, Val, Call) :-
|
||||
( Val == false -> true ;
|
||||
@ -925,7 +925,7 @@ nb_setval('$if_le1vel',0).
|
||||
'$init_win_graphics',
|
||||
fail.
|
||||
'$do_startup_reconsult'(X) :-
|
||||
catch(load_files(user:X, [silent(false)]), Error, '$LoopError'(Error, consult)),
|
||||
catch(load_files(user:X, [silent(true)]), Error, '$LoopError'(Error, consult)),
|
||||
!,
|
||||
( current_prolog_flag(halt_after_consult, false) -> true ; halt).
|
||||
'$do_startup_reconsult'(_).
|
||||
|
@ -609,7 +609,7 @@ be lost.
|
||||
GoalNumber =< G0,
|
||||
!,
|
||||
fail.
|
||||
'$re_trace_query'(forward(redo,G0), G, M, GoalNumber, H) :-
|
||||
'$re_trace_query'(forward(redo,G0), G, M, GoalNumber, H) :-
|
||||
GoalNumber > G0,
|
||||
!,
|
||||
catch(
|
||||
|
@ -1009,7 +1009,7 @@ prolog:print_message(Severity, Msg) :-
|
||||
),
|
||||
!.
|
||||
prolog:print_message(Level, _Msg) :-
|
||||
current_prolog_flag(verbose_load, silent),
|
||||
current_prolog_flag(verbose_load, false),
|
||||
stream_property(_Stream, alias(loop_stream) ),
|
||||
Level = informational,
|
||||
!.
|
||||
|
@ -578,7 +578,6 @@ predicate_statistics(P0,NCls,Sz,ISz) :-
|
||||
|
||||
Given predicate _P_, _NCls_ is the number of erased clauses for
|
||||
_P_ that could not be discarded yet, _Sz_ is the amount of space
|
||||
taken to store those clauses (in bytes), and _IndexSz_ is the amount
|
||||
of space required to store indices to those clauses (in bytes).
|
||||
|
||||
*/
|
||||
@ -596,9 +595,9 @@ Defines the relation: _P_ is a currently defined predicate whose name is the at
|
||||
*/
|
||||
current_predicate(A,T0) :-
|
||||
'$yap_strip_module'(T0, M, T),
|
||||
( var(Mod)
|
||||
( var(M)
|
||||
->
|
||||
'$all_current_modules'(Mod)
|
||||
'$all_current_modules'(M)
|
||||
;
|
||||
true
|
||||
),
|
||||
|
20
pl/qly.yap
20
pl/qly.yap
@ -229,6 +229,9 @@ qend_program :-
|
||||
% there is some ordering between flags.
|
||||
'x_yap_flag'(language, V) :-
|
||||
yap_flag(language, V).
|
||||
%if silent keep silent, otherwise use the saved state.
|
||||
'x_yap_flag'(verbose, _) :- !.
|
||||
'x_yap_flag'(verbose_load, _) :- !.
|
||||
'x_yap_flag'(M:P, V) :-
|
||||
current_module(M),
|
||||
yap_flag(M:P, V).
|
||||
@ -357,12 +360,9 @@ available it tries reconsulting the source file.
|
||||
|
||||
*/
|
||||
qload_module(Mod) :-
|
||||
( current_prolog_flag(verbose_load, true)
|
||||
->
|
||||
Verbosity = informational
|
||||
;
|
||||
current_prolog_flag(verbose_load, Verbosity)
|
||||
),
|
||||
prolog_flag(verbose_load, OldF, false),
|
||||
prolog_flag(verbose, OldV, silent),
|
||||
Verbosity = silent
|
||||
StartMsg = loading_module,
|
||||
EndMsg = module_loaded,
|
||||
'$current_module'(SourceModule, Mod),
|
||||
@ -375,6 +375,8 @@ qload_module(Mod) :-
|
||||
H is heapused-H0, '$cputime'(TF,_), T is TF-T0,
|
||||
print_message(Verbosity, loaded(EndMsg, File, Mod, T, H)),
|
||||
'$current_module'(_, SourceModule),
|
||||
prolog_flag(verbose_load, _, OldF),
|
||||
prolog_flag(verbose, _, OldV),
|
||||
working_directory(_, OldD).
|
||||
|
||||
'$qload_module'(Mod, S, SourceModule) :-
|
||||
@ -558,11 +560,11 @@ Restores a previously saved state of YAP contaianing a qly file _F_.
|
||||
|
||||
*/
|
||||
qload_file( F0 ) :-
|
||||
( current_prolog_flag(verbose_load, true)
|
||||
( current_prolog_flag(verbose_load, false)
|
||||
->
|
||||
Verbosity = informational
|
||||
;
|
||||
Verbosity = silent
|
||||
;
|
||||
current_prolog_flag(verbose, Verbosity)
|
||||
),
|
||||
StartMsg = loading_module,
|
||||
EndMsg = module_loaded,
|
||||
|
@ -41,7 +41,7 @@ rdir( FRoot ) :-
|
||||
absolute_file_name( FRoot, [glob(*), solutions(all), file_errors(fail)], File ),
|
||||
\+ doskip( File ),
|
||||
(
|
||||
catch( file_property( File, type(directory) ), _, fail )
|
||||
cat zzch( file_property( File, type(directory) ), _, fail )
|
||||
->
|
||||
assert_new( dir( File ) ),
|
||||
assert_new( sub_dir( FRoot, File ) ),
|
||||
|
Reference in New Issue
Block a user