Modules.Mod 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911
  1. MODULE Modules; (** AUTHOR "pjm"; PURPOSE "Modules and types"; *)
  2. IMPORT SYSTEM,
  3. #IF COOP THEN
  4. Environment, Activities, Processors, Queues,
  5. #END
  6. Trace, Machine, Heaps;
  7. CONST
  8. Ok* = 0;
  9. AddressSize = SIZEOF (ADDRESS); (* architecture dependent size of addresses in bytes *)
  10. MaxTags* = 16; (* in type descriptor *)
  11. (** type descriptor field offsets relative to root (middle) *)
  12. Tag0Ofs* = -AddressSize * 2; (** first tag *)
  13. Mth0Ofs* = Tag0Ofs - AddressSize*MaxTags; (** first method *)
  14. Ptr0Ofs* = AddressSize; (** first pointer offset *)
  15. MaxObjFormats = 5; (* maximum number of object file formats installed *)
  16. (** flags in TypeDesc, RoundUp(log2(MaxTags)) low bits reserved for extLevel *)
  17. ProtTypeBit* = Heaps.ProtTypeBit;
  18. None* = 0; PowerDown* = 1; Reboot* = 2;
  19. ClearCode = TRUE;
  20. DefaultContext* = "A2";
  21. NoLoader=3400;
  22. TraceBoot=FALSE;
  23. (* flags *)
  24. PreciseGC* = 0;
  25. TYPE
  26. (* definitions for object-model loader support *)
  27. Name* = ARRAY 32 OF CHAR;
  28. (* the correponding name array is protected from being GCed via module's internal pointer arrray
  29. compiler generated!
  30. *)
  31. DynamicName* = POINTER {UNSAFE,UNTRACED} TO ARRAY 256 OF CHAR;
  32. Command* = RECORD
  33. (* Fields exported for initialization by loader/linker only! Consider read-only! *)
  34. name*: Name; (* name of the procedure *)
  35. argTdAdr*, retTdAdr* : ADDRESS; (* address of type descriptors of argument and return type, 0 if no type *)
  36. entryAdr* : ADDRESS; (* entry address of procedure *)
  37. END;
  38. ExportDesc* = RECORD
  39. fp*: ADDRESS;
  40. name* {UNTRACED}: DynamicName;
  41. adr*: ADDRESS;
  42. exports*: LONGINT; (* number of exports referenced by ExportArray *)
  43. dsc* {UNTRACED}: ExportArray; (* pointer to memory containing a raw array with "exports" entries *)
  44. END;
  45. ExportArray* = POINTER {UNSAFE,UNTRACED} TO ARRAY OF ExportDesc;
  46. Bytes* = POINTER TO ARRAY OF CHAR;
  47. TerminationHandler* = PROCEDURE;
  48. (* all implicit or explicit pointers in the subsequent data structures are protected with one pointer array
  49. *)
  50. TypeDesc* = POINTER TO RECORD
  51. descSize-: SIZE;
  52. sentinel-: LONGINT; (* = MPO-4 *)
  53. tag-: ADDRESS; (* pointer to static type descriptor, only used by linker and loader *)
  54. flags-: SET;
  55. mod- {UNTRACED}: Module; (* hint only, because module may have been freed (at Heaps.ModOfs) *)
  56. name-: Name;
  57. refsOffset-: SIZE;
  58. END;
  59. ExceptionTableEntry* = RECORD
  60. pcFrom*: ADDRESS;
  61. pcTo*: ADDRESS;
  62. pcHandler*: ADDRESS;
  63. END;
  64. ExceptionTable* = POINTER TO ARRAY OF ExceptionTableEntry;
  65. ProcedureDescPointer* = POINTER TO ProcedureDesc;
  66. ProcedureDesc*= RECORD
  67. pcFrom-, pcLimit-: ADDRESS;
  68. offsets- {UNTRACED}: POINTER TO ARRAY OF ADDRESS;
  69. END;
  70. ProcedureDescs* = POINTER TO ARRAY OF ProcedureDescPointer;
  71. Module* = OBJECT (Heaps.RootObject) (* cf. Linker0 & Heaps.WriteType *)
  72. VAR
  73. next*: Module; (** once a module is published, all fields are read-only *)
  74. name*: Name;
  75. init, published: BOOLEAN;
  76. refcnt*: LONGINT; (* counts loaded modules that import this module *)
  77. sb*: ADDRESS; (* reference address between constants and local variables *)
  78. entry*: POINTER TO ARRAY OF ADDRESS;
  79. command*: POINTER TO ARRAY OF Command;
  80. ptrAdr*: POINTER TO ARRAY OF ADDRESS; (* traced explicitly in FindRoots *)
  81. typeInfo*: POINTER TO ARRAY OF TypeDesc;
  82. module*: POINTER TO ARRAY OF Module; (* imported modules: for reference counting *)
  83. procTable*: ProcedureDescs; (* information inserted by loader, sorted by pc after loading *)
  84. data*, code*, staticTypeDescs* (* ug *), refs*: Bytes;
  85. export*: ExportDesc;
  86. term*: TerminationHandler;
  87. exTable*: ExceptionTable;
  88. (* internal pointer array: to protect internal data structures from being GCed *)
  89. internal-: POINTER TO ARRAY OF ANY;
  90. crc*: LONGINT;
  91. body*: PROCEDURE;
  92. flags*: SET; (* e.g. compilation flags *)
  93. #IF ~COOP THEN
  94. PROCEDURE FindRoots*; (* override *)
  95. VAR i: LONGINT; ptr {UNTRACED}: ANY; false: BOOLEAN;
  96. VAR name: Name;
  97. BEGIN
  98. name := SELF.name;
  99. false := FALSE; IF false THEN BEGIN{EXCLUSIVE} END END; (* trick to make a module a protected record ... *)
  100. IF published THEN (* mark global pointers *)
  101. FOR i := 0 TO LEN(ptrAdr) - 1 DO
  102. SYSTEM.GET (ptrAdr[i], ptr);
  103. IF ptr # NIL THEN Heaps.Mark(ptr) END
  104. END;
  105. Heaps.AddRootObject(next);
  106. (* all other fields are being traversed by Mark of the Garbage Collector *)
  107. END;
  108. END FindRoots;
  109. #END
  110. END Module;
  111. LoaderProc* = PROCEDURE (CONST name, fileName: ARRAY OF CHAR; VAR res: WORD;
  112. VAR msg: ARRAY OF CHAR): Module; (** load an object file *)
  113. VAR
  114. extension-: ARRAY MaxObjFormats, 8 OF CHAR;
  115. loader: ARRAY MaxObjFormats OF LoaderProc;
  116. numLoaders: LONGINT;
  117. freeRoot*: Module; (** list of freed modules (temporary) *)
  118. root-: Module; (** list of modules (read-only) *)
  119. shutdown*: LONGINT; (** None, Reboot, PowerDown *)
  120. trace: BOOLEAN;
  121. register: RECORD
  122. first {UNTRACED}, last {UNTRACED}: Module;
  123. END;
  124. (* global sorted table of all procedures , basically for GC *)
  125. procedureDescriptors-: ProcedureDescs;
  126. (** Register a module loader. *)
  127. PROCEDURE Halt(CONST reason: ARRAY OF CHAR);
  128. BEGIN
  129. HALT(999);
  130. END Halt;
  131. PROCEDURE AddLoader*(CONST ext: ARRAY OF CHAR; proc: LoaderProc);
  132. BEGIN
  133. Machine.Acquire(Machine.Modules);
  134. ASSERT(numLoaders < MaxObjFormats);
  135. loader[numLoaders] := proc;
  136. COPY(ext, extension[numLoaders]);
  137. ASSERT(ext = extension[numLoaders]); (* no overflow *)
  138. INC(numLoaders);
  139. Machine.Release(Machine.Modules)
  140. END AddLoader;
  141. (** Remove a module loader. *)
  142. PROCEDURE RemoveLoader*(CONST ext: ARRAY OF CHAR; proc: LoaderProc);
  143. VAR i, j: LONGINT;
  144. BEGIN
  145. Machine.Acquire(Machine.Modules);
  146. i := 0;
  147. WHILE (i # numLoaders) & ((loader[i] # proc) OR (extension[i] # ext)) DO INC(i) END;
  148. IF i # numLoaders THEN
  149. FOR j := i TO numLoaders - 2 DO
  150. loader[j] := loader[j + 1]; extension[j] := extension[j + 1];
  151. END;
  152. loader[numLoaders - 1] := NIL; extension[numLoaders - 1] := "";
  153. DEC(numLoaders)
  154. END;
  155. Machine.Release(Machine.Modules)
  156. END RemoveLoader;
  157. (** Append string from to to, truncating on overflow. *)
  158. PROCEDURE Append*(CONST from: ARRAY OF CHAR; VAR to: ARRAY OF CHAR);
  159. VAR i, j, m: LONGINT;
  160. BEGIN
  161. j := 0; WHILE to[j] # 0X DO INC(j) END;
  162. m := LEN(to)-1;
  163. i := 0; WHILE (from[i] # 0X) & (j # m) DO to[j] := from[i]; INC(i); INC(j) END;
  164. to[j] := 0X
  165. END Append;
  166. (** Add a module to the pool of accessible modules, or return named module. *)
  167. PROCEDURE Publish*(VAR m: Module; VAR new: BOOLEAN);
  168. VAR n: Module; i: LONGINT; name: Name;
  169. BEGIN
  170. Machine.Acquire(Machine.Modules);
  171. n := root; WHILE (n # NIL) & (n.name # m.name) DO n := n.next END;
  172. IF n # NIL THEN (* module with same name exists, return it and ignore new m *)
  173. m := n; new := FALSE
  174. ELSE
  175. IF TraceBoot OR trace THEN
  176. Machine.Acquire(Machine.TraceOutput);
  177. Trace.String("publish "); Trace.String(m.name);
  178. Trace.Ln;
  179. Machine.Release(Machine.TraceOutput);
  180. END;
  181. Unregister(m);
  182. m.published := TRUE;
  183. m.next := root; root := m;
  184. m.refcnt := 0;
  185. SortExceptionTable(m.exTable);
  186. SortProcedureDescs(m.procTable);
  187. IF m.module # NIL THEN
  188. FOR i := 0 TO LEN(m.module)-1 DO INC(m.module[i].refcnt) END;
  189. END;
  190. new := TRUE;
  191. END;
  192. Machine.Release(Machine.Modules);
  193. #IF ~COOP THEN
  194. IF (Heaps.GCType = Heaps.MetaDataForStackGC) & ~(PreciseGC IN m.flags) THEN
  195. name := m.name;
  196. Halt("Module does not provide metadata required by the GC.");
  197. END;
  198. #END
  199. END Publish;
  200. PROCEDURE Initialize*(VAR module: Module);
  201. VAR new: BOOLEAN; import: LONGINT;
  202. BEGIN
  203. IF (module = NIL) THEN RETURN END;
  204. Publish (module, new);
  205. IF new THEN
  206. FOR import := 0 TO LEN (module.module) - 1 DO
  207. IF ~module.module[import].published THEN
  208. ASSERT(register.first # NIL);
  209. Initialize(module.module[import]);
  210. END
  211. END;
  212. IF (module.code # NIL) & (LEN(module.code) > 0) THEN
  213. Machine.FlushDCacheRange(ADDRESSOF(module.code[0]), LEN(module.code));
  214. END;
  215. IF module.body # NIL THEN
  216. module.body
  217. END;
  218. module.init := TRUE;
  219. END;
  220. END Initialize;
  221. VAR callagain: BOOLEAN;
  222. PROCEDURE Initialize0*(module: Module);
  223. VAR new: BOOLEAN;
  224. BEGIN
  225. (*TRACE(module.name);*)
  226. (* module MUST have been removed from register list and must not have been initialized yet *)
  227. (* ASSERT(module.next = NIL); *)
  228. Publish (module, new);
  229. callagain := FALSE;
  230. IF new THEN
  231. IF module.name = "Objects" THEN
  232. callagain := TRUE;
  233. module.init := TRUE;
  234. END;
  235. (*
  236. Trace.Memory(SYSTEM.VAL(ADDRESS, module), 256);
  237. TRACE(module, module.name, module.body);
  238. TRACE(module);
  239. TRACE(ADDRESS OF module.next);
  240. TRACE(ADDRESS OF module.name);
  241. TRACE(ADDRESS OF module.init);
  242. TRACE(ADDRESS OF module.published);
  243. TRACE(ADDRESS OF module.body);
  244. TRACE(ADDRESS OF module.refcnt);
  245. TRACE(ADDRESS OF module.sb);
  246. TRACE(ADDRESS OF module.entry);
  247. TRACE(ADDRESS OF module.command);
  248. TRACE(ADDRESS OF module.ptrAdr);
  249. TRACE(ADDRESS OF module.typeInfo);
  250. TRACE(ADDRESS OF module.module);
  251. TRACE(ADDRESS OF module.procTable);
  252. TRACE(ADDRESS OF module.ptrTable);
  253. TRACE(ADDRESS OF module.data);
  254. TRACE(ADDRESS OF module.code);
  255. TRACE(ADDRESS OF module.staticTypeDescs);
  256. TRACE(ADDRESS OF module.refs);
  257. TRACE(ADDRESS OF module.export);
  258. TRACE(ADDRESS OF module.term);
  259. TRACE(ADDRESS OF module.exTable);
  260. TRACE(ADDRESS OF module.noProcs);
  261. TRACE(ADDRESS OF module.firstProc);
  262. TRACE(ADDRESS OF module.maxPtrs);
  263. TRACE(ADDRESS OF module.crc);
  264. TRACE(ADDRESS OF module.body);
  265. *)
  266. IF module.body # NIL THEN module.body END;
  267. IF callagain THEN
  268. PublishRegisteredModules (* does not return on intel architecture. Returns on ARM but looses procedure stack frame: we are not allowed to refer to local variables after this *)
  269. ELSE
  270. module.init := TRUE;
  271. END;
  272. END;
  273. END Initialize0;
  274. (** Return the named module or NIL if it is not loaded yet. *)
  275. PROCEDURE ModuleByName*(CONST name: ARRAY OF CHAR): Module;
  276. VAR m: Module;
  277. BEGIN
  278. Machine.Acquire(Machine.Modules);
  279. m := root; WHILE (m # NIL) & (m.name # name) DO m := m.next END;
  280. Machine.Release(Machine.Modules);
  281. RETURN m
  282. END ModuleByName;
  283. PROCEDURE ByName(CONST name: ARRAY OF CHAR; VAR referenced: BOOLEAN): Module;
  284. VAR m: Module;
  285. BEGIN
  286. Machine.Acquire(Machine.Modules);
  287. referenced := FALSE;
  288. m := root; WHILE (m # NIL) & (m.name # name) DO m := m.next END;
  289. IF m = NIL THEN
  290. referenced := TRUE;
  291. m := register.first; WHILE (m#NIL) & (m.name # name) DO m := m.next END;
  292. END;
  293. Machine.Release(Machine.Modules);
  294. RETURN m
  295. END ByName;
  296. (* Generate a module file name. *)
  297. PROCEDURE GetFileName(CONST name, extension: ARRAY OF CHAR; VAR fileName: ARRAY OF CHAR);
  298. VAR i, j: LONGINT;
  299. BEGIN
  300. i := 0; WHILE name[i] # 0X DO fileName[i] := name[i]; INC(i) END;
  301. j := 0; WHILE extension[j] # 0X DO fileName[i] := extension[j]; INC(i); INC(j) END;
  302. fileName[i] := 0X
  303. END GetFileName;
  304. (* sort procedure descriptors by firstPC in ascending order *)
  305. PROCEDURE SortProcedureDescs(p: ProcedureDescs);
  306. PROCEDURE Less(i,j: LONGINT): BOOLEAN;
  307. BEGIN
  308. RETURN p[i].pcFrom < p[j].pcFrom;
  309. END Less;
  310. PROCEDURE Swap(i,j: LONGINT);
  311. VAR tmp: ProcedureDescPointer;
  312. BEGIN
  313. tmp := p[i];
  314. p[i] := p[j];
  315. p[j] := tmp;
  316. END Swap;
  317. PROCEDURE Quick( lo, hi: LONGINT);
  318. VAR i, j, m: LONGINT;
  319. BEGIN
  320. IF lo < hi THEN
  321. i := lo; j := hi; m := (lo + hi) DIV 2;
  322. REPEAT
  323. WHILE Less( i, m ) DO INC( i ) END;
  324. WHILE Less( m, j ) DO DEC( j ) END;
  325. IF i <= j THEN
  326. IF m = i THEN m := j
  327. ELSIF m = j THEN m := i
  328. END;
  329. Swap( i, j ); INC( i ); DEC( j )
  330. END
  331. UNTIL i > j;
  332. Quick( lo, j); Quick( i, hi)
  333. END;
  334. END Quick;
  335. BEGIN
  336. Quick(0, LEN(p)-1);
  337. END SortProcedureDescs;
  338. (* sort procedure descriptors by firstPC in ascending order *)
  339. PROCEDURE SortExceptionTable(p: ExceptionTable);
  340. PROCEDURE Less(i,j: LONGINT): BOOLEAN;
  341. BEGIN
  342. RETURN p[i].pcFrom < p[j].pcFrom;
  343. END Less;
  344. PROCEDURE Swap(i,j: LONGINT);
  345. VAR tmp: ExceptionTableEntry;
  346. BEGIN
  347. tmp := p[i];
  348. p[i] := p[j];
  349. p[j] := tmp;
  350. END Swap;
  351. PROCEDURE Quick( lo, hi: LONGINT);
  352. VAR i, j, m: LONGINT;
  353. BEGIN
  354. IF lo < hi THEN
  355. i := lo; j := hi; m := (lo + hi) DIV 2;
  356. REPEAT
  357. WHILE Less( i, m ) DO INC( i ) END;
  358. WHILE Less( m, j ) DO DEC( j ) END;
  359. IF i <= j THEN
  360. IF m = i THEN m := j
  361. ELSIF m = j THEN m := i
  362. END;
  363. Swap( i, j ); INC( i ); DEC( j )
  364. END
  365. UNTIL i > j;
  366. Quick( lo, j); Quick( i, hi)
  367. END;
  368. END Quick;
  369. BEGIN
  370. Quick(0, LEN(p)-1);
  371. END SortExceptionTable;
  372. (** Load the module if it is not already loaded. *) (* Algorithm J. Templ, ETHZ, 1994 *)
  373. PROCEDURE ThisModule*(CONST name: ARRAY OF CHAR; VAR res: WORD; VAR msg: ARRAY OF CHAR): Module;
  374. VAR m: Module; fileName: ARRAY 64 OF CHAR; i: LONGINT; registered: BOOLEAN;
  375. BEGIN
  376. res := Ok; msg[0] := 0X; m := ByName(name, registered);
  377. IF (m#NIL) & (registered) THEN
  378. IF trace THEN
  379. Machine.Acquire (Machine.TraceOutput);
  380. Trace.String(">R>"); Trace.StringLn (name);
  381. Machine.Release (Machine.TraceOutput);
  382. END;
  383. IF ~m.published THEN (* no race on m.published, as update is done in Publish *)
  384. Initialize(m);
  385. END;
  386. IF trace THEN
  387. Machine.Acquire (Machine.TraceOutput);
  388. Trace.String("<R<"); Trace.StringLn (name);
  389. Machine.Release (Machine.TraceOutput);
  390. END;
  391. ELSIF m = NIL THEN
  392. IF trace THEN
  393. Machine.Acquire (Machine.TraceOutput);
  394. Trace.String(">L>"); Trace.StringLn (name);
  395. Machine.Release (Machine.TraceOutput);
  396. END;
  397. IF numLoaders = 0 THEN
  398. res := NoLoader; m := NIL;
  399. ELSE
  400. i:= 0;
  401. REPEAT
  402. GetFileName(name, extension[i], fileName);
  403. m := loader[i](name, fileName, res, msg);
  404. INC(i);
  405. UNTIL (m # NIL) OR (i=numLoaders);
  406. END;
  407. IF trace THEN
  408. Machine.Acquire (Machine.TraceOutput);
  409. Trace.String("?"); Trace.StringLn (name);
  410. Machine.Release (Machine.TraceOutput);
  411. END;
  412. IF (m # NIL) & ~m.published THEN (* no race on m.published, as update is done below in Publish *)
  413. Initialize(m);
  414. END;
  415. IF trace THEN
  416. Machine.Acquire (Machine.TraceOutput);
  417. IF m = NIL THEN
  418. Trace.String("could not load "); Trace.StringLn(name)
  419. ELSIF ~m.published THEN
  420. Trace.String("not published "); Trace.StringLn(name)
  421. ELSE
  422. Trace.String("<L<"); Trace.StringLn (name);
  423. END;
  424. Machine.Release (Machine.TraceOutput);
  425. END;
  426. END;
  427. RETURN m
  428. END ThisModule;
  429. (** Return the module that contains code address pc or NIL if not found. Can also return freed modules. Non-blocking version for reflection *)
  430. PROCEDURE ThisModuleByAdr0*(pc: ADDRESS): Module;
  431. VAR m: Module; found: BOOLEAN; list: LONGINT;
  432. BEGIN
  433. list := 0; found := FALSE;
  434. REPEAT
  435. CASE list OF
  436. 0: m := root
  437. |1: m := freeRoot
  438. END;
  439. WHILE (m # NIL) & ~found DO
  440. found := FindProc(pc, m.procTable) # NIL;
  441. IF ~found THEN m := m.next END;
  442. END;
  443. INC(list)
  444. UNTIL found OR (list=2);
  445. RETURN m
  446. END ThisModuleByAdr0;
  447. (** Return the module that contains code address pc or NIL if not found. Can also return freed modules. *)
  448. PROCEDURE ThisModuleByAdr*(pc: ADDRESS): Module;
  449. VAR m: Module;
  450. BEGIN
  451. Machine.Acquire(Machine.Modules);
  452. m := ThisModuleByAdr0(pc);
  453. Machine.Release(Machine.Modules);
  454. RETURN m
  455. END ThisModuleByAdr;
  456. CONST ModuleInitTimeout = HUGEINT(3000000000); (* Timeout for waiting until a module get initialized, 3 seconds for 1 GHz CPU *)
  457. (* Retrieve a procedure given a module name, the procedure name and some type information (kernel call) *)
  458. PROCEDURE GetProcedure*(CONST moduleName, procedureName : ARRAY OF CHAR; argTdAdr, retTdAdr : ADDRESS; VAR entryAdr : ADDRESS);
  459. VAR module : Module; ignoreMsg : ARRAY 32 OF CHAR; i, res : LONGINT; t: HUGEINT;
  460. BEGIN
  461. module := ThisModule(moduleName, res, ignoreMsg);
  462. IF (res = Ok) THEN
  463. (*!
  464. module body must have been called (see note at the end of this module);
  465. return NIL if the module does not get initialized within the specified timeout
  466. *)
  467. IF ~module.init THEN
  468. t := Machine.GetTimer();
  469. WHILE ~module.init & (Machine.GetTimer() - t < ModuleInitTimeout) DO END;
  470. IF ~module.init THEN (* timeout has expired *)
  471. RETURN;
  472. END;
  473. END;
  474. Machine.Acquire(Machine.Modules);
  475. i := 0; entryAdr := Heaps.NilVal;
  476. WHILE (entryAdr = Heaps.NilVal) & (i # LEN(module.command^)) DO
  477. IF (module.command[i].name = procedureName) & (module.command[i].argTdAdr = argTdAdr) & (module.command[i].retTdAdr = retTdAdr) THEN
  478. entryAdr := module.command[i].entryAdr;
  479. END;
  480. INC(i)
  481. END;
  482. Machine.Release(Machine.Modules);
  483. END;
  484. END GetProcedure;
  485. (** Return the named type *)
  486. PROCEDURE ThisType*(m: Module; CONST name: ARRAY OF CHAR): TypeDesc;
  487. VAR i: LONGINT; type: TypeDesc;
  488. BEGIN
  489. Machine.Acquire(Machine.Modules);
  490. i := 0;
  491. WHILE (i < LEN(m.typeInfo)) & (m.typeInfo[i].name # name) DO INC(i) END;
  492. IF i = LEN(m.typeInfo) THEN
  493. type := NIL
  494. ELSE
  495. type := m.typeInfo[i]
  496. END;
  497. Machine.Release(Machine.Modules);
  498. RETURN type
  499. END ThisType;
  500. PROCEDURE ThisTypeByAdr*(adr: ADDRESS; VAR m: Module; VAR t: TypeDesc);
  501. BEGIN
  502. IF adr # 0 THEN
  503. Machine.Acquire(Machine.Modules);
  504. SYSTEM.GET (adr + Heaps.TypeDescOffset, adr);
  505. t := SYSTEM.VAL(TypeDesc, adr);
  506. m := t.mod;
  507. Machine.Release(Machine.Modules)
  508. ELSE
  509. m := NIL; t := NIL
  510. END
  511. END ThisTypeByAdr;
  512. (** create a new object given its type descriptor *)
  513. PROCEDURE NewObj*(t : TypeDesc; isRealtime: BOOLEAN) : ANY;
  514. VAR x : ANY;
  515. BEGIN
  516. Heaps.NewRec(x, SYSTEM.VAL (ADDRESS, t.tag), isRealtime);
  517. RETURN x;
  518. END NewObj;
  519. (** return the type descriptor of an object *)
  520. PROCEDURE TypeOf*(obj : ANY): TypeDesc;
  521. VAR
  522. m : Module;
  523. t : TypeDesc;
  524. adr : ADDRESS;
  525. BEGIN
  526. SYSTEM.GET(SYSTEM.VAL(ADDRESS, obj) + Heaps.TypeDescOffset, adr);
  527. ThisTypeByAdr(adr, m, t);
  528. RETURN t;
  529. END TypeOf;
  530. (** searches for the given pc in the global ProcKeyTable, if found it returns the corresponding data element *)
  531. PROCEDURE FindProc*(pc: ADDRESS; p: ProcedureDescs): ProcedureDescPointer;
  532. VAR l,r,x: LONGINT; isHit: BOOLEAN;
  533. BEGIN
  534. IF p # NIL THEN
  535. l := 0; r := LEN(p)-1;
  536. REPEAT
  537. x := (l + r) DIV 2;
  538. IF pc < p[x].pcFrom THEN r := x - 1 ELSE l := x + 1 END;
  539. isHit := ((p[x].pcFrom <= pc) & (pc < p[x].pcLimit));
  540. UNTIL isHit OR (l > r);
  541. IF isHit THEN
  542. RETURN p[x];
  543. END;
  544. END;
  545. RETURN NIL;
  546. END FindProc;
  547. (** Install procedure to execute when module is freed or shut down. The handler can distinguish the two cases by checking Modules.shutdown. If it is None, the module is being freed, otherwise the system is being shut down or rebooted. Only one handler may be installed per module. The last handler installed is active. *)
  548. PROCEDURE InstallTermHandler*(h: TerminationHandler);
  549. VAR m: Module;
  550. BEGIN
  551. m := ThisModuleByAdr(SYSTEM.VAL (ADDRESS, h));
  552. IF m # NIL THEN
  553. m.term := h (* overwrite existing handler, if any *)
  554. END
  555. END InstallTermHandler;
  556. (** Free a module. The module's termination handler, if any, is called first. Then all objects that have finalizers in this module are finalized (even if they are still reachable). Then the module's data and code are invalidated. *)
  557. PROCEDURE FreeModule*(CONST name: ARRAY OF CHAR; VAR res: WORD; VAR msg: ARRAY OF CHAR);
  558. VAR p, m: Module; term: TerminationHandler; i: LONGINT;
  559. BEGIN
  560. m := ModuleByName(name);
  561. IF (m # NIL) & (m.refcnt = 0) THEN (* will be freed below *)
  562. IF m.term # NIL THEN (* call termination handler *)
  563. term := m.term; m.term := NIL; term (* may trap *)
  564. END;
  565. IF m.code # NIL THEN
  566. Heaps.CleanupModuleFinalizers(ADDRESSOF(m.code[0]), LEN(m.code), m.name)
  567. END;
  568. END;
  569. res := Ok; msg[0] := 0X;
  570. Machine.Acquire(Machine.Modules);
  571. p := NIL; m := root;
  572. WHILE (m # NIL) & (m.name # name) DO p := m; m := m.next END;
  573. IF m # NIL THEN
  574. IF m.refcnt = 0 THEN (* free the module *)
  575. FOR i := 0 TO LEN(m.module)-1 DO DEC(m.module[i].refcnt) END;
  576. m.init := FALSE; (* disallow ThisCommand *)
  577. Append("?", m.name);
  578. (* move module to free list *)
  579. IF p = NIL THEN root := root.next ELSE p.next := m.next END;
  580. m.next := freeRoot; freeRoot := m;
  581. (* clear global pointers and code *)
  582. IF m.ptrAdr # NIL THEN
  583. FOR i := 0 TO LEN(m.ptrAdr)-1 DO SYSTEM.PUT (m.ptrAdr[i], NIL) END;
  584. END;
  585. IF ClearCode & (m.code # NIL) THEN
  586. FOR i := 0 TO LEN(m.code)-1 DO m.code[i] := 0CCX END
  587. END;
  588. (* remove references to module data *)
  589. m.published := FALSE;
  590. m.entry := NIL; m.command := NIL; m.ptrAdr := NIL;
  591. (* do not clear m.type or m.module, as old heap block tags might reference type descs indirectly. *) (* m.staticTypeDescs, m.typeInfo ??? *)
  592. (* do not clear m.data or m.code, as they are used in ThisModuleByAdr (for debugging). *)
  593. (* do not clear m.refs, as they are used in Traps (for debugging). *)
  594. m.export.dsc := NIL; m.exTable := NIL;
  595. ELSE
  596. res := 1901; (* can not free module in use *)
  597. COPY(name, msg); Append(" reference count not zero", msg)
  598. END
  599. ELSE
  600. res := 1902; (* module not found *)
  601. COPY(name, msg); Append(" not found", msg)
  602. END;
  603. Machine.Release(Machine.Modules)
  604. END FreeModule;
  605. (** Shut down all modules by calling their termination handlers and then call Machine.Shutdown. *)
  606. PROCEDURE Shutdown*(code: LONGINT);
  607. VAR m: Module; term: TerminationHandler;
  608. BEGIN
  609. IF code # None THEN
  610. LOOP
  611. Machine.Acquire(Machine.Modules);
  612. m := root; WHILE (m # NIL) & (m.term = NIL) DO m := m.next END;
  613. IF m # NIL THEN term := m.term; m.term := NIL END; (* finalizer only called once *)
  614. Machine.Release(Machine.Modules);
  615. IF m = NIL THEN EXIT END;
  616. IF TraceBoot OR trace THEN
  617. Machine.Acquire (Machine.TraceOutput);
  618. Trace.String("TermHandler "); Trace.StringLn (m.name);
  619. Machine.Release (Machine.TraceOutput);
  620. END;
  621. term (* if this causes exception or hangs, another shutdown call will retry *)
  622. END;
  623. (* clean up finalizers *)
  624. m := root;
  625. WHILE m # NIL DO
  626. IF (m.code # NIL) & (LEN(m.code)>0) THEN
  627. Heaps.CleanupModuleFinalizers(ADDRESSOF(m.code[0]), LEN(m.code), m.name)
  628. END;
  629. m := m.next
  630. END;
  631. IF TraceBoot OR trace THEN
  632. Machine.Acquire (Machine.TraceOutput);
  633. Trace.StringLn ("Modules.Shutdown finished");
  634. Machine.Release (Machine.TraceOutput);
  635. END;
  636. Machine.Shutdown(code = Reboot) (* does not return *)
  637. END
  638. END Shutdown;
  639. (* Is this PC handled in the corresponding module. deep = scan the whole stack. *)
  640. PROCEDURE IsExceptionHandled*(VAR pc, fp: ADDRESS; deep: BOOLEAN): BOOLEAN;
  641. VAR
  642. handler: ADDRESS;
  643. BEGIN
  644. IF deep THEN
  645. handler := GetExceptionHandler(pc);
  646. IF handler # -1 THEN (* Handler in the current PAF *)
  647. RETURN TRUE
  648. ELSE
  649. WHILE (fp # 0) & (handler = -1) DO
  650. SYSTEM.GET (fp + 4, pc);
  651. pc := pc - 1; (* CALL instruction, machine dependant!!! *)
  652. handler := GetExceptionHandler(pc);
  653. SYSTEM.GET (fp, fp) (* Unwind PAF *)
  654. END;
  655. IF handler = -1 THEN RETURN FALSE ELSE pc := handler; RETURN TRUE END
  656. END
  657. ELSE
  658. RETURN GetExceptionHandler(pc) # -1
  659. END
  660. END IsExceptionHandled;
  661. (* Is this PC handled in the corresponding module. If the PC is handled the PC of the
  662. handler is return else -1 is return. There is no problem concurrently accessing this
  663. procedure, there is only reading work. *)
  664. PROCEDURE GetExceptionHandler*(pc: ADDRESS): ADDRESS;
  665. VAR
  666. m: Module;
  667. PROCEDURE BinSearch(exTable: ExceptionTable; key: ADDRESS): ADDRESS;
  668. VAR
  669. x, l, r: LONGINT;
  670. BEGIN
  671. l := 0; r:=LEN(exTable) - 1;
  672. REPEAT
  673. x := (l + r) DIV 2;
  674. IF key < exTable[x].pcFrom THEN r := x - 1 ELSE l := x + 1 END;
  675. UNTIL ((key >= exTable[x].pcFrom) & (key < exTable[x].pcTo) ) OR (l > r);
  676. IF (key >= exTable[x].pcFrom) & (key < exTable[x].pcTo) THEN
  677. RETURN exTable[x].pcHandler;
  678. ELSE
  679. RETURN -1;
  680. END
  681. END BinSearch;
  682. BEGIN
  683. m := ThisModuleByAdr(pc);
  684. IF (m # NIL) & (m.exTable # NIL) & (LEN(m.exTable) > 0) THEN
  685. RETURN BinSearch(m.exTable, pc);
  686. END;
  687. RETURN -1;
  688. END GetExceptionHandler;
  689. (** fof: to make custom solutions to the race process, described below, possible. This is not a solution to the generic problem !! *)
  690. PROCEDURE Initialized*(m: Module): BOOLEAN;
  691. BEGIN
  692. RETURN m.init;
  693. END Initialized;
  694. PROCEDURE Register- (module {UNTRACED}: Module);
  695. BEGIN {UNCOOPERATIVE, UNCHECKED}
  696. (*TRACE(module.name);*)
  697. IF register.first = NIL THEN
  698. register.first := module;
  699. ELSE
  700. register.last.next := module; (* transitively unsafe access via register.last *)
  701. END;
  702. register.last := module;
  703. END Register;
  704. PROCEDURE Unregister(m: Module);
  705. VAR prev: Module;
  706. BEGIN
  707. ASSERT(m#NIL);
  708. IF register.first = NIL THEN RETURN
  709. ELSIF m = register.first THEN
  710. register.first := m.next;
  711. IF register.first = NIL THEN register.last := NIL END;
  712. ELSE
  713. prev := register.first;
  714. WHILE (prev.next # NIL) & (prev.next # m) DO
  715. prev := prev.next;
  716. END;
  717. IF prev.next = m THEN
  718. prev.next := prev.next.next;
  719. IF prev.next = NIL THEN register.last := prev END;
  720. END;
  721. END;
  722. m.next := NIL;
  723. END Unregister;
  724. PROCEDURE PublishRegisteredModules;
  725. VAR m {UNTRACED}, prev {UNTRACED}, cur {UNTRACED}: Module; import: SIZE;
  726. BEGIN
  727. #IF COOP THEN
  728. Activities.Call (Activities.Idle);
  729. #END
  730. WHILE register.first # NIL DO
  731. m := register.first;
  732. (*
  733. register.first := m.next;
  734. m.next := NIL;
  735. *)
  736. IF m.module # NIL THEN
  737. FOR import := 0 TO LEN (m.module) - 1 DO
  738. IF ~m.module[import].published THEN
  739. ASSERT(register.first # NIL);
  740. (*prev := NIL;
  741. cur := register.first;
  742. WHILE (cur # NIL) & (cur # m.module[import]) DO
  743. prev := cur;
  744. cur := cur.next
  745. END;
  746. (*ASSERT(cur = m.module[import]);*)
  747. ASSERT(cur = m.module[import]);
  748. IF prev = NIL THEN
  749. register.first := cur.next
  750. ELSE
  751. prev.next := cur.next;
  752. END;
  753. cur.next := NIL;
  754. *)
  755. Initialize0 (m.module[import]);
  756. END
  757. END;
  758. END;
  759. Initialize0 (m);
  760. END;
  761. END PublishRegisteredModules;
  762. #IF COOP THEN
  763. PROCEDURE FinalizeModules;
  764. VAR module {UNTRACED}: Module;
  765. PROCEDURE Finalize EXTERN "BaseTypes.Object.Finalize" (module {UNTRACED}: Module);
  766. BEGIN {UNCOOPERATIVE, UNCHECKED}
  767. module := root;
  768. WHILE module # NIL DO
  769. Finalize (module);
  770. module := module.next;
  771. END;
  772. END FinalizeModules;
  773. PROCEDURE {FINAL} Main;
  774. PROCEDURE InitializeGC EXTERN "GarbageCollector.Initialize";
  775. PROCEDURE TerminateGC EXTERN "GarbageCollector.Terminate";
  776. BEGIN {UNCOOPERATIVE, UNCHECKED}
  777. SYSTEM.SetActivity (NIL);
  778. SYSTEM.SetFramePointer (NIL);
  779. Environment.Initialize;
  780. InitializeGC;
  781. Processors.Initialize;
  782. Activities.Execute (PublishRegisteredModules);
  783. Processors.Terminate;
  784. FinalizeModules;
  785. Activities.Terminate;
  786. Queues.Terminate;
  787. Environment.Terminate;
  788. TerminateGC;
  789. Environment.Exit (Environment.status);
  790. END Main;
  791. #ELSE
  792. (* procedure that will be called last in a linked kernel *)
  793. PROCEDURE {FINAL, NOPAF} Main-;
  794. BEGIN
  795. (*Machine.Init;*)
  796. IF TraceBoot THEN
  797. Trace.String("publish registered modules"); Trace.Ln;
  798. END;
  799. PublishRegisteredModules;
  800. (* a standard A2 kernel does not reach this point, but for standalone executables this is required *)
  801. Machine.Shutdown(FALSE);
  802. END Main;
  803. #END
  804. PROCEDURE Init;
  805. VAR
  806. s: ARRAY 4 OF CHAR;
  807. BEGIN
  808. (* root and initBlock are initialized by the linker *)
  809. shutdown := None;
  810. numLoaders := 0;
  811. freeRoot := NIL;
  812. Machine.GetConfig("TraceModules", s);
  813. trace := (s[0] = "1");
  814. END Init;
  815. BEGIN
  816. Init;
  817. END Modules.