Linux.Unix.Mod 39 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300
  1. MODULE Unix; (* Josef Templ, 5.3.90 SVR4 system calls *) (** Linux x86 version, non portable *)
  2. (* Linux PPC version g.f. 18.04.98 *)
  3. (* Linux x86 version g.f 10.11.99 *)
  4. (* 2000.09.19 g.f. 'Sigaltstack' added *)
  5. (* 2002.06.27 g.f. TmDesc fixed, new: Utime, Mktime *)
  6. (* 2006.07.31 g.f. shared memory support added *)
  7. (* 2007.04.13 g.f. Thread priorities added *)
  8. IMPORT S := SYSTEM, Glue, Trace;
  9. CONST
  10. Version* = "Linux";
  11. libcname* = "libc.so.6";
  12. libX11name* = "libX11.so.6";
  13. libpthreadname = "libpthread.so.0";
  14. LittleEndian* = TRUE; (** byte order of basic types *)
  15. LsbIs0* = TRUE; (** bit order of SET type *)
  16. PageSize* = 4096; (* least MMU page size *)
  17. stdin* = 0; stdout* = 1; stderr* = 2;
  18. (** Unix error codes: *)
  19. EPERM* = 1; (* Not super-user *)
  20. ENOENT* = 2; (* No such file or directory *)
  21. ESRCH* = 3; (* No such process *)
  22. EINTR* = 4; (* interrupted system call *)
  23. EIO* = 5; (* I/O error *)
  24. ENXIO* = 6; (* No such device or address *)
  25. E2BIG* = 7; (* Arg list too long *)
  26. ENOEXEC* = 8; (* Exec format error *)
  27. EBADF* = 9; (* Bad file number *)
  28. ECHILD* = 10; (* No children *)
  29. EAGAIN* = 11; (* No more processes *)
  30. ENOMEM* = 12; (* Not enough core *)
  31. EACCES* = 13; (* Permission denied *)
  32. EFAULT* = 14; (* Bad address *)
  33. ENOTBLK* = 15; (* Block device required *)
  34. EBUSY* = 16; (* Mount device busy *)
  35. EEXIST* = 17; (* File exists *)
  36. EXDEV* = 18; (* Cross-device link *)
  37. ENODEV* = 19; (* No such device *)
  38. ENOTDIR* = 20; (* Not a directory *)
  39. EISDIR* = 21; (* Is a directory *)
  40. EINVAL* = 22; (* Invalid argument *)
  41. ENFILE* = 23; (* File table overflow *)
  42. EMFILE* = 24; (* Too many open files *)
  43. ENOTTY* = 25; (* Inappropriate ioctl for device *)
  44. ETXTBSY* = 26; (* Text file busy *)
  45. EFBIG* = 27; (* File too large *)
  46. ENOSPC* = 28; (* No space left on device *)
  47. ESPIPE* = 29; (* Illegal seek *)
  48. EROFS* = 30; (* Read only file system *)
  49. EMLINK* = 31; (* Too many links *)
  50. EPIPE* = 32; (* Broken pipe *)
  51. EDOM* = 33; (* Math arg out of domain of func *)
  52. ERANGE* = 34; (* Math result not representable *)
  53. ENOMSG* = 42; (* No message of desired type *)
  54. EIDRM* = 43; (* Identifier removed *)
  55. ECHRNG* = 44; (* Channel number out of range *)
  56. EL2NSYNC* = 45; (* Level 2 not synchronized *)
  57. EL3HLT* = 46; (* Level 3 halted *)
  58. EL3RST* = 47; (* Level 3 reset *)
  59. ELNRNG* = 48; (* Link number out of range *)
  60. EUNATCH* = 49; (* Protocol driver not attached *)
  61. ENOCSI* = 50; (* No CSI structure available *)
  62. EL2HLT* = 51; (* Level 2 halted *)
  63. EDEADLK* = 35; (* Deadlock condition. *)
  64. ENOLCK* = 37; (* No record locks available. *)
  65. (* open flags *)
  66. rdonly* = SET32({}); rdwr* = SET32({1}); creat* = SET32({6}); trunc* = SET32({9});
  67. (* access modes *)
  68. rwrwr* = 1B4H; rwxrwxrwx* = 1FFH;
  69. F_OK* = {}; X_Ok* = {0}; W_OK* = {1}; R_OK* = {2};
  70. SCHED_OTHER = 0;
  71. T_SIGRESUME = SIGUSR1;
  72. T_SIGSUSPEND = SIGUSR2;
  73. SIGHUP* = 1;
  74. SIGINT* = 2;
  75. SIGQUIT* =3;
  76. SIGILL* = 4;
  77. SIGTRAP* = 5;
  78. SIGABRT* = 6;
  79. SIGIOT* = 6;
  80. SIGBUS* = 7;
  81. SIGFPE* = 8;
  82. SIGKILL* = 9;
  83. SIGUSR1* = 10;
  84. SIGSEGV* = 11;
  85. SIGUSR2* = 12;
  86. SIGPIPE* = 13;
  87. SIGALRM* = 14;
  88. SIGTERM* = 15;
  89. SIGSTKFLT* = 16;
  90. SIGCHLD* = 17;
  91. SIGCONT* = 18;
  92. SIGSTOP* = 19;
  93. SIGTSTP* = 20;
  94. SIGTTIN* = 21;
  95. SIGTTOU* = 22;
  96. SIGURG* = 23;
  97. SIGXCPU* = 24;
  98. SIGXFSZ* = 25;
  99. SIGVTALRM* = 26;
  100. SIGPROF* = 27;
  101. SIGWINCH* =28;
  102. SIGIO* =29;
  103. SIGPOLL* = SIGIO;
  104. SIGPWR* = 30;
  105. SIGSYS* = 31;
  106. SIGUNUSED = 31;
  107. SIG_BLOCK = 0;
  108. SIG_UNBLOCK=1;
  109. SIG_SETMASK=2;
  110. SA_NOCLDSTOP = 0x00000001;
  111. SA_SIGINFO = 0x00000004;
  112. SA_ONSTACK = 0x08000000;
  113. SA_RESTART = 0x10000000;
  114. SA_NODEFER = 0x40000000;
  115. SA_RESETHAND = 0x80000000;
  116. CLOCK_MONOTONIC* = 1;
  117. CLOCK_MONOTONIC_RAW* = 4;
  118. CLOCK_PROCESS_CPUTIME_ID* = 2;
  119. CLOCK_REALTIME* = 0;
  120. CLOCK_THREAD_CPUTIME_ID* = 3;
  121. PTHREAD_CANCEL_ENABLE = 0;
  122. PTHREAD_CANCEL_DISABLE = 1;
  123. PTHREAD_CANCEL_ASYNCHRONOUS = 0;
  124. PTHREAD_CANCEL_DEFERRED = 1;
  125. PTHREAD_BARRIER_SERIAL_THREAD* = -1;
  126. (*--------------------------- Threads -------------------------------*)
  127. TYPE
  128. Thread_t* = ADDRESS;
  129. Mutex_t* = ADDRESS;
  130. Condition_t* = ADDRESS;
  131. MutexType = ARRAY 10 OF WORD;
  132. MutexAttributeType = ARRAY 1 OF WORD;
  133. ConditionType = ARRAY 12 OF WORD;
  134. Key_t* = ADDRESS;
  135. Sigset_t= ARRAY 32 OF WORD;
  136. SignalTrap = PROCEDURE ( sig: LONGINT; mc: Mcontext );
  137. path_t* = ARRAY OF CHAR;
  138. arg_t* = ARRAY OF CHAR;
  139. argv_t* = ARRAY OF arg_t;
  140. Sem* = RECORD reserved1-: ARRAY 4 OF ADDRESS END;
  141. Barrier* = RECORD reserved1-: ARRAY 3 OF ADDRESS; reserved2-: ARRAY 2 OF WORD END;
  142. CONST
  143. (* Thread priorities *)
  144. ThreadLow* = 1; ThreadNormal* = 20; ThreadHigh* = 99;
  145. NumPriorities* = 99; (* number of priority levels *)
  146. (*---------------------------- IP -----------------------------------*)
  147. CONST
  148. (* domain *)
  149. AFINET* = 2;
  150. AFINET6* = 26;
  151. PFINET* = AFINET;
  152. PFINET6* = AFINET6;
  153. (* types of connection*)
  154. SockStream* = 1;
  155. SockDGram* = 2;
  156. (* Protocols *)
  157. IpProtoUDP* = 17;
  158. IpProtoTCP* = 6;
  159. (* setsockopt *)
  160. SoLSocket* = 1; (* socket option level *)
  161. SoLinger* = 13; (* linger (gracefully close the connection)*)
  162. SoKeepAlive* = 9; (* keep connection alive *)
  163. SoNoDelay* = 1; (* no delay *)
  164. (* ioctl *)
  165. FioNRead* = 541BH; (* something to read ? *)
  166. (* recv *)
  167. MsgPeek* = 2;
  168. MsgDontWait* = 40H; (* non blocking read *)
  169. (* shutdown *)
  170. ShutRDWR* = 2;
  171. SockAddrSizeV4* = 16;
  172. SockAddrSizeV6* = 28;
  173. (*----------------------- seral line, cf Unix.V24.Mod -----------------------*)
  174. FIONREAD* = 541BH;
  175. TIOCMGET* = 5415H;
  176. TIOCMBIS* = 5416H;
  177. TIOCMBIC* = 5417H;
  178. TIOCMSET* = 5418H;
  179. (* speeds *)
  180. B0* = 0;
  181. B50* = 1;
  182. B75* = 2;
  183. B110* = 3;
  184. B134* = 4;
  185. B150* = 5;
  186. B200* = 6;
  187. B300* = 7;
  188. B600* = 8;
  189. B1200* = 9;
  190. B1800* = 10;
  191. B2400* = 11;
  192. B4800* = 12;
  193. B9600* = 13;
  194. B19200* = 14;
  195. B38400* = 15;
  196. B57600* = 1001H;
  197. B115200* = 1002H;
  198. B230400* = 1003H;
  199. (* tio.cflag bits *)
  200. CSIZE* = {4,5};
  201. CS5* = {};
  202. CS6* = {4};
  203. CS7* = {5};
  204. CS8* = {4,5};
  205. CSTOPB* = {6};
  206. CREAD* = {7};
  207. PARENB* = {8};
  208. PARODD* = {9};
  209. HUPCL* = {10};
  210. CLOCAL* = {11};
  211. TYPE
  212. Termios* = RECORD
  213. iflags*, oflags*, cflags*, lflags*: SET32;
  214. line*: CHAR;
  215. cc* : ARRAY 32 OF CHAR;
  216. ispeed-, ospeed-: LONGINT
  217. END;
  218. (*------------------------------------------------------------------*)
  219. TYPE
  220. dev_t* = HUGEINT;
  221. ino_t* = LONGWORD;
  222. nlink_t* = LONGWORD;
  223. mode_t* = WORD;
  224. off_t* = LONGWORD;
  225. blksize_t*= LONGWORD;
  226. blkcnt_t* = LONGWORD;
  227. uid_t* = LONGINT;
  228. gid_t* = LONGINT;
  229. pid_t* = LONGINT;
  230. Status* = RECORD
  231. #IF I386 THEN
  232. dev- : dev_t;
  233. pad1 : WORD;
  234. ino- : ino_t;
  235. mode- : mode_t;
  236. nlink- : nlink_t;
  237. uid- : LONGINT;
  238. gid- : LONGINT;
  239. rdev- : dev_t;
  240. pad2 : WORD;
  241. size- : SIZE;
  242. blksize- : blksize_t;
  243. blocks- : blkcnt_t;
  244. atime- : Timeval;
  245. mtime- : Timeval;
  246. ctime- : Timeval;
  247. #ELSIF AMD64 THEN
  248. dev- : dev_t;
  249. ino- : ino_t;
  250. nlink- : nlink_t;
  251. mode- : mode_t;
  252. uid- : WORD;
  253. gid- : WORD;
  254. pad1 : WORD;
  255. rdev- : dev_t;
  256. size- : SIZE;
  257. blksize- : blksize_t;
  258. blocks- : blkcnt_t;
  259. atime- : Timeval;
  260. mtime- : Timeval;
  261. ctime- : Timeval;
  262. #ELSE
  263. unimplemented
  264. #END
  265. reserved : ARRAY 3 OF LONGWORD;
  266. END;
  267. tvPtr* = POINTER {UNSAFE, UNTRACED} TO Timeval;
  268. Timeval* = RECORD
  269. sec* : LONGWORD;
  270. usec* : LONGWORD;
  271. END;
  272. TmPtr* = POINTER {UNSAFE, UNTRACED} TO Tm;
  273. Tm* = RECORD
  274. sec*, min*, hour*, mday*, mon*, year*, wday*, yday*, isdst*: LONGINT;
  275. gmtoff*, tmzone*: LONGINT;
  276. END;
  277. Tms* = POINTER TO RECORD
  278. utime*, stime*, cutime*, cstime*: LONGINT
  279. END;
  280. Timezone* = RECORD
  281. minuteswest*, dsttime*: LONGINT
  282. END;
  283. Itimerval* = RECORD
  284. interval*, value*: Timeval
  285. END;
  286. Timespec* = RECORD
  287. tv_sec*: LONGWORD;
  288. tv_nsec*: LONGWORD;
  289. END;
  290. CONST
  291. FdSetLen* = 32;
  292. TYPE
  293. FdSet* = ARRAY FdSetLen OF SET32;
  294. Dirent* = POINTER {UNSAFE, UNTRACED} TO RECORD
  295. ino- : ino_t;
  296. off- : off_t;
  297. reclen- : INTEGER;
  298. typ- : CHAR;
  299. name- : (*array of*) CHAR;
  300. END;
  301. Stack* = RECORD
  302. sp* : ADDRESS;
  303. flags* : SET;
  304. size* : SIZE
  305. END;
  306. Ucontext* = POINTER {UNSAFE, UNTRACED} TO UcontextDesc;
  307. UcontextDesc* = RECORD
  308. flags- : SET;
  309. link- : ADDRESS;
  310. stack- : Stack;
  311. mc- : McontextDesc
  312. END;
  313. Mcontext* = POINTER{UNSAFE, UNTRACED} TO McontextDesc;
  314. McontextDesc* = RECORD
  315. #IF I386 THEN
  316. r_gs- : ADDRESS;
  317. r_fs- : ADDRESS;
  318. r_es- : ADDRESS;
  319. r_ds- : ADDRESS;
  320. r_di- : ADDRESS;
  321. r_si- : ADDRESS;
  322. r_bp- : ADDRESS;
  323. r_sp_x : ADDRESS;
  324. r_bx- : ADDRESS;
  325. r_dx- : ADDRESS;
  326. r_cx- : ADDRESS;
  327. r_ax- : ADDRESS;
  328. trapno- : LONGINT;
  329. err- : LONGINT;
  330. r_pc- : ADDRESS;
  331. r_cs- : ADDRESS;
  332. flags- : LONGINT;
  333. r_sp- : ADDRESS; (* sp at error (signal) *)
  334. r_ss- : LONGINT;
  335. fpc- : ADDRESS; (* FP context *)
  336. oldmask : LONGINT;
  337. cr2 : LONGINT
  338. #ELSIF AMD64 THEN
  339. r_8 : HUGEINT;
  340. r_9 : HUGEINT;
  341. r_10 : HUGEINT;
  342. r_11 : HUGEINT;
  343. r_12 : HUGEINT;
  344. r_13 : HUGEINT;
  345. r_14 : HUGEINT;
  346. r_15 : HUGEINT;
  347. r_di : HUGEINT;
  348. r_si : HUGEINT;
  349. r_bp- : HUGEINT;
  350. r_bx : HUGEINT;
  351. r_dx : HUGEINT;
  352. r_ax : HUGEINT;
  353. r_cx : HUGEINT;
  354. r_sp- : HUGEINT;
  355. r_pc- : HUGEINT;
  356. r_efl : HUGEINT;
  357. r_csgsfs : HUGEINT; (* Actually short cs, gs, fs, pad0. *)
  358. err- : HUGEINT;
  359. trapno- : HUGEINT;
  360. oldmask : HUGEINT;
  361. cr2 : HUGEINT;
  362. #ELSE
  363. unimplemented
  364. #END
  365. END;
  366. PThreadAttr = RECORD
  367. reserved1-: ARRAY 5 OF ADDRESS;
  368. reserved2-: ARRAY 4 OF WORD;
  369. END;
  370. Sigaction = RECORD
  371. sa_handler: ADDRESS;
  372. (*filler1: ADDRESS;*)
  373. sa_mask: Sigset_t;
  374. sa_flags: ADDRESS;
  375. filler: ADDRESS;
  376. END;
  377. Sched_param = RECORD
  378. sched_priority: LONGINT;
  379. safety: ARRAY 8 OF ADDRESS;
  380. END;
  381. VAR
  382. suspend_mutex: MutexType;
  383. mainthread: Thread_t;
  384. suspend_done: LONGINT;
  385. resume_done: LONGINT;
  386. sasuspend, saresume: Sigaction;
  387. argc-: LONGINT; argv-: ADDRESS; environ-: ADDRESS;
  388. sysinfo-: RECORD
  389. sysname-, nodename-, release-, version-, machine-: ARRAY 65 OF CHAR;
  390. END;
  391. sigstack-: ARRAY 32*4096 OF CHAR;
  392. sysconf: PROCEDURE {C} (name: LONGINT):WORD;
  393. pthread_mutex_init: PROCEDURE {C} (mutex: ADDRESS; mutexattr: ADDRESS): WORD;
  394. pthread_mutex_destroy: PROCEDURE {C} (mutex: ADDRESS): WORD;
  395. pthread_mutex_lock: PROCEDURE {C} (mutex: ADDRESS): WORD;
  396. pthread_mutex_unlock: PROCEDURE {C} (mutex: ADDRESS): WORD;
  397. pthread_mutexattr_init: PROCEDURE {C} (mutexattr: ADDRESS): WORD;
  398. pthread_mutexattr_settype: PROCEDURE {C} (mutexattr: ADDRESS; type: WORD): WORD;
  399. pthread_cond_init: PROCEDURE {C} (cond: ADDRESS; condAttr: ADDRESS): WORD;
  400. pthread_cond_destroy: PROCEDURE {C} (cond: ADDRESS): WORD;
  401. pthread_cond_wait: PROCEDURE {C} (cond: ADDRESS; mutex: ADDRESS): WORD;
  402. pthread_cond_signal: PROCEDURE {C} (cond: ADDRESS): WORD;
  403. pthread_create-: PROCEDURE {C} (newthread: ADDRESS; attr: ADDRESS; start_routine: ADDRESS; arg: PROCEDURE): WORD;
  404. pthread_exit-: PROCEDURE {C, NORETURN} (thr: ADDRESS);
  405. pthread_detach: PROCEDURE {C} (thr: ADDRESS);
  406. pthread_kill: PROCEDURE {C} (thr: ADDRESS; sigid: LONGINT): LONGINT;
  407. pthread_cancel: PROCEDURE {C} (thr: ADDRESS);
  408. pthread_join-: PROCEDURE {C} (thread: Thread_t; return: ADDRESS): WORD;
  409. pthread_key_create : PROCEDURE {C} ( key: ADDRESS; destructor: PROCEDURE {C} ( param: ADDRESS ) ): WORD;
  410. pthread_setspecific : PROCEDURE {C} ( key: Key_t; value: ADDRESS ): WORD;
  411. pthread_getspecific : PROCEDURE {C} ( key: Key_t ): ADDRESS;
  412. pthread_attr_init: PROCEDURE {C} (attr: ADDRESS);
  413. pthread_attr_setscope: PROCEDURE {C}(attr: ADDRESS; set: WORD);
  414. pthread_attr_setdetachstate: PROCEDURE {C}(attr: ADDRESS; set: WORD);
  415. pthread_attr_setstacksize: PROCEDURE {C}(attr: ADDRESS; stackSize: SIZE);
  416. pthread_self-: PROCEDURE {C} (): Thread_t;
  417. sched_get_priority_max: PROCEDURE {C} (policy: LONGINT): LONGINT;
  418. sched_get_priority_min: PROCEDURE {C} (policy: LONGINT): LONGINT;
  419. pthread_setschedparam: PROCEDURE {C} (thread: Thread_t; policy: LONGINT; param: ADDRESS): WORD;
  420. pthread_getschedparam: PROCEDURE {C} (thread: Thread_t; policy: ADDRESS; param: ADDRESS): WORD;
  421. pthread_setcancelstate: PROCEDURE {C} (state: LONGINT; oldstate: ADDRESS): LONGINT;
  422. pthread_setcanceltype: PROCEDURE {C} (type: LONGINT; oldtype: ADDRESS): LONGINT;
  423. sigaction: PROCEDURE {C} (signum: LONGINT; CONST act, oldact: ADDRESS): LONGINT;
  424. sigemptyset: PROCEDURE {C} (set: ADDRESS);
  425. sigfillset: PROCEDURE {C} (set: ADDRESS): LONGINT;
  426. sigsuspend: PROCEDURE {C} (set: ADDRESS): LONGINT;
  427. sigaddset: PROCEDURE {C} (set: ADDRESS; signo: LONGINT);
  428. sigdelset: PROCEDURE {C} (set: ADDRESS; signo: LONGINT);
  429. nanosleep: PROCEDURE {C} (req, rem: ADDRESS): LONGINT;
  430. sigaltstack: PROCEDURE {C} (ss, oss: ADDRESS): LONGINT;
  431. pthread_sigmask: PROCEDURE {C}(how: LONGINT; set: ADDRESS; oldset: ADDRESS): LONGINT;
  432. sem_init-: PROCEDURE {C} (sem: ADDRESS; pshared: WORD; value: WORD): WORD;
  433. sem_wait-: PROCEDURE {C} (sem: ADDRESS): WORD;
  434. sem_post-: PROCEDURE {C} (sem: ADDRESS): WORD;
  435. sem_destroy-: PROCEDURE {C} (sem: ADDRESS): WORD;
  436. pthread_barrier_init-: PROCEDURE {C} (barrier: ADDRESS; attr: ADDRESS; count: WORD): WORD;
  437. pthread_barrier_wait-: PROCEDURE {C} (barrier: ADDRESS): WORD;
  438. pthread_barrier_destroy-: PROCEDURE {C} (barrier: ADDRESS): WORD;
  439. pthread_getaffinity_np-: PROCEDURE {C} (thread: Thread_t; cpusetsize: SIZE; cpuset: ADDRESS): WORD;
  440. pthread_setaffinity_np-: PROCEDURE {C} (thread: Thread_t; cpusetsize: SIZE; cpuset: ADDRESS): WORD;
  441. (*pid: return param for process id. Only set if initialized non-null. path: pointer to string denoting the executable. file_actions: modify which files are open for the new process, if NIL it inherits open files from parent process. attrp: sets process groups, scheduler, signals etc, leave NIL. argv, evp: char** to the arguments and env. variables*)
  442. posix_spawnp- : PROCEDURE {C} (pid: ADDRESS; path: ADDRESS; file_actions: ADDRESS; attrp: ADDRESS; argv: ADDRESS ; envp: ADDRESS): LONGINT;
  443. (*more restrictive than spawnp*)
  444. posix_spawn- : PROCEDURE {C} (pid: ADDRESS; path: ADDRESS; file_actions: ADDRESS; attrp: ADDRESS; argv: ADDRESS ; envp: ADDRESS): LONGINT;
  445. waitpid- : PROCEDURE {C} (pid: pid_t; status: ADDRESS; options: LONGINT): pid_t;
  446. pipe- : PROCEDURE {C} (pipefd: ADDRESS): LONGINT; (*pipefd is assumed to be a pointer to a C array of 2 elements, after pipe creation the array will contain file descriptors for the input and output end of the pipe. returns 0 on success, or -1 on fail*)
  447. dup2- : PROCEDURE {C} (oldfd,newfd: LONGINT): LONGINT; (*overwrites file descriptor newfd with a copy of oldfd. useful for redirecting pipes.*)
  448. dup- : PROCEDURE {C} (oldfd: LONGINT): LONGINT;
  449. read- : PROCEDURE {C} ( fd: LONGINT; buf: ADDRESS; n: SIZE ): SIZE;
  450. write- : PROCEDURE {C} ( fd: LONGINT; buf: ADDRESS; n: SIZE ): SIZE;
  451. open- : PROCEDURE {C} ( name: ADDRESS; flags: SET32; mode: mode_t ): LONGINT;
  452. close- : PROCEDURE {C} ( fd: LONGINT ): LONGINT;
  453. lseek- : PROCEDURE {C} ( fd: LONGINT; offset: off_t; origin: LONGINT ): off_t;
  454. fsync- : PROCEDURE {C} ( fd: LONGINT ): LONGINT;
  455. ioctl- : PROCEDURE {C} ( fd: LONGINT; request: LONGINT; arg: ADDRESS ): LONGINT;
  456. unlink- : PROCEDURE {C} ( name: ADDRESS ): LONGINT;
  457. rename- : PROCEDURE {C} ( oldname, newname: ADDRESS ): LONGINT;
  458. ftruncate- : PROCEDURE {C} ( fd: LONGINT; length: SIZE ): LONGINT;
  459. chmod- : PROCEDURE {C} ( name: ADDRESS; mode: SET ): LONGINT;
  460. utime- : PROCEDURE {C} ( name: ADDRESS; tb: ADDRESS ): LONGINT;
  461. access- : PROCEDURE {C} ( name: ADDRESS; mode: SET ): LONGINT;
  462. select- : PROCEDURE {C} ( width: LONGINT; rd, wr, ex: ADDRESS; VAR timeout: Timeval ): LONGINT;
  463. realpath- : PROCEDURE {C} ( file_name: ADDRESS; resolved_name: ADDRESS ): ADDRESS;
  464. chdir- : PROCEDURE {C} ( name: ADDRESS ): LONGINT;
  465. mkdir- : PROCEDURE {C} ( name: ADDRESS; mode: mode_t ): LONGINT;
  466. rmdir- : PROCEDURE {C} ( path: ADDRESS ): LONGINT;
  467. xstat- : PROCEDURE {C} ( ver: LONGINT; name: ADDRESS; VAR buf: Status ): LONGINT;
  468. lxstat- : PROCEDURE {C} ( ver: LONGINT; name: ADDRESS; VAR buf: Status ): LONGINT;
  469. fxstat- : PROCEDURE {C} ( ver: LONGINT; fd: LONGINT; VAR buf: Status ): LONGINT;
  470. getpid- : PROCEDURE {C} ( ): LONGINT;
  471. getuid- : PROCEDURE {C} ( ): LONGINT;
  472. posix_memalign- : PROCEDURE {C} ( VAR p: ADDRESS; alignment, size: SIZE ): LONGINT;
  473. malloc- : PROCEDURE {C} ( size: SIZE ): ADDRESS;
  474. free- : PROCEDURE {C} ( p: ADDRESS );
  475. mprotect- : PROCEDURE {C} ( p: ADDRESS; len: SIZE; prot: LONGINT ): LONGINT;
  476. alarm- : PROCEDURE {C} ( ms: LONGINT ): LONGINT;
  477. setitimer- : PROCEDURE {C} ( which: LONGINT; VAR value, ovalue: Itimerval ): LONGINT;
  478. getitimer- : PROCEDURE {C} ( which: LONGINT; VAR value: Itimerval ): LONGINT;
  479. clock_gettime- : PROCEDURE {C} (clk_id: WORD; tp: ADDRESS): WORD;
  480. clock_getres- : PROCEDURE {C} (clk_id: WORD; res: ADDRESS): WORD;
  481. gettimeofday- : PROCEDURE {C} ( VAR tv: Timeval; VAR tz: Timezone ): LONGINT;
  482. mktime- : PROCEDURE {C} ( VAR tm: Tm ): LONGINT;
  483. localtime- : PROCEDURE {C} ( CONST tv: Timeval ): TmPtr;
  484. time- : PROCEDURE {C} ( VAR tv: Timeval ): LONGINT;
  485. times- : PROCEDURE {C} ( VAR tms: Tms ): LONGINT;
  486. system- : PROCEDURE {C} ( cmd: ADDRESS );
  487. uname- : PROCEDURE {C} ( utsname: ADDRESS ): LONGINT;
  488. getcwd- : PROCEDURE {C} ( buf: ADDRESS; len: SIZE ): ADDRESS;
  489. getenv- : PROCEDURE {C} ( name: ADDRESS ): ADDRESS;
  490. opendir- : PROCEDURE {C} ( name: ADDRESS ): ADDRESS;
  491. readdir- : PROCEDURE {C} ( dir: ADDRESS ): Dirent;
  492. closedir- : PROCEDURE {C} ( dir: ADDRESS );
  493. sigsetjmp- : PROCEDURE {C} ( env: ADDRESS; savemask: LONGINT ): LONGINT;
  494. siglongjmp- : PROCEDURE {C} ( env: ADDRESS; val: LONGINT );
  495. kill- : PROCEDURE {C} ( pid, sig: LONGINT ): LONGINT;
  496. exit- : PROCEDURE {C} ( status: LONGINT );
  497. perror- : PROCEDURE {C} ( msg: ADDRESS );
  498. errno_location: PROCEDURE {C} ( ): ADDRESS;
  499. xSetErrorHandler: PROCEDURE {C} (h: ADDRESS): WORD;
  500. xSetIOErrorHandler: PROCEDURE {C} (h: ADDRESS): WORD;
  501. libc-: ADDRESS;
  502. libp-: ADDRESS;
  503. libx-: ADDRESS;
  504. libraryPaths: ARRAY 8 OF ARRAY 32 OF CHAR;
  505. noPaths: LONGINT;
  506. PROCEDURE getnprocs* (): LONGINT;
  507. BEGIN {UNCOOPERATIVE, UNCHECKED}
  508. RETURN sysconf( 0x54 ); (*0x53 for number of processors configured, 0x54 for number of processors online *)
  509. END getnprocs;
  510. PROCEDURE NewKey*( ): Key_t;
  511. VAR
  512. key: Key_t;
  513. BEGIN {UNCOOPERATIVE, UNCHECKED}
  514. ASSERT(pthread_key_create(ADDRESSOF(key), NIL) = 0);
  515. RETURN key;
  516. END NewKey;
  517. PROCEDURE ReadKey* (key: Key_t): ADDRESS;
  518. BEGIN {UNCOOPERATIVE, UNCHECKED}
  519. RETURN pthread_getspecific(key);
  520. END ReadKey;
  521. PROCEDURE WriteKey* (key: Key_t; value: ADDRESS);
  522. BEGIN {UNCOOPERATIVE, UNCHECKED}
  523. ASSERT(pthread_setspecific(key, value) = 0);
  524. END WriteKey;
  525. PROCEDURE NewMtx*( ): Mutex_t;
  526. VAR
  527. mtx: Mutex_t;
  528. BEGIN {UNCOOPERATIVE, UNCHECKED}
  529. mtx := malloc( SIZEOF(MutexType) );
  530. ASSERT(mtx # 0);
  531. ASSERT(pthread_mutex_init(mtx, NIL) = 0);
  532. RETURN mtx;
  533. END NewMtx;
  534. PROCEDURE NewRecursiveMtx*( ): Mutex_t;
  535. VAR
  536. mtx: Mutex_t;
  537. attr: MutexAttributeType;
  538. res: WORD;
  539. CONST
  540. Recursive = 1;
  541. BEGIN {UNCOOPERATIVE, UNCHECKED}
  542. mtx := malloc( SIZEOF(MutexType) );
  543. res := pthread_mutexattr_init(ADDRESS OF attr);
  544. res := pthread_mutexattr_settype(ADDRESS OF attr, Recursive);
  545. ASSERT(mtx # 0);
  546. ASSERT(pthread_mutex_init(mtx, ADDRESS OF attr) = 0);
  547. RETURN mtx;
  548. END NewRecursiveMtx;
  549. PROCEDURE MtxDestroy*(mtx: Mutex_t);
  550. BEGIN {UNCOOPERATIVE, UNCHECKED}
  551. ASSERT(pthread_mutex_destroy(mtx) = 0);
  552. END MtxDestroy;
  553. PROCEDURE MtxLock*(mtx: Mutex_t);
  554. BEGIN {UNCOOPERATIVE, UNCHECKED}
  555. ASSERT(pthread_mutex_lock(mtx) = 0);
  556. END MtxLock;
  557. PROCEDURE MtxUnlock*(mtx: Mutex_t);
  558. BEGIN {UNCOOPERATIVE, UNCHECKED}
  559. ASSERT(pthread_mutex_unlock(mtx) = 0);
  560. END MtxUnlock;
  561. PROCEDURE NewCond* ( ): Condition_t;
  562. VAR cond: Condition_t;
  563. BEGIN {UNCOOPERATIVE, UNCHECKED}
  564. cond := malloc( SIZEOF(ConditionType) );
  565. ASSERT(cond # 0);
  566. ASSERT(pthread_cond_init(cond, NIL)=0);
  567. RETURN cond;
  568. END NewCond;
  569. PROCEDURE CondDestroy*(con: Condition_t);
  570. BEGIN {UNCOOPERATIVE, UNCHECKED}
  571. ASSERT(pthread_cond_destroy(con) = 0);
  572. END CondDestroy;
  573. PROCEDURE CondWait*(con: Condition_t; mtx: Mutex_t);
  574. BEGIN {UNCOOPERATIVE, UNCHECKED}
  575. ASSERT(pthread_cond_wait(con, mtx) = 0);
  576. END CondWait;
  577. PROCEDURE CondSignal*(cond: Condition_t);
  578. BEGIN {UNCOOPERATIVE, UNCHECKED}
  579. ASSERT(pthread_cond_signal(cond) = 0);
  580. END CondSignal;
  581. PROCEDURE ThrThis*(): Thread_t;
  582. BEGIN {UNCOOPERATIVE, UNCHECKED}
  583. RETURN pthread_self( );
  584. END ThrThis;
  585. PROCEDURE ThrYield*( );
  586. BEGIN {UNCOOPERATIVE, UNCHECKED}
  587. ThrSleep(1);
  588. END ThrYield;
  589. PROCEDURE ThrExit*( );
  590. BEGIN {UNCOOPERATIVE, UNCHECKED}
  591. pthread_exit( 0 );
  592. END ThrExit;
  593. PROCEDURE ThrSetPriority*(thr: Thread_t; prio: LONGINT);
  594. VAR
  595. param: Sched_param;
  596. policy: LONGINT;
  597. BEGIN {UNCOOPERATIVE, UNCHECKED}
  598. IF pthread_getschedparam( thr, ADDRESS OF policy, ADDRESS OF param ) # 0 THEN END;
  599. param.sched_priority := prio;
  600. IF pthread_setschedparam( thr, SCHED_OTHER, ADDRESS OF param ) # 0 THEN
  601. Perror("pthread_setschedparam");
  602. END
  603. END ThrSetPriority;
  604. PROCEDURE ThrGetPriority*(thr: Thread_t):LONGINT;
  605. VAR
  606. param: Sched_param;
  607. policy: LONGINT;
  608. BEGIN {UNCOOPERATIVE, UNCHECKED}
  609. IF pthread_getschedparam( thr, ADDRESS OF policy, ADDRESS OF param ) # 0 THEN END;
  610. RETURN param.sched_priority;
  611. END ThrGetPriority;
  612. VAR
  613. sigstk: Stack;
  614. PROCEDURE SetSigaltstack;
  615. BEGIN {UNCOOPERATIVE, UNCHECKED}
  616. IF sigaltstack(ADDRESS OF sigstk, NIL) < 0 THEN
  617. Perror("sigaltstack")
  618. END;
  619. END SetSigaltstack;
  620. PROCEDURE {C} Starter(proc: PROCEDURE): ADDRESS;
  621. VAR
  622. me: Thread_t;
  623. old, new: Sigset_t;
  624. param: Sched_param;
  625. res: WORD;
  626. BEGIN {UNCOOPERATIVE, UNCHECKED}
  627. me := pthread_self();
  628. SetSigaltstack();
  629. IF sigfillset( ADDRESS OF new ) < 0 THEN
  630. Perror("sigfillset");
  631. END;
  632. sigdelset( ADDRESS OF new, SIGILL );
  633. sigdelset( ADDRESS OF new, SIGTRAP );
  634. sigdelset( ADDRESS OF new, SIGFPE );
  635. sigdelset( ADDRESS OF new, SIGBUS );
  636. sigdelset( ADDRESS OF new, SIGSEGV );
  637. sigdelset( ADDRESS OF new, SIGTERM );
  638. sigdelset( ADDRESS OF new, T_SIGSUSPEND );
  639. res := pthread_sigmask( SIG_SETMASK, ADDRESS OF new, ADDRESS OF old );
  640. res := pthread_setcancelstate( PTHREAD_CANCEL_ENABLE, NIL );
  641. res := pthread_setcanceltype( PTHREAD_CANCEL_ASYNCHRONOUS, NIL );
  642. param.sched_priority := 0;
  643. res := pthread_setschedparam( me, SCHED_OTHER, ADDRESS OF param );
  644. proc();
  645. pthread_exit( NIL );
  646. RETURN NIL;
  647. END Starter;
  648. PROCEDURE ThrStart*(p: PROCEDURE; stackSize: SIZE): Thread_t;
  649. VAR
  650. attr: PThreadAttr;
  651. id: Thread_t;
  652. res,i: LONGINT;
  653. CONST
  654. PTHREAD_SCOPE_SYSTEM = 0;
  655. PTHREAD_CREATE_DETACHED = 1;
  656. BEGIN {UNCOOPERATIVE, UNCHECKED}
  657. pthread_attr_init(ADDRESS OF attr);
  658. pthread_attr_setscope(ADDRESS OF attr, PTHREAD_SCOPE_SYSTEM);
  659. pthread_attr_setdetachstate(ADDRESS OF attr, PTHREAD_CREATE_DETACHED);
  660. (*pthread_attr_setdetachstate(ADDRESS OF attr, 0);*)
  661. pthread_attr_setstacksize(ADDRESS OF attr, stackSize);
  662. res := pthread_create(ADDRESS OF id, ADDRESS OF attr, Starter, p);
  663. RETURN id;
  664. END ThrStart;
  665. PROCEDURE ThrSleep*(ms: LONGINT);
  666. VAR
  667. sltime,rem: RECORD
  668. tv_sec: LONGWORD; (* seconds *)
  669. tv_nsec: LONGWORD; (* nanoseconds *)
  670. END;
  671. BEGIN {UNCOOPERATIVE, UNCHECKED}
  672. sltime.tv_sec := ms DIV 1000;
  673. sltime.tv_nsec := 1000000*(ms MOD 1000);
  674. WHILE (nanosleep(ADDRESS OF sltime, ADDRESS OF rem) < 0) DO
  675. (* check error ! *)
  676. sltime := rem;
  677. END;
  678. END ThrSleep;
  679. PROCEDURE ThrKill*(thr: Thread_t);
  680. BEGIN {UNCOOPERATIVE, UNCHECKED}
  681. IF (thr # mainthread) THEN
  682. pthread_detach( thr );
  683. IF (thr = pthread_self()) THEN
  684. pthread_exit( 0 );
  685. ELSE
  686. pthread_cancel( thr );
  687. END
  688. END;
  689. END ThrKill;
  690. PROCEDURE {C} resume_handler( sig: LONGINT );
  691. BEGIN {UNCOOPERATIVE, UNCHECKED}
  692. END resume_handler;
  693. PROCEDURE ThrResume*( thr: Thread_t );
  694. VAR res: WORD;
  695. BEGIN {UNCOOPERATIVE, UNCHECKED}
  696. res := pthread_mutex_lock( ADDRESS OF suspend_mutex );
  697. resume_done := 0;
  698. res := pthread_kill( thr, T_SIGRESUME );
  699. WHILE (resume_done # 1) DO ThrSleep(1); END;
  700. res := pthread_mutex_unlock( ADDRESS OF suspend_mutex );
  701. END ThrResume;
  702. VAR suspendHandler*: PROCEDURE(c: Ucontext);
  703. PROCEDURE {C} suspend_handler(sig: LONGINT; scp: ADDRESS; ucp: ADDRESS);
  704. VAR block: Sigset_t; res: WORD;
  705. BEGIN {UNCOOPERATIVE, UNCHECKED}
  706. IF suspendHandler # NIL THEN suspendHandler( S.VAL( Ucontext, ucp) ) END;
  707. res := sigfillset( ADDRESS OF block );
  708. sigdelset( ADDRESS OF block, T_SIGRESUME );
  709. suspend_done := 1; (*this is ok because ThrSuspend is protected by a mutex, so no race condidtion. It may alert the ThrSuspend too early though!*)
  710. res := sigsuspend( ADDRESS OF block ); (* await T_SIGRESUME *)
  711. resume_done := 1; (*makes no difference if we do that here or in the resume handler*)
  712. END suspend_handler;
  713. PROCEDURE ThrSuspend*(thr: Thread_t; saveContext: BOOLEAN);
  714. VAR res: WORD;
  715. BEGIN {UNCOOPERATIVE, UNCHECKED}
  716. res := pthread_mutex_lock(ADDRESS OF suspend_mutex );
  717. suspend_done := 0;
  718. res := pthread_kill( thr, T_SIGSUSPEND );
  719. WHILE (suspend_done # 1) DO ThrSleep( 1 ) END; (*this should bettr check the actual thread status!*)
  720. ThrSleep( 1 ); (*improves the probability of the suspednd actually being done*)
  721. res := pthread_mutex_unlock( ADDRESS OF suspend_mutex );
  722. END ThrSuspend;
  723. PROCEDURE ThrInitialize*( VAR low, high: LONGINT ): BOOLEAN;
  724. VAR
  725. param: Sched_param; res: WORD;
  726. BEGIN {UNCOOPERATIVE, UNCHECKED}
  727. ASSERT(pthread_mutex_init( ADDRESS OF suspend_mutex, NIL ) = 0);
  728. mainthread := pthread_self();
  729. high := sched_get_priority_max(SCHED_OTHER);
  730. low := sched_get_priority_min(SCHED_OTHER);
  731. param.sched_priority := high;
  732. IF pthread_setschedparam( mainthread, SCHED_OTHER, ADDRESS OF param)#0 THEN
  733. Perror("ThrInitialize: setparam");
  734. END;
  735. res := sigfillset( ADDRESS OF sasuspend.sa_mask );
  736. sasuspend.sa_flags := SA_SIGINFO;
  737. sasuspend.sa_handler := suspend_handler;
  738. ASSERT(sigaction( T_SIGSUSPEND, ADDRESS OF sasuspend, NIL ) = 0);
  739. sigemptyset( ADDRESS OF saresume.sa_mask );
  740. saresume.sa_flags := 0;
  741. saresume.sa_handler := resume_handler;
  742. ASSERT(sigaction( T_SIGRESUME, ADDRESS OF saresume, NIL ) = 0);
  743. RETURN TRUE;
  744. END ThrInitialize;
  745. PROCEDURE CopyContext*(CONST from: McontextDesc; VAR to: McontextDesc);
  746. BEGIN {UNCOOPERATIVE, UNCHECKED}
  747. S.MOVE(ADDRESS OF from, ADDRESS OF to, SIZE OF McontextDesc);
  748. END CopyContext;
  749. PROCEDURE ModifyContext*( cont: Mcontext; pc, bp, sp: ADDRESS );
  750. BEGIN {UNCOOPERATIVE, UNCHECKED}
  751. cont.r_pc := pc;
  752. cont.r_bp := bp;
  753. cont.r_sp := sp;
  754. END ModifyContext;
  755. PROCEDURE Perror*( CONST msg: ARRAY OF CHAR );
  756. BEGIN {UNCOOPERATIVE, UNCHECKED}
  757. perror( ADDRESSOF( msg ) )
  758. END Perror;
  759. PROCEDURE Dlsym*( lib: ADDRESS; CONST sym: ARRAY OF CHAR; objAddr: ADDRESS );
  760. VAR val: LONGINT;
  761. BEGIN {UNCOOPERATIVE, UNCHECKED}
  762. Glue.Dlsym( lib, sym, objAddr );
  763. S.GET( objAddr, val );
  764. IF val = 0 THEN
  765. Trace.String( "Unix.Dlsym: entry '" ); Trace.String( sym ); Trace.String( "' not found" );
  766. Trace.Ln;
  767. (* exit(0); *)
  768. END
  769. END Dlsym;
  770. PROCEDURE Dlopen*( CONST libname: ARRAY OF CHAR; mode: LONGINT ): ADDRESS;
  771. VAR h: ADDRESS; i, j, k: INTEGER;
  772. p: ARRAY 256 OF CHAR;
  773. BEGIN {UNCOOPERATIVE, UNCHECKED}
  774. IF libname[0] = '/' THEN h := Glue.dlopen( ADDRESSOF( libname ), mode );
  775. ELSE
  776. i := 0; h := 0;
  777. WHILE (h = 0) & (i < noPaths) DO
  778. COPY( libraryPaths[i], p ); j := 0;
  779. WHILE p[j] # 0X DO INC( j ) END;
  780. p[j] := '/'; k := 0;
  781. REPEAT INC( j ); p[j] := libname[k]; INC( k ) UNTIL p[j] = 0X;
  782. h := Glue.dlopen( ADDRESSOF( p ), mode ); INC( i );
  783. END
  784. END;
  785. IF h = 0 THEN
  786. Trace.String( "Unix.Dlopen: loading library " );
  787. Trace.String( libname ); Trace.String( " failed" ); Trace.Ln;
  788. END;
  789. RETURN h
  790. END Dlopen;
  791. PROCEDURE Dlclose*( lib: ADDRESS );
  792. BEGIN {UNCOOPERATIVE, UNCHECKED}
  793. Glue.dlclose( lib )
  794. END Dlclose;
  795. PROCEDURE GetArg*( no: LONGINT; VAR val: ARRAY OF CHAR );
  796. VAR ch: CHAR; adr: ADDRESS; i: LONGINT;
  797. BEGIN {UNCOOPERATIVE, UNCHECKED}
  798. IF no >= argc THEN val[0] := 0X
  799. ELSE
  800. S.GET( argv + SIZEOF(ADDRESS)*no, adr ); i := 0;
  801. REPEAT S.GET( adr, ch ); val[i] := ch; INC( adr ); INC( i ); UNTIL (ch = 0X) OR (i >= LEN( val ));
  802. END
  803. END GetArg;
  804. PROCEDURE GetArgval*( CONST argName: ARRAY OF CHAR; VAR val: ARRAY OF CHAR );
  805. VAR i: INTEGER;
  806. buf: ARRAY 40 OF CHAR;
  807. BEGIN {UNCOOPERATIVE, UNCHECKED}
  808. i := 1;
  809. WHILE i < argc - 1 DO
  810. GetArg( i, buf );
  811. IF buf = argName THEN GetArg( i + 1, val ); RETURN END;
  812. INC( i )
  813. END;
  814. val[0] := 0X
  815. END GetArgval;
  816. PROCEDURE getSysinfo;
  817. VAR res: WORD; p: INTEGER;
  818. buf: ARRAY 4096 OF CHAR;
  819. PROCEDURE copy( VAR p: INTEGER; VAR dest: ARRAY OF CHAR );
  820. VAR i: INTEGER;
  821. BEGIN {UNCOOPERATIVE, UNCHECKED}
  822. WHILE buf[p] <= ' ' DO INC( p ) END;
  823. i := 0;
  824. REPEAT dest[i] := buf[p]; INC( i ); INC( p ) UNTIL (buf[p - 1] = 0X) OR (i >= LEN( dest ));
  825. dest[i - 1] := 0X
  826. END copy;
  827. BEGIN {UNCOOPERATIVE, UNCHECKED}
  828. FOR p := 0 TO 4096 - 1 DO buf[p] := 0X END;
  829. res := uname( ADDRESSOF( buf ) );
  830. p := 0;
  831. copy( p, sysinfo.sysname );
  832. copy( p, sysinfo.nodename );
  833. copy( p, sysinfo.release );
  834. copy( p, sysinfo.version );
  835. copy( p, sysinfo.machine );
  836. END getSysinfo;
  837. PROCEDURE CreateSignalStack;
  838. BEGIN {UNCOOPERATIVE, UNCHECKED}
  839. sigstk.sp := ADDRESS OF sigstack;
  840. sigstk.size := LEN(sigstack);
  841. sigstk.flags := {};
  842. END CreateSignalStack;
  843. VAR trap: SignalTrap;
  844. PROCEDURE {C} SigHandler ( sig: LONGINT; scp: ADDRESS; ucp: Ucontext ); (* reversed arguments !! *)
  845. BEGIN {UNCOOPERATIVE, UNCHECKED}
  846. IF trap # NIL THEN
  847. trap( sig, S.VAL( Mcontext, ADDRESSOF( ucp.mc ) ) )
  848. ELSE
  849. Trace.String( "Unix.SigHandler: sig = " ); Trace.Int( sig, 0 ); Trace.Ln; exit( -1 );
  850. END;
  851. END SigHandler;
  852. PROCEDURE InstallTrap* ( h: SignalTrap );
  853. BEGIN {UNCOOPERATIVE, UNCHECKED}
  854. trap := h;
  855. END InstallTrap;
  856. PROCEDURE InstallHandler(sig: LONGINT);
  857. VAR
  858. act: Sigaction;
  859. mask: Sigset_t;
  860. BEGIN {UNCOOPERATIVE, UNCHECKED}
  861. sigemptyset(ADDRESS OF mask);
  862. act.sa_mask := mask;
  863. IF sig = SIGSEGV THEN (* segmentation violation *)
  864. act.sa_flags := SA_SIGINFO + SA_ONSTACK + SA_NODEFER;
  865. ELSE
  866. act.sa_flags := SA_SIGINFO + SA_NODEFER;
  867. END;
  868. act.sa_handler := ADDRESS OF SigHandler;
  869. IF sigaction( sig, ADDRESS OF act, 0 ) # 0 THEN
  870. Perror("sigaction");
  871. END
  872. END InstallHandler;
  873. PROCEDURE fstat* ( fd: LONGINT; VAR buf: Status ): LONGINT;
  874. BEGIN {UNCOOPERATIVE, UNCHECKED}
  875. #IF AMD64 THEN
  876. RETURN fxstat( 1, fd, buf );
  877. #ELSE
  878. RETURN fxstat( 3, fd, buf );
  879. #END
  880. END fstat;
  881. PROCEDURE stat* ( path: ADDRESS; VAR buf: Status ): LONGINT;
  882. BEGIN {UNCOOPERATIVE, UNCHECKED}
  883. #IF AMD64 THEN
  884. RETURN xstat( 1, path, buf );
  885. #ELSE
  886. RETURN xstat( 3, path, buf );
  887. #END
  888. END stat;
  889. PROCEDURE HandleSignal*( sig: LONGINT );
  890. BEGIN {UNCOOPERATIVE, UNCHECKED}
  891. InstallHandler( sig )
  892. END HandleSignal;
  893. PROCEDURE errno*(): LONGINT;
  894. VAR loc: ADDRESS;
  895. BEGIN {UNCOOPERATIVE, UNCHECKED}
  896. loc := errno_location();
  897. RETURN S.GET32(loc);
  898. END errno;
  899. TYPE OberonXErrorHandler* = PROCEDURE (disp, err: ADDRESS): LONGINT;
  900. TYPE OberonXIOErrorHandler* = PROCEDURE (disp: ADDRESS): LONGINT;
  901. VAR oberonXErrorHandler: OberonXErrorHandler;
  902. VAR oberonXIOErrorHandler: OberonXIOErrorHandler;
  903. PROCEDURE {C} X11ErrorHandler(d: ADDRESS; err: ADDRESS): WORD;
  904. VAR res: WORD;
  905. BEGIN {UNCOOPERATIVE, UNCHECKED}
  906. TRACE(d,err);
  907. IF oberonXErrorHandler # NIL THEN
  908. res := oberonXErrorHandler(d, err);
  909. END;
  910. RETURN 0;
  911. END X11ErrorHandler;
  912. PROCEDURE {C} X11IOErrorHandler(d: ADDRESS): WORD;
  913. VAR res: WORD;
  914. BEGIN {UNCOOPERATIVE, UNCHECKED}
  915. TRACE(d);
  916. IF oberonXIOErrorHandler # NIL THEN
  917. res := oberonXIOErrorHandler(d);
  918. END;
  919. RETURN 0;
  920. END X11IOErrorHandler;
  921. PROCEDURE InitXErrorHandlers*(xErrorHandler: OberonXErrorHandler; xIOErrorHandler: OberonXIOErrorHandler);
  922. VAR res: WORD;
  923. BEGIN {UNCOOPERATIVE, UNCHECKED}
  924. oberonXErrorHandler := xErrorHandler;
  925. oberonXIOErrorHandler := xIOErrorHandler;
  926. res := xSetErrorHandler(ADDRESS OF X11ErrorHandler);
  927. res := xSetIOErrorHandler(ADDRESS OF X11IOErrorHandler);
  928. END InitXErrorHandlers;
  929. PROCEDURE Init;
  930. VAR test: ADDRESS; i: LONGINT; s: ARRAY 256 OF CHAR;
  931. BEGIN {UNCOOPERATIVE, UNCHECKED}
  932. argc := Glue.argc;
  933. argv := Glue.argv;
  934. environ := Glue.environ;
  935. #IF I386 THEN
  936. libraryPaths[0] := "/lib/i386-linux-gnu/i686/cmov";
  937. libraryPaths[1] := "/lib/i386-linux-gnu";
  938. libraryPaths[2] := "/lib32";
  939. libraryPaths[3] := "/lib";
  940. libraryPaths[4] := "/usr/lib/i386-linux-gnu";
  941. libraryPaths[5] := "/usr/lib32";
  942. libraryPaths[6] := "/usr/lib";
  943. noPaths := 7;
  944. #ELSIF AMD64 THEN
  945. libraryPaths[0] := "/lib/x86_64-linux-gnu";
  946. libraryPaths[1] := "/lib64";
  947. libraryPaths[2] := "/lib";
  948. libraryPaths[3] := "/usr/lib/x86_64-linux-gnu";
  949. libraryPaths[4] := "/usr/lib64";
  950. libraryPaths[5] := "/usr/lib";
  951. noPaths := 6;
  952. #ELSE
  953. === error
  954. #END
  955. libc := Dlopen( libcname, 2 );
  956. libp := Dlopen( libpthreadname, 2 );
  957. Dlsym( libc, "exit", ADDRESSOF(exit) );
  958. Dlsym( libc, "sysconf", ADDRESSOF(sysconf) );
  959. Dlsym( libc, "pthread_mutex_init", ADDRESSOF(pthread_mutex_init) );
  960. Dlsym( libc, "pthread_mutex_destroy", ADDRESSOF(pthread_mutex_destroy) );
  961. Dlsym( libc, "pthread_mutex_lock", ADDRESSOF(pthread_mutex_lock) );
  962. Dlsym( libc, "pthread_mutex_unlock", ADDRESSOF(pthread_mutex_unlock) );
  963. Dlsym( libp, "pthread_mutexattr_init", ADDRESSOF(pthread_mutexattr_init) );
  964. Dlsym( libp, "pthread_mutexattr_settype", ADDRESSOF(pthread_mutexattr_settype) );
  965. Dlsym( libc, "pthread_cond_init", ADDRESSOF(pthread_cond_init) );
  966. Dlsym( libc, "pthread_cond_destroy", ADDRESSOF(pthread_cond_destroy) );
  967. Dlsym( libc, "pthread_cond_wait", ADDRESSOF(pthread_cond_wait) );
  968. Dlsym( libc, "pthread_cond_signal", ADDRESSOF(pthread_cond_signal) );
  969. Dlsym( libp, "pthread_create", ADDRESSOF(pthread_create) );
  970. Dlsym( libp, "pthread_exit", ADDRESSOF(pthread_exit) );
  971. Dlsym( libp, "pthread_detach", ADDRESSOF(pthread_detach) );
  972. Dlsym( libp, "pthread_cancel", ADDRESSOF(pthread_cancel) );
  973. Dlsym( libp, "pthread_kill", ADDRESSOF(pthread_kill) );
  974. Dlsym( libp, "pthread_join", ADDRESSOF(pthread_join) );
  975. Dlsym( libp, "pthread_key_create", ADDRESSOF( pthread_key_create ) );
  976. Dlsym( libp, "pthread_getspecific", ADDRESSOF( pthread_getspecific ) );
  977. Dlsym( libp, "pthread_setspecific", ADDRESSOF( pthread_setspecific ) );
  978. Dlsym( libp, "pthread_sigmask", ADDRESSOF(pthread_sigmask) );
  979. Dlsym( libp, "pthread_setcancelstate", ADDRESSOF(pthread_setcancelstate) );
  980. Dlsym( libp, "pthread_setcanceltype", ADDRESSOF(pthread_setcanceltype) );
  981. Dlsym( libp, "pthread_attr_init", ADDRESSOF(pthread_attr_init) );
  982. Dlsym( libp, "pthread_attr_setscope", ADDRESSOF(pthread_attr_setscope) );
  983. Dlsym( libp, "pthread_attr_setdetachstate", ADDRESSOF(pthread_attr_setdetachstate) );
  984. Dlsym( libp, "pthread_attr_setstacksize", ADDRESSOF(pthread_attr_setstacksize) );
  985. Dlsym( libp, "pthread_self", ADDRESSOF(pthread_self) );
  986. Dlsym( libp, "sem_init", ADDRESSOF(sem_init) );
  987. Dlsym( libp, "sem_wait", ADDRESSOF(sem_wait) );
  988. Dlsym( libp, "sem_post", ADDRESSOF(sem_post) );
  989. Dlsym( libp, "sem_destroy", ADDRESSOF(sem_destroy) );
  990. Dlsym( libp, "pthread_barrier_init", ADDRESSOF(pthread_barrier_init) );
  991. Dlsym( libp, "pthread_barrier_wait", ADDRESSOF(pthread_barrier_wait) );
  992. Dlsym( libp, "pthread_barrier_destroy", ADDRESSOF(pthread_barrier_destroy) );
  993. Dlsym( libp, "pthread_getaffinity_np", ADDRESSOF(pthread_getaffinity_np) );
  994. Dlsym( libp, "pthread_setaffinity_np", ADDRESSOF(pthread_setaffinity_np) );
  995. Dlsym( libc, "posix_spawnp", ADDRESSOF(posix_spawnp) );
  996. Dlsym( libc, "posix_spawn", ADDRESSOF(posix_spawn) );
  997. Dlsym( libc, "waitpid", ADDRESSOF(waitpid) );
  998. Dlsym( libc, "pipe", ADDRESSOF(pipe) );
  999. Dlsym( libc, "dup2",ADDRESSOF(dup2) );
  1000. Dlsym( libc, "dup", ADDRESSOF(dup) );
  1001. Dlsym( libc, "sched_get_priority_max", ADDRESSOF(sched_get_priority_max) );
  1002. Dlsym( libc, "sched_get_priority_min", ADDRESSOF(sched_get_priority_min) );
  1003. Dlsym( libc, "pthread_setschedparam", ADDRESSOF(pthread_setschedparam) );
  1004. Dlsym( libc, "pthread_getschedparam", ADDRESSOF(pthread_getschedparam) );
  1005. Dlsym( libc, "sigaction", ADDRESSOF(sigaction) );
  1006. Dlsym( libc, "sigemptyset", ADDRESSOF(sigemptyset) );
  1007. Dlsym( libc, "sigfillset", ADDRESSOF(sigfillset) );
  1008. Dlsym( libc, "sigaddset", ADDRESSOF(sigaddset) );
  1009. Dlsym( libc, "sigdelset", ADDRESSOF(sigdelset) );
  1010. Dlsym( libc, "nanosleep", ADDRESSOF(nanosleep) );
  1011. Dlsym( libc, "sigaltstack", ADDRESSOF(sigaltstack) );
  1012. Dlsym( libc, "sigsuspend", ADDRESSOF(sigsuspend) );
  1013. Dlsym( libc, "read", ADDRESSOF( read ) );
  1014. Dlsym( libc, "write", ADDRESSOF( write ) );
  1015. Dlsym( libc, "open", ADDRESSOF( open ) );
  1016. Dlsym( libc, "close", ADDRESSOF( close ) );
  1017. Dlsym( libc, "lseek", ADDRESSOF( lseek ) );
  1018. Dlsym( libc, "realpath", ADDRESSOF( realpath ) );
  1019. Dlsym( libc, "fsync", ADDRESSOF( fsync ) );
  1020. Dlsym( libc, "ioctl", ADDRESSOF( ioctl ) );
  1021. Dlsym( libc, "unlink", ADDRESSOF( unlink ) );
  1022. Dlsym( libc, "rename", ADDRESSOF( rename ) );
  1023. Dlsym( libc, "ftruncate", ADDRESSOF( ftruncate ) );
  1024. Dlsym( libc, "chmod", ADDRESSOF( chmod ) );
  1025. Dlsym( libc, "utime", ADDRESSOF( utime ) );
  1026. Dlsym( libc, "access", ADDRESSOF( access ) );
  1027. Dlsym( libc, "select", ADDRESSOF( select ) );
  1028. Dlsym( libc, "chdir", ADDRESSOF( chdir ) );
  1029. Dlsym( libc, "mkdir", ADDRESSOF( mkdir ) );
  1030. Dlsym( libc, "rmdir", ADDRESSOF( rmdir ) );
  1031. Dlsym( libc, "__xstat", ADDRESSOF( xstat ) );
  1032. Dlsym( libc, "__lxstat", ADDRESSOF( lxstat ) );
  1033. Dlsym( libc, "__fxstat", ADDRESSOF( fxstat ) );
  1034. Dlsym( libc, "getpid", ADDRESSOF( getpid ) );
  1035. Dlsym( libc, "getuid", ADDRESSOF( getuid ) );
  1036. Dlsym( libc, "alarm", ADDRESSOF( alarm ) );
  1037. Dlsym( libc, "setitimer", ADDRESSOF( setitimer ) );
  1038. Dlsym( libc, "getitimer", ADDRESSOF( getitimer ) );
  1039. Dlsym( libc, "clock_gettime", ADDRESSOF(clock_gettime) );
  1040. Dlsym( libc, "clock_getres", ADDRESSOF(clock_getres) );
  1041. Dlsym( libc, "gettimeofday", ADDRESSOF( gettimeofday ) );
  1042. Dlsym( libc, "mktime", ADDRESSOF( mktime ) );
  1043. Dlsym( libc, "localtime", ADDRESSOF( localtime ) );
  1044. Dlsym( libc, "time", ADDRESSOF( time ) );
  1045. Dlsym( libc, "times", ADDRESSOF( times ) );
  1046. Dlsym( libc, "getcwd", ADDRESSOF( getcwd ) );
  1047. Dlsym( libc, "getenv", ADDRESSOF( getenv ) );
  1048. Dlsym( libc, "opendir", ADDRESSOF( opendir ) );
  1049. Dlsym( libc, "readdir", ADDRESSOF( readdir ) );
  1050. Dlsym( libc, "closedir", ADDRESSOF( closedir ) );
  1051. Dlsym( libc, "__sigsetjmp", ADDRESSOF( sigsetjmp ) );
  1052. Dlsym( libc, "siglongjmp", ADDRESSOF( siglongjmp ) );
  1053. Dlsym( libc, "malloc", ADDRESSOF( malloc ) );
  1054. Dlsym( libc, "posix_memalign", ADDRESSOF( posix_memalign ) );
  1055. Dlsym( libc, "free", ADDRESSOF( free ) );
  1056. Dlsym( libc, "mprotect", ADDRESSOF( mprotect ) );
  1057. Dlsym( libc, "system", ADDRESSOF( system ) );
  1058. Dlsym( libc, "uname", ADDRESSOF( uname ) );
  1059. Dlsym( libc, "kill", ADDRESSOF( kill ) );
  1060. Dlsym( libc, "perror", ADDRESSOF( perror ) );
  1061. Dlsym( libc, "__errno_location", ADDRESSOF(errno_location ) );
  1062. getSysinfo;
  1063. CreateSignalStack;
  1064. END Init;
  1065. (* load X11 related libaries only on demand *)
  1066. PROCEDURE LinkToX*;
  1067. BEGIN {UNCOOPERATIVE, UNCHECKED}
  1068. libx := Dlopen( libX11name, 2 );
  1069. Dlsym( libx, "XSetErrorHandler", ADDRESS OF xSetErrorHandler);
  1070. Dlsym( libx, "XSetIOErrorHandler", ADDRESS OF xSetIOErrorHandler);
  1071. END LinkToX;
  1072. PROCEDURE {INITIAL} Init0;
  1073. BEGIN {UNCOOPERATIVE, UNCHECKED}
  1074. Init;
  1075. END Init0;
  1076. END Unix.