sqobject.cpp 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113
  1. /*
  2. see copyright notice in squirrel.h
  3. */
  4. #include "sqpcheader.h"
  5. #include "sqvm.h"
  6. #include "sqstring.h"
  7. #include "sqarray.h"
  8. #include "sqtable.h"
  9. #include "squserdata.h"
  10. #include "sqfuncproto.h"
  11. #include "sqclass.h"
  12. #include "sqclosure.h"
  13. const SQChar *IdType2Name(SQObjectType type)
  14. {
  15. switch(_RAW_TYPE(type))
  16. {
  17. case _RT_NULL:return _SC("null");
  18. case _RT_INTEGER:return _SC("integer");
  19. case _RT_FLOAT:return _SC("float");
  20. case _RT_BOOL:return _SC("bool");
  21. case _RT_STRING:return _SC("string");
  22. case _RT_TABLE:return _SC("table");
  23. case _RT_ARRAY:return _SC("array");
  24. case _RT_GENERATOR:return _SC("generator");
  25. case _RT_CLOSURE:
  26. case _RT_NATIVECLOSURE:
  27. return _SC("function");
  28. case _RT_USERDATA:
  29. case _RT_USERPOINTER:
  30. return _SC("userdata");
  31. case _RT_THREAD: return _SC("thread");
  32. case _RT_FUNCPROTO: return _SC("function");
  33. case _RT_CLASS: return _SC("class");
  34. case _RT_INSTANCE: return _SC("instance");
  35. case _RT_WEAKREF: return _SC("weakref");
  36. case _RT_OUTER: return _SC("outer");
  37. default:
  38. return NULL;
  39. }
  40. }
  41. const SQChar *GetTypeName(const SQObjectPtr &obj1)
  42. {
  43. return IdType2Name(sq_type(obj1));
  44. }
  45. SQObjectPtr SQObjectPtr::operator[](SQInteger nidx) {
  46. SQObjectPtr val;
  47. if(sq_type(*this) == OT_ARRAY) _array(*this)->Get(nidx, val);
  48. return val;
  49. }
  50. SQObjectPtr SQObjectPtr::operator[](const SQChar *key) {
  51. SQObjectPtr val;
  52. switch(sq_type(*this))
  53. {
  54. case OT_TABLE: _table(*this)->Get(key, val); break;
  55. case OT_CLASS: _class(*this)->Get(key, val); break;
  56. case OT_INSTANCE: _instance(*this)->Get(key, val); break;
  57. default:
  58. break;
  59. }
  60. return val;
  61. }
  62. SQString *SQString::Create(SQSharedState *ss,const SQChar *s,SQInteger len)
  63. {
  64. SQString *str=ADD_STRING(ss,s,len);
  65. return str;
  66. }
  67. void SQString::Release()
  68. {
  69. REMOVE_STRING(_sharedstate,this);
  70. }
  71. SQInteger SQString::Next(const SQObjectPtr &refpos, SQObjectPtr &outkey, SQObjectPtr &outval)
  72. {
  73. SQInteger idx = (SQInteger)SQTranslateIndex(refpos);
  74. while(idx < _len){
  75. outkey = (SQInteger)idx;
  76. outval = (SQInteger)((SQUnsignedInteger)_val[idx]);
  77. //return idx for the next iteration
  78. return ++idx;
  79. }
  80. //nothing to iterate anymore
  81. return -1;
  82. }
  83. SQUnsignedInteger SQTranslateIndex(const SQObjectPtr &idx)
  84. {
  85. switch(sq_type(idx)){
  86. case OT_NULL:
  87. return 0;
  88. case OT_INTEGER:
  89. return (SQUnsignedInteger)_integer(idx);
  90. default: assert(0); break;
  91. }
  92. return 0;
  93. }
  94. SQWeakRef *SQRefCounted::GetWeakRef(SQObjectType type)
  95. {
  96. if(!_weakref) {
  97. sq_new(_weakref,SQWeakRef);
  98. #if defined(SQUSEDOUBLE) && !defined(_SQ64)
  99. _weakref->_obj._unVal.raw = 0; //clean the whole union on 32 bits with double
  100. #endif
  101. _weakref->_obj._type = type;
  102. _weakref->_obj._unVal.pRefCounted = this;
  103. }
  104. return _weakref;
  105. }
  106. SQRefCounted::~SQRefCounted()
  107. {
  108. if(_weakref) {
  109. _weakref->_obj._type = OT_NULL;
  110. _weakref->_obj._unVal.pRefCounted = NULL;
  111. }
  112. }
  113. void SQWeakRef::Release() {
  114. if(ISREFCOUNTED(_obj._type)) {
  115. _obj._unVal.pRefCounted->_weakref = NULL;
  116. }
  117. sq_delete(this,SQWeakRef);
  118. }
  119. bool SQDelegable::GetMetaMethod(SQVM *v,SQMetaMethod mm,SQObjectPtr &res) {
  120. if(_delegate) {
  121. return _delegate->Get((*_ss(v)->_metamethods)[mm],res);
  122. }
  123. return false;
  124. }
  125. bool SQDelegable::SetDelegate(SQTable *mt)
  126. {
  127. SQTable *temp = mt;
  128. if(temp == this) return false;
  129. while (temp) {
  130. if (temp->_delegate == this) return false; //cycle detected
  131. temp = temp->_delegate;
  132. }
  133. if (mt) __ObjAddRef(mt);
  134. __ObjRelease(_delegate);
  135. _delegate = mt;
  136. return true;
  137. }
  138. bool SQGenerator::Yield(SQVM *v,SQInteger target)
  139. {
  140. if(_state==eSuspended) { v->Raise_Error(_SC("internal vm error, yielding dead generator")); return false;}
  141. if(_state==eDead) { v->Raise_Error(_SC("internal vm error, yielding a dead generator")); return false; }
  142. SQInteger size = v->_top-v->_stackbase;
  143. _stack.resize(size);
  144. SQObject _this = v->_stack[v->_stackbase];
  145. _stack._vals[0] = ISREFCOUNTED(sq_type(_this)) ? SQObjectPtr(_refcounted(_this)->GetWeakRef(sq_type(_this))) : _this;
  146. for(SQInteger n =1; n<target; n++) {
  147. _stack._vals[n] = v->_stack[v->_stackbase+n];
  148. }
  149. for(SQInteger j =0; j < size; j++)
  150. {
  151. v->_stack[v->_stackbase+j].Null();
  152. }
  153. _ci = *v->ci;
  154. _ci._generator=NULL;
  155. for(SQInteger i=0;i<_ci._etraps;i++) {
  156. _etraps.push_back(v->_etraps.top());
  157. v->_etraps.pop_back();
  158. // store relative stack base and size in case of resume to other _top
  159. SQExceptionTrap &et = _etraps.back();
  160. et._stackbase -= v->_stackbase;
  161. et._stacksize -= v->_stackbase;
  162. }
  163. _state=eSuspended;
  164. return true;
  165. }
  166. bool SQGenerator::Resume(SQVM *v,SQObjectPtr &dest)
  167. {
  168. if(_state==eDead){ v->Raise_Error(_SC("resuming dead generator")); return false; }
  169. if(_state==eRunning){ v->Raise_Error(_SC("resuming active generator")); return false; }
  170. SQInteger size = _stack.size();
  171. SQInteger target = &dest - &(v->_stack._vals[v->_stackbase]);
  172. assert(target>=0 && target<=255);
  173. SQInteger newbase = v->_top;
  174. if(!v->EnterFrame(v->_top, v->_top + size, false))
  175. return false;
  176. v->ci->_generator = this;
  177. v->ci->_target = (SQInt32)target;
  178. v->ci->_closure = _ci._closure;
  179. v->ci->_ip = _ci._ip;
  180. v->ci->_literals = _ci._literals;
  181. v->ci->_ncalls = _ci._ncalls;
  182. v->ci->_etraps = _ci._etraps;
  183. v->ci->_root = _ci._root;
  184. for(SQInteger i=0;i<_ci._etraps;i++) {
  185. v->_etraps.push_back(_etraps.top());
  186. _etraps.pop_back();
  187. SQExceptionTrap &et = v->_etraps.back();
  188. // restore absolute stack base and size
  189. et._stackbase += newbase;
  190. et._stacksize += newbase;
  191. }
  192. SQObject _this = _stack._vals[0];
  193. v->_stack[v->_stackbase] = sq_type(_this) == OT_WEAKREF ? _weakref(_this)->_obj : _this;
  194. for(SQInteger n = 1; n<size; n++) {
  195. v->_stack[v->_stackbase+n] = _stack._vals[n];
  196. _stack._vals[n].Null();
  197. }
  198. _state=eRunning;
  199. if (v->_debughook)
  200. v->CallDebugHook(_SC('c'));
  201. return true;
  202. }
  203. void SQArrayBase::Extend(SQArrayBase *a){
  204. SQInteger xlen;
  205. if((xlen=a->Size()))
  206. for(SQInteger i=0;i<xlen;i++)
  207. {
  208. SQObject o;
  209. a->_get2(i, o);
  210. Append(o);
  211. }
  212. }
  213. //Only here to create a unique vtable
  214. void SQCollectable::Finalize(){}
  215. void SQArray::DummyPinVtable(){}
  216. void SQFloat64Array::DummyPinVtable(){}
  217. void SQFloat32Array::DummyPinVtable(){}
  218. void SQInt64Array::DummyPinVtable(){}
  219. void SQInt32Array::DummyPinVtable(){}
  220. void SQInt16Array::DummyPinVtable(){}
  221. void SQInt8Array::DummyPinVtable(){}
  222. const SQChar* SQFunctionProto::GetLocal(SQVM *vm,SQUnsignedInteger stackbase,SQUnsignedInteger nseq,SQUnsignedInteger nop)
  223. {
  224. SQUnsignedInteger nvars=_nlocalvarinfos;
  225. const SQChar *res=NULL;
  226. if(nvars>=nseq){
  227. for(SQUnsignedInteger i=0;i<nvars;i++){
  228. if(_localvarinfos[i]._start_op<=nop && _localvarinfos[i]._end_op>=nop)
  229. {
  230. if(nseq==0){
  231. vm->Push(vm->_stack[stackbase+_localvarinfos[i]._pos]);
  232. res=_stringval(_localvarinfos[i]._name);
  233. break;
  234. }
  235. nseq--;
  236. }
  237. }
  238. }
  239. return res;
  240. }
  241. SQInteger SQFunctionProto::GetLine(SQInstruction *curr)
  242. {
  243. SQInteger op = (SQInteger)(curr-_instructions);
  244. SQInteger line=_lineinfos[0]._line;
  245. SQInteger low = 0;
  246. SQInteger high = _nlineinfos - 1;
  247. SQInteger mid = 0;
  248. while(low <= high)
  249. {
  250. mid = low + ((high - low) >> 1);
  251. SQInteger curop = _lineinfos[mid]._op;
  252. if(curop > op)
  253. {
  254. high = mid - 1;
  255. }
  256. else if(curop < op) {
  257. if(mid < (_nlineinfos - 1)
  258. && _lineinfos[mid + 1]._op >= op) {
  259. break;
  260. }
  261. low = mid + 1;
  262. }
  263. else { //equal
  264. break;
  265. }
  266. }
  267. while(mid > 0 && _lineinfos[mid]._op >= op) mid--; //I've changed this one
  268. line = _lineinfos[mid]._line;
  269. return line;
  270. }
  271. SQClosure::~SQClosure()
  272. {
  273. __ObjRelease(_root);
  274. __ObjRelease(_env);
  275. __ObjRelease(_base);
  276. REMOVE_FROM_CHAIN(&_ss(this)->_gc_chain,this);
  277. }
  278. #define _CHECK_IO(exp) { if(!exp)return false; }
  279. static bool SafeWrite(HSQUIRRELVM v,SQWRITEFUNC write,SQUserPointer up,SQUserPointer dest,SQInteger size)
  280. {
  281. if(write(up,dest,size) != size) {
  282. v->Raise_Error(_SC("io error (write function failure)"));
  283. return false;
  284. }
  285. return true;
  286. }
  287. static bool SafeWriteFmt(HSQUIRRELVM v,SQWRITEFUNC write,SQUserPointer up, const SQChar *fmt, ...)
  288. {
  289. if(fmt){
  290. SQChar str[8192];
  291. va_list vl;
  292. va_start(vl, fmt);
  293. SQInteger len = scvsprintf(str, sizeof(str), fmt, vl);
  294. va_end(vl);
  295. return SafeWrite(v, write, up, str, len);
  296. }
  297. return false;
  298. }
  299. static bool SafeRead(HSQUIRRELVM v,SQWRITEFUNC read,SQUserPointer up,SQUserPointer dest,SQInteger size)
  300. {
  301. if(size && read(up,dest,size) != size) {
  302. v->Raise_Error(_SC("io error, read function failure, the origin stream could be corrupted/trucated"));
  303. return false;
  304. }
  305. return true;
  306. }
  307. static bool WriteTag(HSQUIRRELVM v,SQWRITEFUNC write,SQUserPointer up,SQUnsignedInteger32 tag)
  308. {
  309. return SafeWrite(v,write,up,&tag,sizeof(tag));
  310. }
  311. static bool CheckTag(HSQUIRRELVM v,SQWRITEFUNC read,SQUserPointer up,SQUnsignedInteger32 tag)
  312. {
  313. SQUnsignedInteger32 t;
  314. _CHECK_IO(SafeRead(v,read,up,&t,sizeof(t)));
  315. if(t != tag){
  316. v->Raise_Error(_SC("invalid or corrupted closure stream"));
  317. return false;
  318. }
  319. return true;
  320. }
  321. static bool WriteObjectAsCode(HSQUIRRELVM v,SQUserPointer up,SQWRITEFUNC write,SQObjectPtr &o, bool withQuotes=true)
  322. {
  323. SQChar buf[32];
  324. SQInteger sz;
  325. switch(sq_type(o)){
  326. case OT_STRING:{
  327. SQInteger str_size = _string(o)->_len;
  328. if(str_size){
  329. const SQChar *str = _stringval(o);
  330. bool needQuote = false;
  331. for(int i=0; i < str_size; ++i){
  332. if(str[i] == '"' || str[i] == '\n'){
  333. needQuote = true;
  334. break;
  335. }
  336. }
  337. if(!needQuote) withQuotes = true;
  338. const SQChar *d1 = withQuotes ? _SC("\"") : _SC("[==[");
  339. const SQChar *d2 = withQuotes ? _SC("\"") : _SC("]==]");
  340. _CHECK_IO(SafeWrite(v,write,up, (void*)d1, scstrlen(d1)));
  341. _CHECK_IO(SafeWrite(v,write,up, (void*)str,rsl(_string(o)->_len)));
  342. _CHECK_IO(SafeWrite(v,write,up, (void*)d2, scstrlen(d2)));
  343. }
  344. else
  345. {
  346. const SQChar *str = _SC("null");
  347. _CHECK_IO(SafeWrite(v,write,up, (void*)str, scstrlen(str)));
  348. }
  349. }
  350. break;
  351. case OT_INTEGER:
  352. sz = scsprintf(buf, sizeof(buf), _PRINT_INT_FMT, _integer(o));
  353. _CHECK_IO(SafeWrite(v,write,up,buf,sz));break;
  354. case OT_FLOAT:
  355. sz = scsprintf(buf, sizeof(buf), "%f", _float(o));
  356. _CHECK_IO(SafeWrite(v,write,up,buf,sz));break;
  357. case OT_NULL:{
  358. const SQChar str[] = _SC("null");
  359. _CHECK_IO(SafeWrite(v,write,up, (void*)str, scstrlen(str)));
  360. }
  361. break;
  362. default:
  363. v->Raise_Error(_SC("cannot serialize a %s"),GetTypeName(o));
  364. return false;
  365. }
  366. return true;
  367. }
  368. static bool WriteObject(HSQUIRRELVM v,SQUserPointer up,SQWRITEFUNC write,SQObjectPtr &o)
  369. {
  370. SQUnsignedInteger32 _type = (SQUnsignedInteger32)sq_type(o);
  371. _CHECK_IO(SafeWrite(v,write,up,&_type,sizeof(_type)));
  372. switch(sq_type(o)){
  373. case OT_STRING:
  374. _CHECK_IO(SafeWrite(v,write,up,&_string(o)->_len,sizeof(SQInteger)));
  375. _CHECK_IO(SafeWrite(v,write,up,_stringval(o),rsl(_string(o)->_len)));
  376. break;
  377. case OT_BOOL:
  378. case OT_INTEGER:
  379. _CHECK_IO(SafeWrite(v,write,up,&_integer(o),sizeof(SQInteger)));break;
  380. case OT_FLOAT:
  381. _CHECK_IO(SafeWrite(v,write,up,&_float(o),sizeof(SQFloat)));break;
  382. case OT_NULL:
  383. break;
  384. default:
  385. v->Raise_Error(_SC("cannot serialize a %s"),GetTypeName(o));
  386. return false;
  387. }
  388. return true;
  389. }
  390. static bool ReadObject(HSQUIRRELVM v,SQUserPointer up,SQREADFUNC read,SQObjectPtr &o)
  391. {
  392. SQUnsignedInteger32 _type;
  393. _CHECK_IO(SafeRead(v,read,up,&_type,sizeof(_type)));
  394. SQObjectType t = (SQObjectType)_type;
  395. switch(t){
  396. case OT_STRING:{
  397. SQInteger len;
  398. _CHECK_IO(SafeRead(v,read,up,&len,sizeof(SQInteger)));
  399. _CHECK_IO(SafeRead(v,read,up,_ss(v)->GetScratchPad(sq_rsl(len)),sq_rsl(len)));
  400. o=SQString::Create(_ss(v),_ss(v)->GetScratchPad(-1),len);
  401. }
  402. break;
  403. case OT_INTEGER:{
  404. SQInteger i;
  405. _CHECK_IO(SafeRead(v,read,up,&i,sizeof(SQInteger))); o = i; break;
  406. }
  407. case OT_BOOL:{
  408. SQInteger i;
  409. _CHECK_IO(SafeRead(v,read,up,&i,sizeof(SQInteger))); o._type = OT_BOOL; o._unVal.nInteger = i; break;
  410. }
  411. case OT_FLOAT:{
  412. SQFloat f;
  413. _CHECK_IO(SafeRead(v,read,up,&f,sizeof(SQFloat))); o = f; break;
  414. }
  415. case OT_NULL:
  416. o.Null();
  417. break;
  418. default:
  419. v->Raise_Error(_SC("cannot serialize a %s"),IdType2Name(t));
  420. return false;
  421. }
  422. return true;
  423. }
  424. bool SQClosure::Save(SQVM *v,SQUserPointer up,SQWRITEFUNC write)
  425. {
  426. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_HEAD));
  427. _CHECK_IO(WriteTag(v,write,up,sizeof(SQChar)));
  428. _CHECK_IO(WriteTag(v,write,up,sizeof(SQInteger)));
  429. _CHECK_IO(WriteTag(v,write,up,sizeof(SQFloat)));
  430. _CHECK_IO(_function->Save(v,up,write));
  431. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_TAIL));
  432. return true;
  433. }
  434. bool SQClosure::SaveAsSource(SQVM *v,SQUserPointer up,SQWRITEFUNC write)
  435. {
  436. _CHECK_IO(_function->SaveAsSource(v,up,write));
  437. return true;
  438. }
  439. bool SQClosure::Load(SQVM *v,SQUserPointer up,SQREADFUNC read,SQObjectPtr &ret)
  440. {
  441. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_HEAD));
  442. _CHECK_IO(CheckTag(v,read,up,sizeof(SQChar)));
  443. _CHECK_IO(CheckTag(v,read,up,sizeof(SQInteger)));
  444. _CHECK_IO(CheckTag(v,read,up,sizeof(SQFloat)));
  445. SQObjectPtr func;
  446. _CHECK_IO(SQFunctionProto::Load(v,up,read,func));
  447. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_TAIL));
  448. ret = SQClosure::Create(_ss(v),_funcproto(func),_table(v->_roottable)->GetWeakRef(OT_TABLE));
  449. //FIXME: load an root for this closure
  450. return true;
  451. }
  452. SQFunctionProto::SQFunctionProto(SQSharedState *ss)
  453. {
  454. _stacksize=0;
  455. _bgenerator=false;
  456. INIT_CHAIN();ADD_TO_CHAIN(&_ss(this)->_gc_chain,this);
  457. }
  458. SQFunctionProto::~SQFunctionProto()
  459. {
  460. REMOVE_FROM_CHAIN(&_ss(this)->_gc_chain,this);
  461. }
  462. bool SQFunctionProto::Save(SQVM *v,SQUserPointer up,SQWRITEFUNC write)
  463. {
  464. SQInteger i,nliterals = _nliterals,nparameters = _nparameters;
  465. SQInteger noutervalues = _noutervalues,nlocalvarinfos = _nlocalvarinfos;
  466. SQInteger nlineinfos=_nlineinfos,ninstructions = _ninstructions,nfunctions=_nfunctions;
  467. SQInteger ndefaultparams = _ndefaultparams;
  468. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  469. _CHECK_IO(WriteObject(v,up,write,_sourcename));
  470. _CHECK_IO(WriteObject(v,up,write,_name));
  471. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  472. _CHECK_IO(SafeWrite(v,write,up,&nliterals,sizeof(nliterals)));
  473. _CHECK_IO(SafeWrite(v,write,up,&nparameters,sizeof(nparameters)));
  474. _CHECK_IO(SafeWrite(v,write,up,&noutervalues,sizeof(noutervalues)));
  475. _CHECK_IO(SafeWrite(v,write,up,&nlocalvarinfos,sizeof(nlocalvarinfos)));
  476. _CHECK_IO(SafeWrite(v,write,up,&nlineinfos,sizeof(nlineinfos)));
  477. _CHECK_IO(SafeWrite(v,write,up,&ndefaultparams,sizeof(ndefaultparams)));
  478. _CHECK_IO(SafeWrite(v,write,up,&ninstructions,sizeof(ninstructions)));
  479. _CHECK_IO(SafeWrite(v,write,up,&nfunctions,sizeof(nfunctions)));
  480. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  481. for(i=0;i<nliterals;i++){
  482. _CHECK_IO(WriteObject(v,up,write,_literals[i]));
  483. }
  484. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  485. for(i=0;i<nparameters;i++){
  486. _CHECK_IO(WriteObject(v,up,write,_parameters[i]));
  487. }
  488. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  489. for(i=0;i<noutervalues;i++){
  490. _CHECK_IO(SafeWrite(v,write,up,&_outervalues[i]._type,sizeof(SQUnsignedInteger)));
  491. _CHECK_IO(WriteObject(v,up,write,_outervalues[i]._src));
  492. _CHECK_IO(WriteObject(v,up,write,_outervalues[i]._name));
  493. }
  494. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  495. for(i=0;i<nlocalvarinfos;i++){
  496. SQLocalVarInfo &lvi=_localvarinfos[i];
  497. _CHECK_IO(WriteObject(v,up,write,lvi._name));
  498. _CHECK_IO(SafeWrite(v,write,up,&lvi._pos,sizeof(SQUnsignedInteger)));
  499. _CHECK_IO(SafeWrite(v,write,up,&lvi._start_op,sizeof(SQUnsignedInteger)));
  500. _CHECK_IO(SafeWrite(v,write,up,&lvi._end_op,sizeof(SQUnsignedInteger)));
  501. }
  502. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  503. _CHECK_IO(SafeWrite(v,write,up,_lineinfos,sizeof(SQLineInfo)*nlineinfos));
  504. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  505. _CHECK_IO(SafeWrite(v,write,up,_defaultparams,sizeof(SQInteger)*ndefaultparams));
  506. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  507. _CHECK_IO(SafeWrite(v,write,up,_instructions,sizeof(SQInstruction)*ninstructions));
  508. _CHECK_IO(WriteTag(v,write,up,SQ_CLOSURESTREAM_PART));
  509. for(i=0;i<nfunctions;i++){
  510. _CHECK_IO(_funcproto(_functions[i])->Save(v,up,write));
  511. }
  512. _CHECK_IO(SafeWrite(v,write,up,&_stacksize,sizeof(_stacksize)));
  513. _CHECK_IO(SafeWrite(v,write,up,&_bgenerator,sizeof(_bgenerator)));
  514. _CHECK_IO(SafeWrite(v,write,up,&_varparams,sizeof(_varparams)));
  515. return true;
  516. }
  517. const SQChar *SQGetBitwiseOpName(int it){
  518. #define SCASE(x) case x: return _SC(#x); break;
  519. switch(it){
  520. SCASE(BW_AND)
  521. SCASE(BW_OR)
  522. SCASE(BW_XOR)
  523. SCASE(BW_SHIFTL)
  524. SCASE(BW_SHIFTR)
  525. SCASE(BW_USHIFTR)
  526. default: return _SC("?");
  527. }
  528. #undef SCASE
  529. }
  530. const SQChar *SQGetCmpOpName(int it){
  531. #define SCASE(x) case x: return _SC(#x); break;
  532. switch(it){
  533. SCASE(CMP_G)
  534. SCASE(CMP_GE)
  535. SCASE(CMP_L)
  536. SCASE(CMP_LE)
  537. SCASE(CMP_3W)
  538. default: return _SC("?");
  539. }
  540. #undef SCASE
  541. }
  542. const SQChar *SQGetArrayAppendTypeName(int it){
  543. #define SCASE(x) case x: return _SC(#x); break;
  544. switch(it){
  545. SCASE(AAT_STACK)
  546. SCASE(AAT_LITERAL)
  547. SCASE(AAT_INT)
  548. SCASE(AAT_FLOAT)
  549. SCASE(AAT_BOOL)
  550. default: return _SC("?");
  551. }
  552. #undef SCASE
  553. }
  554. const SQChar *SQGetNewObjTypeName(int it){
  555. #define SCASE(x) case x: return _SC(#x); break;
  556. switch(it){
  557. SCASE(NOT_TABLE)
  558. SCASE(NOT_ARRAY)
  559. SCASE(NOT_CLASS)
  560. default: return _SC("?");
  561. }
  562. #undef SCASE
  563. }
  564. const SQChar *SQGetVarTypeName(int it){
  565. #define SCASE(x) case _VAR_##x: return _SC(#x); break;
  566. switch(it){
  567. SCASE(ANY)
  568. SCASE(INTEGER)
  569. SCASE(FLOAT)
  570. SCASE(BOOL)
  571. SCASE(STRING)
  572. SCASE(TABLE)
  573. SCASE(ARRAY)
  574. SCASE(CLOSURE)
  575. default: return _SC("?");
  576. }
  577. #undef SCASE
  578. }
  579. const SQChar *SQGetArithOpName(int it){
  580. #define SCASE(x, z) case x: return _SC(#z); break;
  581. switch(it){
  582. SCASE(_OP_ADD, +)
  583. SCASE(_OP_SUB, -)
  584. SCASE(_OP_MUL, *)
  585. SCASE(_OP_DIV, /)
  586. SCASE(_OP_MOD, %)
  587. default: return _SC("?");
  588. }
  589. #undef SCASE
  590. }
  591. const SQChar *SQGetOpName(int op_code) {
  592. const SQChar *str_op;
  593. switch(op_code){
  594. #define ENUM_OP(a,b) case a: str_op = _SC(#a); break;
  595. SQ_OP_CODE_LIST()
  596. #undef ENUM_OP
  597. default:
  598. str_op = _SC("???");
  599. }
  600. return str_op;
  601. }
  602. bool SQFunctionProto::SaveAsSource(SQVM *v,SQUserPointer up,SQWRITEFUNC write)
  603. {
  604. SQInteger i,nliterals = _nliterals,nparameters = _nparameters;
  605. SQInteger noutervalues = _noutervalues,nlocalvarinfos = _nlocalvarinfos;
  606. SQInteger nlineinfos=_nlineinfos,ninstructions = _ninstructions,nfunctions=_nfunctions;
  607. SQInteger ndefaultparams = _ndefaultparams;
  608. SafeWriteFmt(v,write,up,"{\n");
  609. SafeWriteFmt(v,write,up,"\tsource_name = ");
  610. _CHECK_IO(WriteObjectAsCode(v,up,write,_sourcename));
  611. SafeWriteFmt(v,write,up,",\n\tfunction_name = ");
  612. _CHECK_IO(WriteObjectAsCode(v,up,write,_name));
  613. SafeWriteFmt(v,write,up,",\n\tfunction_return_type = ");
  614. _CHECK_IO(WriteObjectAsCode(v,up,write,_return_type));
  615. SafeWriteFmt(v,write,up,",\n");
  616. SafeWriteFmt(v,write,up,"\tliterals = [\n");
  617. for(i=0;i<nliterals;i++){
  618. SafeWriteFmt(v,write,up,"\t\t/*%d*/ ", i);
  619. _CHECK_IO(WriteObjectAsCode(v,up,write,_literals[i], false));
  620. SafeWriteFmt(v,write,up,",\n");
  621. }
  622. SafeWriteFmt(v,write,up,"\t],\n");
  623. SafeWriteFmt(v,write,up,"\tparameters = [\n");
  624. for(i=0;i<nparameters;i++){
  625. SafeWriteFmt(v,write,up,"\t\t/*%d*/ ", i);
  626. _CHECK_IO(WriteObjectAsCode(v,up,write,_parameters[i]));
  627. SafeWriteFmt(v,write,up,",\n");
  628. }
  629. SafeWriteFmt(v,write,up,"\t],\n");
  630. SafeWriteFmt(v,write,up,"\toutervalues = [\n\t\t//[type, src, name],\n");
  631. for(i=0;i<noutervalues;i++){
  632. SafeWriteFmt(v,write,up,"\t\t/*%d*/ [%d, ", i, _outervalues[i]._type);
  633. _CHECK_IO(WriteObjectAsCode(v,up,write,_outervalues[i]._src));
  634. SafeWriteFmt(v,write,up,", ");
  635. _CHECK_IO(WriteObjectAsCode(v,up,write,_outervalues[i]._name));
  636. SafeWriteFmt(v,write,up,"],\n");
  637. }
  638. SafeWriteFmt(v,write,up,"\t],\n");
  639. SafeWriteFmt(v,write,up,"\tlocalvarinfos = [\n\t\t//[pos, name, start_op, end_op, scope, type],\n");
  640. for(i=0;i<nlocalvarinfos;i++){
  641. SQLocalVarInfo &lvi=_localvarinfos[i];
  642. SafeWriteFmt(v,write,up,"\t\t/*%d*/ [", i);
  643. SafeWriteFmt(v,write,up,"%d, ", lvi._pos);
  644. _CHECK_IO(WriteObjectAsCode(v,up,write,lvi._name));
  645. SafeWriteFmt(v,write,up,", %d", lvi._start_op);
  646. SafeWriteFmt(v,write,up,", %d", lvi._end_op);
  647. SafeWriteFmt(v,write,up,", %d", lvi._scope);
  648. const char* type_name = (sq_type(lvi._type_name) == OT_STRING) ? _stringval(lvi._type_name) : "";
  649. SafeWriteFmt(v,write,up,", %d], //%s : %s\n", lvi._type, SQGetVarTypeName(lvi._type), type_name);
  650. }
  651. SafeWriteFmt(v,write,up,"\t],\n");
  652. SafeWriteFmt(v,write,up,"\tlineinfos = [\n\t\t//[op, line],\n");
  653. for(i=0;i<nlineinfos;i++){
  654. SQLineInfo &li=_lineinfos[i];
  655. SafeWriteFmt(v,write,up,"\t\t/*%d*/ [%d, %d], /*%s*/\n", i, li._op, li._line, SQGetOpName(li._op));
  656. }
  657. SafeWriteFmt(v,write,up,"\t],\n");
  658. SafeWriteFmt(v,write,up,"\tdefaultparams = [");
  659. for(i=0;i<ndefaultparams;i++){
  660. SafeWriteFmt(v,write,up,"%d,", _defaultparams[i]);
  661. }
  662. SafeWriteFmt(v,write,up,"],\n");
  663. SafeWriteFmt(v,write,up,"\tinstructions = [ /*stack*/\n");
  664. SafeWriteFmt(v,write,up,"\t\t//[op_str, op, arg0, arg1, arg2, arg3],\n");
  665. const SQChar *str_op;
  666. for(i=0;i<ninstructions;i++){
  667. SQInstruction &inst = _instructions[i];
  668. str_op = SQGetOpName(inst.op);
  669. SafeWriteFmt(v,write,up,"\t\t/*%d*/ [\"%s\", %d, %d, %d, %d, %d],", i, str_op, inst.op, inst._arg0, inst._arg1, inst._arg2, inst._arg3);
  670. switch(inst.op){
  671. case _OP_LOAD:
  672. case _OP_DLOAD:
  673. case _OP_GETK:{
  674. SQInteger lidx = inst._arg1;
  675. if(lidx >= 0xFFFFFFFF) SafeWriteFmt(v,write,up,"\t\t/* stk[%d] <- null */", inst._arg0);
  676. else
  677. {
  678. SafeWriteFmt(v,write,up,"\t\t/* stk[%d] <- literals[%d] */", inst._arg0, lidx);
  679. //_CHECK_IO(WriteObjectAsCode(v,up,write,_literals[lidx], false));
  680. //SafeWriteFmt(v,write,up," */");
  681. }
  682. if(inst.op == _OP_DLOAD) {
  683. lidx = inst._arg3;
  684. if(lidx >= 0xFFFFFFFF) SafeWriteFmt(v,write,up," /* stk[%d] <- null */", inst._arg2);
  685. else {
  686. SafeWriteFmt(v,write,up," /* stk[%d] <- literals[%d] ", inst._arg2, lidx);
  687. _CHECK_IO(WriteObjectAsCode(v,up,write,_literals[lidx], false));
  688. SafeWriteFmt(v,write,up," */");
  689. }
  690. }
  691. }
  692. break;
  693. case _OP_GET:
  694. SafeWriteFmt(v,write,up,"\t/* stk_at_arg0[%d] = stk_at_arg1[%d].get(stk_at_arg2(%d)) */",
  695. inst._arg0, inst._arg1, inst._arg2);
  696. break;
  697. case _OP_SET:
  698. SafeWriteFmt(v,write,up,"\t/* stk_at_arg1[%d].set(stk_at_arg2(%d), stk_at_arg3(%d)) */",
  699. inst._arg1, inst._arg2, inst._arg3);
  700. break;
  701. case _OP_PREPCALLK:
  702. case _OP_PREPCALL:
  703. SafeWriteFmt(v,write,up,"\t/* closure_at_stk[%d], stk[%d].get(%s[%d]) -> stk[%d] */",
  704. inst._arg0, inst._arg2, inst.op == _OP_PREPCALLK ? "literals" : "stk", inst._arg1, inst._arg3);
  705. break;
  706. case _OP_LOADFLOAT:
  707. SafeWriteFmt(v,write,up,"\t/* %f */", *((SQFloat32*)&inst._arg1));
  708. break;
  709. case _OP_GETOUTER:
  710. SafeWriteFmt(v,write,up,"\t/* stk[%d] <- outervalues[%d] == (%s) */",
  711. inst._arg0, inst._arg1, _stringval(_outervalues[inst._arg1]._name));
  712. break;
  713. case _OP_CALL:
  714. SafeWriteFmt(v,write,up,"\t\t/* target[%d], closure_at_stk[%d], stackbase(%d), nargs(%d) */",
  715. inst._arg0, inst._arg1, inst._arg2, inst._arg3);
  716. break;
  717. case _OP_MOVE:
  718. SafeWriteFmt(v,write,up,"\t\t/* stk[%d] <- stk[%d] */", inst._arg0, inst._arg1);
  719. break;
  720. case _OP_DMOVE:
  721. SafeWriteFmt(v,write,up,"\t/* stk[%d] <- stk[%d], stk[%d] <- stk[%d] */",
  722. inst._arg0, inst._arg1, inst._arg2, inst._arg3);
  723. break;
  724. case _OP_LOADINT:
  725. SafeWriteFmt(v,write,up,"\t/* stk[%d] <- arg1(%d) */", inst._arg0, inst._arg1);
  726. break;
  727. case _OP_EQ:
  728. SafeWriteFmt(v,write,up,"\t\t/* stk_at_arg0[%d] = stk_at_arg2[%d] == (arg3(%d) !=0 ? literals_at_arg1[%d] : stk_at_arg1[%d]) */",
  729. inst._arg0, inst._arg2, inst._arg3, inst._arg1, inst._arg1);
  730. break;
  731. case _OP_NOT:
  732. SafeWriteFmt(v,write,up,"\t\t/* stk_at_arg0[%d] = IsFalse(stk_at_arg1[%d]) */",
  733. inst._arg0, inst._arg1);
  734. break;
  735. case _OP_AND:
  736. case _OP_OR:
  737. SafeWriteFmt(v,write,up,"\t\t/* %s(stk_at_arg2[%d]) {stk_at_arg0[%d] = stk[%d]; goto[%d]} */",
  738. ((inst.op == _OP_OR) ? "IsTrue" : "IsFalse"),
  739. inst._arg2, inst._arg0, inst._arg2, i + inst._arg1 + 1);
  740. break;
  741. case _OP_JZ:
  742. SafeWriteFmt(v,write,up,"\t\t/* IsFalse(STK(%d) (ci->_ip+=(%d) -> goto[%d]) */",
  743. inst._arg0, inst._arg1, i + inst._arg1 + 1);
  744. break;
  745. case _OP_JCMP:
  746. SafeWriteFmt(v,write,up,"\t\t/* IsFalse(STK(%d) %s STK(%d)) (ci->_ip+=(%d) -> goto[%d]) */",
  747. inst._arg2, SQGetCmpOpName(inst._arg3), inst._arg0, inst._arg1, i + inst._arg1 + 1);
  748. break;
  749. case _OP_JMP:
  750. SafeWriteFmt(v,write,up,"\t\t/* (ci->_ip+=(%d)) -> goto[%d] */",
  751. inst._arg1, i + inst._arg1 + 1);
  752. break;
  753. case _OP_RETURN:
  754. SafeWriteFmt(v,write,up,"\t/* _arg0(%d) != 255 ? stk[%d] : null */",
  755. inst._arg0, inst._arg1);
  756. break;
  757. case _OP_NEWOBJ:
  758. SafeWriteFmt(v,write,up,"\t/* stk[%d], len(%d), %s(%d) */",
  759. inst._arg0, inst._arg1, SQGetNewObjTypeName(inst._arg3), inst._arg3);
  760. break;
  761. case _OP_APPENDARRAY:
  762. SafeWriteFmt(v,write,up,"\t/* array_at_stk(%d), %s(%d), sq_type(%d) */",
  763. inst._arg0, SQGetArrayAppendTypeName(inst._arg2), inst._arg1, inst._arg2);
  764. break;
  765. case _OP_NEWSLOT:
  766. case _OP_NEWSLOTA:
  767. SafeWriteFmt(v,write,up,"\t/* flags(%d), table_at_stk(%d), key_at_stk(%d), val_at_stk(%d) */",
  768. inst._arg0, inst._arg1, inst._arg2, inst._arg3);
  769. break;
  770. case _OP_LOADBOOL:
  771. SafeWriteFmt(v,write,up,"\t/* stk[%d] <- bool(%d) */",
  772. inst._arg0, inst._arg2);
  773. break;
  774. case _OP_LOADNULLS:
  775. SafeWriteFmt(v,write,up,"\t/* stk_at_arg0[%d .. (arg0 + arg1(%d))] = null */",
  776. inst._arg0, inst._arg1);
  777. break;
  778. case _OP_LOADROOT:
  779. SafeWriteFmt(v,write,up,"\t/* stk_at_arg0[%d] <- roottable */",
  780. inst._arg0);
  781. break;
  782. case _OP_CLOSURE:
  783. SafeWriteFmt(v,write,up,"\t/* stk_at_arg0[%d] <- functions[%d] == (",
  784. inst._arg0, inst._arg1);
  785. _CHECK_IO(WriteObjectAsCode(v,up,write,_funcproto(_functions[inst._arg1])->_name));
  786. SafeWriteFmt(v,write,up,"), isLanbda(%d) */", inst._arg2);
  787. break;
  788. case _OP_ADD:
  789. case _OP_SUB:
  790. case _OP_DIV:
  791. case _OP_MUL:
  792. case _OP_MOD:
  793. SafeWriteFmt(v,write,up,"\t\t/* stk[%d] = stk[%d] %s stk[%d] */",
  794. inst._arg0, inst._arg1, SQGetArithOpName(inst.op), inst._arg2);
  795. break;
  796. case _OP_INCL:
  797. SafeWriteFmt(v,write,up,"\t\t/* stk[%d] = stk[%d] + sarg3(%d) */",
  798. inst._arg1, inst._arg1, ((char)inst._arg3));
  799. break;
  800. case _OP_PINCL:
  801. SafeWriteFmt(v,write,up,"\t\t/* target = stk(%d); stk[%d] = stk[%d] + sarg3(%d) */",
  802. inst._arg1, inst._arg1, inst._arg1, ((char)inst._arg3));
  803. break;
  804. case _OP_BITW:
  805. SafeWriteFmt(v,write,up,"\t\t/* stk[%d] = stk[%d] %s stk[%d] */",
  806. inst._arg0, inst._arg1, SQGetBitwiseOpName(inst._arg3), inst._arg2);
  807. break;
  808. //default:
  809. }
  810. SafeWriteFmt(v,write,up,"\n");
  811. }
  812. SafeWriteFmt(v,write,up,"\t],\n");
  813. SafeWriteFmt(v,write,up,"\tfunctions = [\n");
  814. for(i=0;i<nfunctions;i++){
  815. SafeWriteFmt(v,write,up,"/*function %d*/", i);
  816. _CHECK_IO(_funcproto(_functions[i])->SaveAsSource(v,up,write));
  817. SafeWriteFmt(v,write,up,",\n");
  818. }
  819. SafeWriteFmt(v,write,up,"\t],\n");
  820. SafeWriteFmt(v,write,up,"\tstacksize = %d,\n", _stacksize);
  821. SafeWriteFmt(v,write,up,"\tbgenerator = %d,\n", _bgenerator);
  822. SafeWriteFmt(v,write,up,"\tvarparams = %d,\n", _varparams);
  823. SafeWriteFmt(v,write,up,"}");
  824. return true;
  825. }
  826. bool SQFunctionProto::Load(SQVM *v,SQUserPointer up,SQREADFUNC read,SQObjectPtr &ret)
  827. {
  828. SQInteger i, nliterals,nparameters;
  829. SQInteger noutervalues ,nlocalvarinfos ;
  830. SQInteger nlineinfos,ninstructions ,nfunctions,ndefaultparams ;
  831. SQObjectPtr sourcename, name;
  832. SQObjectPtr o;
  833. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  834. _CHECK_IO(ReadObject(v, up, read, sourcename));
  835. _CHECK_IO(ReadObject(v, up, read, name));
  836. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  837. _CHECK_IO(SafeRead(v,read,up, &nliterals, sizeof(nliterals)));
  838. _CHECK_IO(SafeRead(v,read,up, &nparameters, sizeof(nparameters)));
  839. _CHECK_IO(SafeRead(v,read,up, &noutervalues, sizeof(noutervalues)));
  840. _CHECK_IO(SafeRead(v,read,up, &nlocalvarinfos, sizeof(nlocalvarinfos)));
  841. _CHECK_IO(SafeRead(v,read,up, &nlineinfos, sizeof(nlineinfos)));
  842. _CHECK_IO(SafeRead(v,read,up, &ndefaultparams, sizeof(ndefaultparams)));
  843. _CHECK_IO(SafeRead(v,read,up, &ninstructions, sizeof(ninstructions)));
  844. _CHECK_IO(SafeRead(v,read,up, &nfunctions, sizeof(nfunctions)));
  845. SQFunctionProto *f = SQFunctionProto::Create(_opt_ss(v),ninstructions,nliterals,nparameters,
  846. nfunctions,noutervalues,nlineinfos,nlocalvarinfos,ndefaultparams);
  847. SQObjectPtr proto = f; //gets a ref in case of failure
  848. f->_sourcename = sourcename;
  849. f->_name = name;
  850. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  851. for(i = 0;i < nliterals; i++){
  852. _CHECK_IO(ReadObject(v, up, read, o));
  853. f->_literals[i] = o;
  854. }
  855. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  856. for(i = 0; i < nparameters; i++){
  857. _CHECK_IO(ReadObject(v, up, read, o));
  858. f->_parameters[i] = o;
  859. }
  860. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  861. for(i = 0; i < noutervalues; i++){
  862. SQUnsignedInteger itype;
  863. SQObjectPtr iname;
  864. _CHECK_IO(SafeRead(v,read,up, &itype, sizeof(SQUnsignedInteger)));
  865. _CHECK_IO(ReadObject(v, up, read, o));
  866. _CHECK_IO(ReadObject(v, up, read, iname));
  867. f->_outervalues[i] = SQOuterVar(iname,o, (SQOuterType)itype);
  868. }
  869. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  870. for(i = 0; i < nlocalvarinfos; i++){
  871. SQLocalVarInfo lvi;
  872. _CHECK_IO(ReadObject(v, up, read, lvi._name));
  873. _CHECK_IO(SafeRead(v,read,up, &lvi._pos, sizeof(SQUnsignedInteger)));
  874. _CHECK_IO(SafeRead(v,read,up, &lvi._start_op, sizeof(SQUnsignedInteger)));
  875. _CHECK_IO(SafeRead(v,read,up, &lvi._end_op, sizeof(SQUnsignedInteger)));
  876. f->_localvarinfos[i] = lvi;
  877. }
  878. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  879. _CHECK_IO(SafeRead(v,read,up, f->_lineinfos, sizeof(SQLineInfo)*nlineinfos));
  880. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  881. _CHECK_IO(SafeRead(v,read,up, f->_defaultparams, sizeof(SQInteger)*ndefaultparams));
  882. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  883. _CHECK_IO(SafeRead(v,read,up, f->_instructions, sizeof(SQInstruction)*ninstructions));
  884. _CHECK_IO(CheckTag(v,read,up,SQ_CLOSURESTREAM_PART));
  885. for(i = 0; i < nfunctions; i++){
  886. _CHECK_IO(_funcproto(o)->Load(v, up, read, o));
  887. f->_functions[i] = o;
  888. }
  889. _CHECK_IO(SafeRead(v,read,up, &f->_stacksize, sizeof(f->_stacksize)));
  890. _CHECK_IO(SafeRead(v,read,up, &f->_bgenerator, sizeof(f->_bgenerator)));
  891. _CHECK_IO(SafeRead(v,read,up, &f->_varparams, sizeof(f->_varparams)));
  892. ret = f;
  893. return true;
  894. }
  895. #ifndef NO_GARBAGE_COLLECTOR
  896. #define START_MARK() if(!(_uiRef&MARK_FLAG)){ \
  897. _uiRef|=MARK_FLAG;
  898. #define END_MARK() RemoveFromChain(&_sharedstate->_gc_chain, this); \
  899. AddToChain(chain, this); }
  900. void SQVM::Mark(SQCollectable **chain)
  901. {
  902. START_MARK()
  903. SQSharedState::MarkObject(_lasterror,chain);
  904. SQSharedState::MarkObject(_errorhandler,chain);
  905. SQSharedState::MarkObject(_debughook_closure,chain);
  906. SQSharedState::MarkObject(_roottable, chain);
  907. SQSharedState::MarkObject(temp_reg, chain);
  908. for(SQUnsignedInteger i = 0; i < _stack.size(); i++) SQSharedState::MarkObject(_stack[i], chain);
  909. for(SQInteger k = 0; k < _callsstacksize; k++) SQSharedState::MarkObject(_callsstack[k]._closure, chain);
  910. END_MARK()
  911. }
  912. void SQArrayBase::Mark(SQCollectable **chain)
  913. {
  914. if(isCollectable())
  915. {
  916. START_MARK()
  917. SQInteger len = Size();
  918. SQObjectPtr o;
  919. for(SQInteger i = 0;i < len; i++){
  920. _get2(i, o); //do not trigger refcount
  921. SQSharedState::MarkObject(o, chain);
  922. }
  923. o._type=OT_NULL; //hack to not trigger dereference on this temp var
  924. END_MARK()
  925. }
  926. }
  927. void SQTable::Mark(SQCollectable **chain)
  928. {
  929. START_MARK()
  930. if(_delegate) _delegate->Mark(chain);
  931. SQInteger len = _numofnodes;
  932. for(SQInteger i = 0; i < len; i++){
  933. SQSharedState::MarkObject(_nodes[i].key, chain);
  934. SQSharedState::MarkObject(_nodes[i].val, chain);
  935. }
  936. END_MARK()
  937. }
  938. void SQClass::Mark(SQCollectable **chain)
  939. {
  940. START_MARK()
  941. _members->Mark(chain);
  942. if(_base) _base->Mark(chain);
  943. SQSharedState::MarkObject(_attributes, chain);
  944. for(SQUnsignedInteger i =0; i< _defaultvalues.size(); i++) {
  945. SQSharedState::MarkObject(_defaultvalues[i].val, chain);
  946. SQSharedState::MarkObject(_defaultvalues[i].attrs, chain);
  947. }
  948. for(SQUnsignedInteger j =0; j< _methods.size(); j++) {
  949. SQSharedState::MarkObject(_methods[j].val, chain);
  950. SQSharedState::MarkObject(_methods[j].attrs, chain);
  951. }
  952. for(SQUnsignedInteger k =0; k< MT_LAST; k++) {
  953. SQSharedState::MarkObject(_metamethods[k], chain);
  954. }
  955. END_MARK()
  956. }
  957. void SQInstance::Mark(SQCollectable **chain)
  958. {
  959. START_MARK()
  960. _class->Mark(chain);
  961. SQUnsignedInteger nvalues = _class->_defaultvalues.size();
  962. for(SQUnsignedInteger i =0; i< nvalues; i++) {
  963. SQSharedState::MarkObject(_values[i], chain);
  964. }
  965. END_MARK()
  966. }
  967. void SQGenerator::Mark(SQCollectable **chain)
  968. {
  969. START_MARK()
  970. for(SQUnsignedInteger i = 0; i < _stack.size(); i++) SQSharedState::MarkObject(_stack[i], chain);
  971. SQSharedState::MarkObject(_closure, chain);
  972. END_MARK()
  973. }
  974. void SQFunctionProto::Mark(SQCollectable **chain)
  975. {
  976. START_MARK()
  977. for(SQInteger i = 0; i < _nliterals; i++) SQSharedState::MarkObject(_literals[i], chain);
  978. for(SQInteger k = 0; k < _nfunctions; k++) SQSharedState::MarkObject(_functions[k], chain);
  979. END_MARK()
  980. }
  981. void SQClosure::Mark(SQCollectable **chain)
  982. {
  983. START_MARK()
  984. if(_base) _base->Mark(chain);
  985. SQFunctionProto *fp = _function;
  986. fp->Mark(chain);
  987. for(SQInteger i = 0; i < fp->_noutervalues; i++) SQSharedState::MarkObject(_outervalues[i], chain);
  988. for(SQInteger k = 0; k < fp->_ndefaultparams; k++) SQSharedState::MarkObject(_defaultparams[k], chain);
  989. END_MARK()
  990. }
  991. void SQNativeClosure::Mark(SQCollectable **chain)
  992. {
  993. START_MARK()
  994. for(SQUnsignedInteger i = 0; i < _noutervalues; i++) SQSharedState::MarkObject(_outervalues[i], chain);
  995. END_MARK()
  996. }
  997. void SQOuter::Mark(SQCollectable **chain)
  998. {
  999. START_MARK()
  1000. /* If the valptr points to a closed value, that value is alive */
  1001. if(_valptr == &_value) {
  1002. SQSharedState::MarkObject(_value, chain);
  1003. }
  1004. END_MARK()
  1005. }
  1006. void SQUserData::Mark(SQCollectable **chain){
  1007. START_MARK()
  1008. if(_delegate) _delegate->Mark(chain);
  1009. END_MARK()
  1010. }
  1011. void SQCollectable::UnMark() { _uiRef&=~MARK_FLAG; }
  1012. #endif