Coop.Modules.Mod 21 KB

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