459 lines
11 KiB
C++
459 lines
11 KiB
C++
|
|
/**
|
|
* @file yapq.hh
|
|
*
|
|
* @defgroup yap-cplus-query-handling Query Handling in the YAP interface.
|
|
* @brief Engine and Query Management
|
|
*
|
|
* @ingroup yap-cplus-interface
|
|
*
|
|
* @{
|
|
*
|
|
* These classes wrap engine and query. An engine is an environment where we can rum
|
|
* Prolog, that is, where we can run queries.
|
|
*
|
|
* Also, supports callbacks and engine configuration.
|
|
*
|
|
*/
|
|
|
|
#ifndef YAPQ_HH
|
|
#define YAPQ_HH 1
|
|
|
|
class YAPPredicate;
|
|
|
|
/**
|
|
Queries and engines
|
|
*/
|
|
|
|
/**
|
|
* @brief Queries
|
|
*
|
|
* interface to a YAP Query;
|
|
* uses an SWI-like status info internally.
|
|
*/
|
|
class YAPQuery : public YAPPredicate
|
|
{
|
|
bool q_open;
|
|
int q_state;
|
|
yhandle_t q_g, q_handles;
|
|
struct yami *q_p, *q_cp;
|
|
sigjmp_buf q_env;
|
|
int q_flags;
|
|
YAP_dogoalinfo q_h;
|
|
YAPQuery *oq;
|
|
YAPPairTerm names;
|
|
YAPTerm goal;
|
|
// temporaries
|
|
Term tnames, tgoal ;
|
|
|
|
inline void setNext() { // oq = LOCAL_execution;
|
|
// LOCAL_execution = this;
|
|
q_open = true;
|
|
q_state = 0;
|
|
q_flags = true; // PL_Q_PASS_EXCEPTION;
|
|
|
|
q_p = P;
|
|
q_cp = CP;
|
|
// make sure this is safe
|
|
q_handles = LOCAL_CurSlot;
|
|
};
|
|
|
|
|
|
void openQuery(Term t, Term *ts);
|
|
|
|
PredEntry *rewriteUndefQuery();
|
|
|
|
public:
|
|
YAPQuery() {
|
|
openQuery(TermTrue, nullptr);
|
|
};
|
|
/// main constructor, uses a predicate and an array of terms
|
|
///
|
|
/// It is given a YAPPredicate _p_ , and an array of terms that must have at
|
|
/// least
|
|
/// the same arity as the functor.
|
|
YAPQuery(YAPPredicate p, YAPTerm t[]);
|
|
/// full constructor,
|
|
///
|
|
///
|
|
/// It is given a functor, module, and an array of terms that must have at
|
|
/// least
|
|
/// the same arity as the functor.
|
|
YAPQuery(YAPFunctor f, YAPTerm mod, YAPTerm t[]);
|
|
/// functor/term constructor,
|
|
///
|
|
/// It is given a functor, and an array of terms that must have at least
|
|
/// the same arity as the functor. Works within the current module.
|
|
//YAPQuery(YAPFunctor f, YAPTerm t[]);
|
|
/// string constructor without varnames
|
|
///
|
|
/// It is given a string, calls the parser and obtains a Prolog term that
|
|
/// should be a callable
|
|
/// goal.
|
|
inline YAPQuery(const char *s) : YAPPredicate(s, tgoal, tnames)
|
|
{
|
|
CELL *qt = nullptr;
|
|
__android_log_print(ANDROID_LOG_INFO, "YAPDroid", "got game %ld",
|
|
LOCAL_CurSlot);
|
|
if (!ap)
|
|
return;
|
|
__android_log_print(ANDROID_LOG_INFO, "YAPDroid", "%s", vnames.text());
|
|
goal = YAPTerm(tgoal);
|
|
if (IsPairTerm(tgoal)) {
|
|
qt = RepPair(tgoal);
|
|
tgoal = Yap_MkApplTerm(Yap_MkFunctor(Yap_LookupAtom("consult"), 1),1,qt);
|
|
} else if (IsApplTerm(tgoal)) {
|
|
Functor f = FunctorOfTerm(tgoal);
|
|
if (!IsExtensionFunctor(f)) {
|
|
qt = RepAppl(tgoal)+1;
|
|
}
|
|
}
|
|
names = YAPPairTerm(tnames);
|
|
openQuery(tgoal, qt);
|
|
};
|
|
// inline YAPQuery() : YAPPredicate(s, tgoal, tnames)
|
|
// {
|
|
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "got game %ld",
|
|
// LOCAL_CurSlot);
|
|
// if (!ap)
|
|
// return;
|
|
// __android_log_print(ANDROID_LOG_INFO, "YAPDroid", "%s", vnames.text());
|
|
// goal = YAPTerm(tgoal);
|
|
// names = YAPPairTerm(tnames);
|
|
// openQuery(tgoal);
|
|
// };
|
|
/// string constructor with just an atom
|
|
///
|
|
/// It i;
|
|
///};
|
|
YAPQuery(YAPTerm t);
|
|
/// set flags for query execution, currently only for exception handling
|
|
void setFlag(int flag) { q_flags |= flag; }
|
|
/// reset flags for query execution, currently only for exception handling
|
|
void resetFlag(int flag) { q_flags &= ~flag; }
|
|
/// first query
|
|
///
|
|
/// actually implemented by calling the next();
|
|
inline bool first() { return next(); }
|
|
/// ask for the next solution of the current query
|
|
/// same call for every solution
|
|
bool next();
|
|
/// does this query have open choice-points?
|
|
/// or is it deterministic?
|
|
bool deterministic();
|
|
/// represent the top-goal
|
|
const char *text();
|
|
/// remove alternatives in the current search space, and finish the current
|
|
/// query
|
|
/// finish the current query: undo all bindings.
|
|
void close();
|
|
/// query variables.
|
|
void cut();
|
|
Term namedVars() {return names.term(); };
|
|
/// query variables, but copied out
|
|
std::vector<Term> namedVarsVector() {
|
|
return names.listToArray(); };
|
|
/// convert a ref to a binding.
|
|
YAPTerm getTerm(yhandle_t t);
|
|
/// simple YAP Query;
|
|
/// just calls YAP and reports success or failure, Useful when we just
|
|
/// want things done, eg YAPCommand("load_files(library(lists), )")
|
|
inline bool command()
|
|
{
|
|
bool rc = next();
|
|
close();
|
|
return rc;
|
|
};
|
|
};
|
|
|
|
// Java support
|
|
|
|
/// This class implements a callback Prolog-side. It will be inherited by the
|
|
/// Java or Python
|
|
/// class that actually implements the callback.
|
|
class YAPCallback
|
|
{
|
|
public:
|
|
virtual ~YAPCallback() {}
|
|
virtual void run() { LOG("callback"); }
|
|
virtual void run(char *s) {}
|
|
};
|
|
|
|
|
|
/// @brief Setup all arguments to a new engine
|
|
class YAPEngineArgs {
|
|
|
|
public:
|
|
|
|
YAP_init_args init_args;
|
|
|
|
inline void setEmbedded( bool fl )
|
|
{
|
|
init_args.Embedded = fl;
|
|
};
|
|
|
|
inline bool getEmbedded( )
|
|
{
|
|
return init_args.Embedded;
|
|
};
|
|
|
|
inline void setStackSize( bool fl )
|
|
{
|
|
init_args.StackSize = fl;
|
|
};
|
|
|
|
inline bool getStackSize( )
|
|
{
|
|
return init_args.StackSize;
|
|
};
|
|
|
|
inline void setTrailSize( bool fl )
|
|
{
|
|
init_args.TrailSize = fl;
|
|
};
|
|
|
|
inline bool getTrailSize( )
|
|
{
|
|
return init_args.TrailSize;
|
|
};
|
|
|
|
inline bool getMStackSize( )
|
|
{
|
|
return init_args.StackSize;
|
|
};
|
|
|
|
inline void setMaxTrailSize( bool fl )
|
|
{
|
|
init_args.MaxTrailSize = fl;
|
|
};
|
|
|
|
inline bool getMaxTrailSize( )
|
|
{
|
|
return init_args.MaxTrailSize;
|
|
};
|
|
|
|
inline void setYapLibDir( const char * fl )
|
|
{
|
|
init_args.YapLibDir = (const char *)malloc(strlen(fl)+1);
|
|
strcpy((char *)init_args.YapLibDir, fl);
|
|
};
|
|
|
|
inline const char * getYapLibDir( )
|
|
{
|
|
return init_args.YapLibDir;
|
|
};
|
|
|
|
inline void setYapShareDir( const char * fl )
|
|
{
|
|
init_args.YapShareDir = (const char *)malloc(strlen(fl)+1);
|
|
strcpy((char *)init_args.YapShareDir, fl);
|
|
};
|
|
|
|
inline const char * getYapShareDir( )
|
|
{
|
|
return init_args.YapShareDir;
|
|
};
|
|
|
|
inline void setSavedState( const char * fl )
|
|
{
|
|
init_args.SavedState = (const char *)malloc(strlen(fl)+1);
|
|
strcpy((char *)init_args.SavedState, fl);
|
|
};
|
|
|
|
inline const char * getSavedState( )
|
|
{
|
|
return init_args.SavedState;
|
|
};
|
|
|
|
inline void setYapPrologBootFile( const char * fl )
|
|
{
|
|
init_args.YapPrologBootFile = (const char *)malloc(strlen(fl)+1);
|
|
strcpy((char *)init_args.YapPrologBootFile, fl);
|
|
};
|
|
|
|
inline const char * getYapPrologBootFile( )
|
|
{
|
|
return init_args.YapPrologBootFile;
|
|
};
|
|
|
|
inline void setYapPrologGoal( const char * fl )
|
|
{
|
|
init_args.YapPrologGoal = fl;
|
|
};
|
|
|
|
inline const char * getYapPrologGoal( )
|
|
{
|
|
return init_args.YapPrologGoal;
|
|
};
|
|
|
|
inline void setYapPrologTopLevelGoal( const char * fl )
|
|
{
|
|
init_args.YapPrologTopLevelGoal = fl;
|
|
};
|
|
|
|
inline const char * getYapPrologTopLevelGoal( )
|
|
{
|
|
return init_args.YapPrologTopLevelGoal;
|
|
};
|
|
|
|
inline void setHaltAfterConsult( bool fl )
|
|
{
|
|
init_args.HaltAfterConsult = fl;
|
|
};
|
|
|
|
inline bool getHaltAfterConsult( )
|
|
{
|
|
return init_args.HaltAfterConsult;
|
|
};
|
|
|
|
inline void setFastBoot( bool fl )
|
|
{
|
|
init_args.FastBoot = fl;
|
|
};
|
|
|
|
inline bool getFastBoot( )
|
|
{
|
|
return init_args.FastBoot;
|
|
};
|
|
|
|
inline void setArgc( int fl )
|
|
{
|
|
init_args.Argc = fl;
|
|
};
|
|
|
|
inline int getArgc( )
|
|
{
|
|
return init_args.Argc;
|
|
};
|
|
|
|
inline void setArgv( char ** fl )
|
|
{
|
|
init_args.Argv = fl;
|
|
};
|
|
|
|
inline char ** getArgv( )
|
|
{
|
|
return init_args.Argv;
|
|
};
|
|
|
|
YAPEngineArgs() {
|
|
Yap_InitDefaults(&init_args, NULL, 0, NULL);
|
|
#if YAP_PYTHON
|
|
init_args.Embedded = true;
|
|
python_in_python = Py_IsInitialized();
|
|
#endif
|
|
};
|
|
};
|
|
|
|
|
|
/**
|
|
* @brief YAP Engine: takes care of the execution environment
|
|
where we can go executing goals.
|
|
*
|
|
*
|
|
*/
|
|
class YAPEngine
|
|
{
|
|
private:
|
|
YAPEngineArgs *engine_args;
|
|
YAPCallback *_callback;
|
|
YAPError yerror;
|
|
void doInit(YAP_file_type_t BootMode);
|
|
YAP_dogoalinfo q;
|
|
PredEntry *rewriteUndefEngineQuery(PredEntry *ap, Term t, Term tmod);
|
|
|
|
public :
|
|
/// construct a new engine; may use a variable number of arguments
|
|
YAPEngine(YAPEngineArgs *cargs)
|
|
{
|
|
engine_args = cargs;
|
|
//doInit(cargs->init_args.boot_file_type);
|
|
doInit(YAP_QLY);
|
|
}; /// construct a new engine, including aaccess to callbacks
|
|
/// construct a new engine using argc/argv list of arguments
|
|
YAPEngine(int argc, char *argv[],
|
|
YAPCallback *callback = (YAPCallback *)NULL);
|
|
/// kill engine
|
|
~YAPEngine() { delYAPCallback(); };
|
|
/// remove current callback
|
|
void delYAPCallback() { _callback = 0; };
|
|
/// set a new callback
|
|
void setYAPCallback(YAPCallback *cb)
|
|
{
|
|
delYAPCallback();
|
|
_callback = cb;
|
|
};
|
|
/// execute the callback.
|
|
////void run() { if (_callback) _callback.run(); }
|
|
/// execute the callback with a text argument.
|
|
void run(char *s)
|
|
{
|
|
if (_callback)
|
|
_callback->run(s);
|
|
}
|
|
/// stop yap
|
|
void close() { Yap_exit(0); }
|
|
|
|
/// execute the callback with a text argument.
|
|
bool hasError() { return LOCAL_Error_TYPE != YAP_NO_ERROR; }
|
|
/// build a query on the engine
|
|
YAPQuery *query(const char *s) { return new YAPQuery(s); };
|
|
/// build a query from a term
|
|
YAPQuery *query(YAPTerm t) { return new YAPQuery(t); };
|
|
/// build a query from a Prolog term (internal)
|
|
YAPQuery *qt(Term t) { return new YAPQuery(YAPTerm(t)); };
|
|
/// current module for the engine
|
|
YAPModule currentModule() { return YAPModule(); }
|
|
/// given a handle, fetch a term from the engine
|
|
inline YAPTerm getTerm(yhandle_t h) { return YAPTerm(h); }
|
|
/// current directory for the engine
|
|
bool call(YAPPredicate ap, YAPTerm ts[]);
|
|
/// current directory for the engine
|
|
bool goalt(YAPTerm Yt) { return Yt.term(); };
|
|
/// current directory for the engine
|
|
bool mgoal(Term t, Term tmod);
|
|
/// current directory for the engine
|
|
|
|
bool goal(Term t)
|
|
{
|
|
return mgoal(t, CurrentModule);
|
|
}
|
|
/// reset Prolog state
|
|
void reSet();
|
|
/// assune that there are no stack pointers, just release memory
|
|
// for last execution
|
|
void release();
|
|
|
|
const char *currentDir()
|
|
{
|
|
char dir[1024];
|
|
std::string s = Yap_getcwd(dir, 1024 - 1);
|
|
return s.c_str();
|
|
};
|
|
/// report YAP version as a string
|
|
const char *version()
|
|
{
|
|
std::string s = Yap_version();
|
|
return s.c_str();
|
|
};
|
|
//> call a deterninistic predicate: the user will construct aterm of
|
|
//> arity N-1. YAP adds an extra variable which will have the
|
|
//> output.
|
|
YAPTerm fun(YAPTerm t) { return YAPTerm(fun(t.term())); };
|
|
Term fun(Term t);
|
|
//> set a StringFlag, usually a path
|
|
//>
|
|
bool setStringFlag(std::string arg, std::string path)
|
|
{
|
|
return setYapFlag(MkAtomTerm(Yap_LookupAtom(arg.data())), MkAtomTerm(Yap_LookupAtom(path.data())));
|
|
};
|
|
|
|
Term top_level( std::string s);
|
|
Term next_answer(YAPQuery * &Q);
|
|
|
|
};
|
|
|
|
#endif /* YAPQ_HH */
|
|
|
|
/// @}
|