X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FScripting%2FNasalSys.cxx;h=75c49fbcf5d05d7b262b1de836e01ba9d21569d9;hb=4b59c152eafb5aa52c4562838090f037c07b65e9;hp=ffef17dc64beb38a41165f4ccc1466d4868ad08d;hpb=5c38395395065ce5d2de0cf479d35fc1861e624c;p=flightgear.git diff --git a/src/Scripting/NasalSys.cxx b/src/Scripting/NasalSys.cxx index ffef17dc6..75c49fbcf 100644 --- a/src/Scripting/NasalSys.cxx +++ b/src/Scripting/NasalSys.cxx @@ -23,6 +23,7 @@ #include #include #include +#include #include #include #include @@ -33,13 +34,16 @@ #include #include +#include "NasalSGPath.hxx" #include "NasalSys.hxx" #include "NasalSys_private.hxx" +#include "NasalAircraft.hxx" #include "NasalModelData.hxx" #include "NasalPositioned.hxx" #include "NasalCanvas.hxx" #include "NasalClipboard.hxx" #include "NasalCondition.hxx" +#include "NasalHTTP.hxx" #include "NasalString.hxx" #include
@@ -47,6 +51,8 @@ #include
using std::map; +using std::string; +using std::vector; void postinitNasalGUI(naRef globals, naContext c); @@ -125,7 +131,8 @@ public: if (_singleShot) { globals->get_event_mgr()->addEvent(_name, this, &TimerObj::invoke, _interval); } else { - globals->get_event_mgr()->addTask(_name, this, &TimerObj::invoke, _interval); + globals->get_event_mgr()->addTask(_name, this, &TimerObj::invoke, + _interval, _interval /* delay */); } } @@ -139,11 +146,14 @@ public: void invoke() { + if( _singleShot ) + // Callback may restart the timer, so update status before callback is + // called (Prevent warnings of deleting not existing tasks from the + // event manager). + _isRunning = false; + naRef *args = NULL; _sys->callMethod(_func, _self, 0, args, naNil() /* locals */); - if (_singleShot) { - _isRunning = false; - } } void setSingleShot(bool aSingleShot) @@ -196,12 +206,14 @@ static char* readfile(const char* file, int* lenOut) return buf; } -FGNasalSys::FGNasalSys() +FGNasalSys::FGNasalSys() : + _inited(false) { nasalSys = this; _context = 0; _globals = naNil(); _string = naNil(); + _wrappedNodeFunc = naNil(); _log = new simgear::BufferedLogCallback(SG_NASAL, SG_INFO); _log->truncateAt(255); @@ -229,6 +241,11 @@ naRef FGNasalSys::call(naRef code, int argc, naRef* args, naRef locals) return callMethod(code, naNil(), argc, args, locals); } +naRef FGNasalSys::callWithContext(naContext ctx, naRef code, int argc, naRef* args, naRef locals) +{ + return callMethodWithContext(ctx, code, naNil(), argc, args, locals); +} + // Does a naCall() in a new context. Wrapped here to make lock // tracking easier. Extension functions are called with the lock, but // we have to release it before making a new naCall(). So rather than @@ -241,25 +258,30 @@ naRef FGNasalSys::callMethod(naRef code, naRef self, int argc, naRef* args, naRe return naCallMethod(code, self, argc, args, locals); } +naRef FGNasalSys::callMethodWithContext(naContext ctx, naRef code, naRef self, int argc, naRef* args, naRef locals) +{ + return naCallMethodCtx(ctx, code, self, argc, args, locals); +} + FGNasalSys::~FGNasalSys() { + if (_inited) { + SG_LOG(SG_GENERAL, SG_ALERT, "Nasal was not shutdown"); + } nasalSys = 0; - map::iterator it, end = _listener.end(); - for(it = _listener.begin(); it != end; ++it) - delete it->second; - - naFreeContext(_context); - _globals = naNil(); - _string = naNil(); } bool FGNasalSys::parseAndRun(const char* sourceCode) { - naRef code = parse("FGNasalSys::parseAndRun()", sourceCode, + naContext ctx = naNewContext(); + naRef code = parse(ctx, "FGNasalSys::parseAndRun()", sourceCode, strlen(sourceCode)); - if(naIsNil(code)) + if(naIsNil(code)) { + naFreeContext(ctx); return false; - call(code, 0, 0, naNil()); + } + callWithContext(ctx, code, 0, 0, naNil()); + naFreeContext(ctx); return true; } @@ -292,21 +314,26 @@ FGNasalScript* FGNasalSys::parseScript(const char* src, const char* name) // This allows a Nasal object to hold onto a property path and use it // like a node object, e.g. setprop(ObjRoot, "size-parsecs", 2.02). This // is the utility function that walks the property tree. -// Future enhancement: support integer arguments to specify array -// elements. -static SGPropertyNode* findnode(naContext c, naRef* vec, int len) +static SGPropertyNode* findnode(naContext c, naRef* vec, int len, bool create=false) { SGPropertyNode* p = globals->get_props(); try { for(int i=0; igetNode(naStr_data(a)); + if(!naIsString(a)) { + naRuntimeError(c, "bad argument to setprop/getprop path: expected a string"); + } + naRef b = i < len-1 ? naNumValue(vec[i+1]) : naNil(); + if (!naIsNil(b)) { + p = p->getNode(naStr_data(a), (int)b.num, create); + i++; + } else { + p = p->getNode(naStr_data(a), create); + } if(p == 0) return 0; } } catch (const string& err) { naRuntimeError(c, (char *)err.c_str()); - return 0; } return p; } @@ -317,7 +344,10 @@ static SGPropertyNode* findnode(naContext c, naRef* vec, int len) static naRef f_getprop(naContext c, naRef me, int argc, naRef* args) { using namespace simgear; - const SGPropertyNode* p = findnode(c, args, argc); + if (argc < 1) { + naRuntimeError(c, "getprop() expects at least 1 argument"); + } + const SGPropertyNode* p = findnode(c, args, argc, false); if(!p) return naNil(); switch(p->getType()) { @@ -353,45 +383,29 @@ static naRef f_getprop(naContext c, naRef me, int argc, naRef* args) // final argument. static naRef f_setprop(naContext c, naRef me, int argc, naRef* args) { -#define BUFLEN 1024 - char buf[BUFLEN + 1]; - buf[BUFLEN] = 0; - char* p = buf; - int buflen = BUFLEN; - if(argc < 2) naRuntimeError(c, "setprop() expects at least 2 arguments"); - for(int i=0; i 0) { - *p++ = '/'; - buflen--; - } + if (argc < 2) { + naRuntimeError(c, "setprop() expects at least 2 arguments"); } + naRef val = args[argc - 1]; + SGPropertyNode* p = findnode(c, args, argc-1, true); - SGPropertyNode* props = globals->get_props(); - naRef val = args[argc-1]; bool result = false; try { - if(naIsString(val)) result = props->setStringValue(buf, naStr_data(val)); + if(naIsString(val)) result = p->setStringValue(naStr_data(val)); else { - naRef n = naNumValue(val); - if(naIsNil(n)) + if(!naIsNum(val)) naRuntimeError(c, "setprop() value is not string or number"); - if (SGMisc::isNaN(n.num)) { + if (SGMisc::isNaN(val.num)) { naRuntimeError(c, "setprop() passed a NaN"); } - result = props->setDoubleValue(buf, n.num); + result = p->setDoubleValue(val.num); } } catch (const string& err) { naRuntimeError(c, (char *)err.c_str()); } return naNum(result); -#undef BUFLEN } // print() extension function. Concatenates and prints its arguments @@ -477,7 +491,7 @@ static naRef f_makeTimer(naContext c, naRef me, int argc, naRef* args) } TimerObj* timerObj = new TimerObj(nasalSys, func, self, args[0].num); - return NasalTimerObj::create(c, timerObj); + return nasal::to_nasal(c, timerObj); } // setlistener(func, property, bool) extension function. Falls through to @@ -599,10 +613,12 @@ static naRef f_findDataDir(naContext c, naRef me, int argc, naRef* args) class NasalCommand : public SGCommandMgr::Command { public: - NasalCommand(FGNasalSys* sys, naRef f) : + NasalCommand(FGNasalSys* sys, naRef f, const std::string& name) : _sys(sys), - _func(f) + _func(f), + _name(name) { + globals->get_commands()->addCommandObject(_name, this); _gcRoot = sys->gcSave(f); } @@ -626,6 +642,7 @@ private: FGNasalSys* _sys; naRef _func; int _gcRoot; + std::string _name; }; static naRef f_addCommand(naContext c, naRef me, int argc, naRef* args) @@ -633,20 +650,16 @@ static naRef f_addCommand(naContext c, naRef me, int argc, naRef* args) if(argc != 2 || !naIsString(args[0]) || !naIsFunc(args[1])) naRuntimeError(c, "bad arguments to addcommand()"); - naRef func = args[1]; - NasalCommand* cmd = new NasalCommand(nasalSys, func); - globals->get_commands()->addCommandObject(naStr_data(args[0]), cmd); + nasalSys->addCommand(args[1], naStr_data(args[0])); return naNil(); } static naRef f_removeCommand(naContext c, naRef me, int argc, naRef* args) { - SGCommandMgr::Command* cmd = globals->get_commands()->getCommand(naStr_data(args[0])); - - // SGCommandMgr::Command* cmd = globals->get_commands()->removeCommand(naStr_data(args[0])) - - delete cmd; + if ((argc < 1) || !naIsString(args[0])) + naRuntimeError(c, "bad argument to removecommand()"); + globals->get_commands()->removeCommand(naStr_data(args[0])); return naNil(); } @@ -688,6 +701,35 @@ static naRef f_parsexml(naContext c, naRef me, int argc, naRef* args) return naStr_fromdata(naNewString(c), const_cast(file), strlen(file)); } +/** + * Parse very simple and small subset of markdown + * + * parse_markdown(src) + */ +static naRef f_parse_markdown(naContext c, naRef me, int argc, naRef* args) +{ + nasal::CallContext ctx(c, me, argc, args); + return ctx.to_nasal( + simgear::SimpleMarkdown::parse(ctx.requireArg(0)) + ); +} + +/** + * Create md5 hash from given string + * + * md5(str) + */ +static naRef f_md5(naContext c, naRef me, int argc, naRef* args) +{ + if( argc != 1 || !naIsString(args[0]) ) + naRuntimeError(c, "md5(): wrong type or number of arguments"); + + return nasal::to_nasal( + c, + simgear::strutils::md5(naStr_data(args[0]), naStr_len(args[0])) + ); +} + // Return UNIX epoch time in seconds. static naRef f_systime(naContext c, naRef me, int argc, naRef* args) { @@ -726,6 +768,8 @@ static struct { const char* name; naCFunction func; } funcs[] = { { "resolvepath", f_resolveDataPath }, { "finddata", f_findDataDir }, { "parsexml", f_parsexml }, + { "parse_markdown", f_parse_markdown }, + { "md5", f_md5 }, { "systime", f_systime }, { 0, 0 } }; @@ -742,6 +786,9 @@ void FGNasalSys::setCmdArg(SGPropertyNode* aNode) void FGNasalSys::init() { + if (_inited) { + SG_LOG(SG_GENERAL, SG_ALERT, "duplicate init of Nasal"); + } int i; _context = naNewContext(); @@ -775,9 +822,12 @@ void FGNasalSys::init() initNasalPositioned(_globals, _context); initNasalPositioned_cppbind(_globals, _context); + initNasalAircraft(_globals, _context); NasalClipboard::init(this); initNasalCanvas(_globals, _context); initNasalCondition(_globals, _context); + initNasalHTTP(_globals, _context); + initNasalSGPath(_globals, _context); NasalTimerObj::init("Timer") .method("start", &TimerObj::start) @@ -785,7 +835,7 @@ void FGNasalSys::init() .method("restart", &TimerObj::restart) .member("singleShot", &TimerObj::isSingleShot, &TimerObj::setSingleShot) .member("isRunning", &TimerObj::isRunning); - + // Now load the various source files in the Nasal directory simgear::Dir nasalDir(SGPath(globals->get_fg_root(), "Nasal")); loadScriptDirectory(nasalDir); @@ -803,7 +853,7 @@ void FGNasalSys::init() const char *s = "nasal-dir-initialized"; SGPropertyNode *signal = fgGetNode("/sim/signals", true); signal->setBoolValue(s, true); - signal->removeChildren(s, false); + signal->removeChildren(s); // Pull scripts out of the property tree, too loadPropertyScripts(); @@ -811,19 +861,62 @@ void FGNasalSys::init() // now Nasal modules are loaded, we can do some delayed work postinitNasalPositioned(_globals, _context); postinitNasalGUI(_globals, _context); + + _inited = true; +} + +void FGNasalSys::shutdown() +{ + if (!_inited) { + return; + } + + shutdownNasalPositioned(); + + map::iterator it, end = _listener.end(); + for(it = _listener.begin(); it != end; ++it) + delete it->second; + _listener.clear(); + + NasalCommandDict::iterator j = _commands.begin(); + for (; j != _commands.end(); ++j) { + globals->get_commands()->removeCommand(j->first); + } + _commands.clear(); + + std::vector::iterator k = _moduleListeners.begin(); + for(; k!= _moduleListeners.end(); ++k) + delete *k; + _moduleListeners.clear(); + + naClearSaved(); + + _string = naNil(); // will be freed by _context + naFreeContext(_context); + + //setWatchedRef(_globals); + + // remove the recursive reference in globals + hashset(_globals, "globals", naNil()); + _globals = naNil(); + + naGC(); + _inited = false; } naRef FGNasalSys::wrappedPropsNode(SGPropertyNode* aProps) { - static naRef wrapNodeFunc = naNil(); - if (naIsNil(wrapNodeFunc)) { + if (naIsNil(_wrappedNodeFunc)) { nasal::Hash props = getGlobals().get("props"); - wrapNodeFunc = props.get("wrapNode"); + _wrappedNodeFunc = props.get("wrapNode"); } naRef args[1]; args[0] = propNodeGhost(aProps); - return naCall(_context, wrapNodeFunc, 1, args, naNil(), naNil()); + naContext ctx = naNewContext(); + naRef wrapped = naCall(ctx, _wrappedNodeFunc, 1, args, naNil(), naNil()); + naFreeContext(ctx); + return wrapped; } void FGNasalSys::update(double) @@ -853,6 +946,9 @@ void FGNasalSys::update(double) _unloadList.pop()->unload(); } + // Destroy all queued ghosts + nasal::ghostProcessDestroyList(); + // The global context is a legacy thing. We use dynamically // created contexts for naCall() now, so that we can call them // recursively. But there are still spots that want to use it for @@ -977,6 +1073,7 @@ void FGNasalSys::loadPropertyScripts(SGPropertyNode* n) if (enable) { FGNasalModuleListener* listener = new FGNasalModuleListener(n); + _moduleListeners.push_back(listener); enable->addChangeListener(listener, false); } } @@ -1029,48 +1126,62 @@ bool FGNasalSys::createModule(const char* moduleName, const char* fileName, const SGPropertyNode* cmdarg, int argc, naRef* args) { - naRef code = parse(fileName, src, len); - if(naIsNil(code)) + naContext ctx = naNewContext(); + naRef code = parse(ctx, fileName, src, len); + if(naIsNil(code)) { + naFreeContext(ctx); return false; + } + // See if we already have a module hash to use. This allows the // user to, for example, add functions to the built-in math // module. Make a new one if necessary. naRef locals; - naRef modname = naNewString(_context); + naRef modname = naNewString(ctx); naStr_fromdata(modname, (char*)moduleName, strlen(moduleName)); if(!naHash_get(_globals, modname, &locals)) - locals = naNewHash(_context); + locals = naNewHash(ctx); _cmdArg = (SGPropertyNode*)cmdarg; - call(code, argc, args, locals); + callWithContext(ctx, code, argc, args, locals); hashset(_globals, moduleName, locals); + + naFreeContext(ctx); return true; } void FGNasalSys::deleteModule(const char* moduleName) { - naRef modname = naNewString(_context); + if (!_inited) { + // can occur on shutdown due to us being shutdown first, but other + // subsystems having Nasal objects. + return; + } + + naContext ctx = naNewContext(); + naRef modname = naNewString(ctx); naStr_fromdata(modname, (char*)moduleName, strlen(moduleName)); naHash_delete(_globals, modname); + naFreeContext(ctx); } -naRef FGNasalSys::parse(const char* filename, const char* buf, int len) +naRef FGNasalSys::parse(naContext ctx, const char* filename, const char* buf, int len) { int errLine = -1; - naRef srcfile = naNewString(_context); + naRef srcfile = naNewString(ctx); naStr_fromdata(srcfile, (char*)filename, strlen(filename)); - naRef code = naParseCode(_context, srcfile, 1, (char*)buf, len, &errLine); + naRef code = naParseCode(ctx, srcfile, 1, (char*)buf, len, &errLine); if(naIsNil(code)) { SG_LOG(SG_NASAL, SG_ALERT, - "Nasal parse error: " << naGetError(_context) << + "Nasal parse error: " << naGetError(ctx) << " in "<< filename <<", line " << errLine); return naNil(); } // Bind to the global namespace before returning - return naBindFunction(_context, code, _globals); + return naBindFunction(ctx, code, _globals); } bool FGNasalSys::handleCommand( const char* moduleName, @@ -1078,18 +1189,22 @@ bool FGNasalSys::handleCommand( const char* moduleName, const char* src, const SGPropertyNode* arg ) { - naRef code = parse(fileName, src, strlen(src)); - if(naIsNil(code)) return false; + naContext ctx = naNewContext(); + naRef code = parse(ctx, fileName, src, strlen(src)); + if(naIsNil(code)) { + naFreeContext(ctx); + return false; + } // Commands can be run "in" a module. Make sure that module // exists, and set it up as the local variables hash for the // command. naRef locals = naNil(); if(moduleName[0]) { - naRef modname = naNewString(_context); + naRef modname = naNewString(ctx); naStr_fromdata(modname, (char*)moduleName, strlen(moduleName)); if(!naHash_get(_globals, modname, &locals)) { - locals = naNewHash(_context); + locals = naNewHash(ctx); naHash_set(_globals, modname, locals); } } @@ -1099,7 +1214,8 @@ bool FGNasalSys::handleCommand( const char* moduleName, // code doesn't need it. _cmdArg = (SGPropertyNode*)arg; - call(code, 0, 0, locals); + callWithContext(ctx, code, 0, 0, locals); + naFreeContext(ctx); return true; } @@ -1109,7 +1225,7 @@ bool FGNasalSys::handleCommand(const SGPropertyNode* arg) const char* moduleName = arg->getStringValue("module"); return handleCommand( moduleName, - arg ? arg->getPath(true).c_str() : moduleName, + arg->getPath(true).c_str(), src, arg ); } @@ -1248,6 +1364,30 @@ void FGNasalSys::registerToUnload(FGNasalModelData *data) _unloadList.push(data); } +void FGNasalSys::addCommand(naRef func, const std::string& name) +{ + if (_commands.find(name) != _commands.end()) { + SG_LOG(SG_NASAL, SG_WARN, "duplicate add of command:" << name); + return; + } + + NasalCommand* cmd = new NasalCommand(this, func, name); + _commands[name] = cmd; +} + +void FGNasalSys::removeCommand(const std::string& name) +{ + NasalCommandDict::iterator it = _commands.find(name); + if (it == _commands.end()) { + SG_LOG(SG_NASAL, SG_WARN, "remove of unknwon command:" << name); + return; + } + + // will delete the NasalCommand instance + globals->get_commands()->removeCommand(name); + _commands.erase(it); +} + ////////////////////////////////////////////////////////////////////////// // FGNasalListener class.