os_darwin.odin 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125
  1. package os
  2. foreign import dl "system:dl"
  3. foreign import libc "system:System.framework"
  4. foreign import pthread "system:System.framework"
  5. import "base:runtime"
  6. import "core:strings"
  7. import "core:c"
  8. Handle :: distinct i32
  9. File_Time :: distinct u64
  10. Errno :: distinct int
  11. INVALID_HANDLE :: ~Handle(0)
  12. ERROR_NONE: Errno : 0
  13. EPERM: Errno : 1 /* Operation not permitted */
  14. ENOENT: Errno : 2 /* No such file or directory */
  15. ESRCH: Errno : 3 /* No such process */
  16. EINTR: Errno : 4 /* Interrupted system call */
  17. EIO: Errno : 5 /* Input/output error */
  18. ENXIO: Errno : 6 /* Device not configured */
  19. E2BIG: Errno : 7 /* Argument list too long */
  20. ENOEXEC: Errno : 8 /* Exec format error */
  21. EBADF: Errno : 9 /* Bad file descriptor */
  22. ECHILD: Errno : 10 /* No child processes */
  23. EDEADLK: Errno : 11 /* Resource deadlock avoided */
  24. ENOMEM: Errno : 12 /* Cannot allocate memory */
  25. EACCES: Errno : 13 /* Permission denied */
  26. EFAULT: Errno : 14 /* Bad address */
  27. ENOTBLK: Errno : 15 /* Block device required */
  28. EBUSY: Errno : 16 /* Device / Resource busy */
  29. EEXIST: Errno : 17 /* File exists */
  30. EXDEV: Errno : 18 /* Cross-device link */
  31. ENODEV: Errno : 19 /* Operation not supported by device */
  32. ENOTDIR: Errno : 20 /* Not a directory */
  33. EISDIR: Errno : 21 /* Is a directory */
  34. EINVAL: Errno : 22 /* Invalid argument */
  35. ENFILE: Errno : 23 /* Too many open files in system */
  36. EMFILE: Errno : 24 /* Too many open files */
  37. ENOTTY: Errno : 25 /* Inappropriate ioctl for device */
  38. ETXTBSY: Errno : 26 /* Text file busy */
  39. EFBIG: Errno : 27 /* File too large */
  40. ENOSPC: Errno : 28 /* No space left on device */
  41. ESPIPE: Errno : 29 /* Illegal seek */
  42. EROFS: Errno : 30 /* Read-only file system */
  43. EMLINK: Errno : 31 /* Too many links */
  44. EPIPE: Errno : 32 /* Broken pipe */
  45. /* math software */
  46. EDOM: Errno : 33 /* Numerical argument out of domain */
  47. ERANGE: Errno : 34 /* Result too large */
  48. /* non-blocking and interrupt i/o */
  49. EAGAIN: Errno : 35 /* Resource temporarily unavailable */
  50. EWOULDBLOCK: Errno : EAGAIN /* Operation would block */
  51. EINPROGRESS: Errno : 36 /* Operation now in progress */
  52. EALREADY: Errno : 37 /* Operation already in progress */
  53. /* ipc/network software -- argument errors */
  54. ENOTSOCK: Errno : 38 /* Socket operation on non-socket */
  55. EDESTADDRREQ: Errno : 39 /* Destination address required */
  56. EMSGSIZE: Errno : 40 /* Message too long */
  57. EPROTOTYPE: Errno : 41 /* Protocol wrong type for socket */
  58. ENOPROTOOPT: Errno : 42 /* Protocol not available */
  59. EPROTONOSUPPORT: Errno : 43 /* Protocol not supported */
  60. ESOCKTNOSUPPORT: Errno : 44 /* Socket type not supported */
  61. ENOTSUP: Errno : 45 /* Operation not supported */
  62. EOPNOTSUPP:: ENOTSUP
  63. EPFNOSUPPORT: Errno : 46 /* Protocol family not supported */
  64. EAFNOSUPPORT: Errno : 47 /* Address family not supported by protocol family */
  65. EADDRINUSE: Errno : 48 /* Address already in use */
  66. EADDRNOTAVAIL: Errno : 49 /* Can't assign requested address */
  67. /* ipc/network software -- operational errors */
  68. ENETDOWN: Errno : 50 /* Network is down */
  69. ENETUNREACH: Errno : 51 /* Network is unreachable */
  70. ENETRESET: Errno : 52 /* Network dropped connection on reset */
  71. ECONNABORTED: Errno : 53 /* Software caused connection abort */
  72. ECONNRESET: Errno : 54 /* Connection reset by peer */
  73. ENOBUFS: Errno : 55 /* No buffer space available */
  74. EISCONN: Errno : 56 /* Socket is already connected */
  75. ENOTCONN: Errno : 57 /* Socket is not connected */
  76. ESHUTDOWN: Errno : 58 /* Can't send after socket shutdown */
  77. ETOOMANYREFS: Errno : 59 /* Too many references: can't splice */
  78. ETIMEDOUT: Errno : 60 /* Operation timed out */
  79. ECONNREFUSED: Errno : 61 /* Connection refused */
  80. ELOOP: Errno : 62 /* Too many levels of symbolic links */
  81. ENAMETOOLONG: Errno : 63 /* File name too long */
  82. /* should be rearranged */
  83. EHOSTDOWN: Errno : 64 /* Host is down */
  84. EHOSTUNREACH: Errno : 65 /* No route to host */
  85. ENOTEMPTY: Errno : 66 /* Directory not empty */
  86. /* quotas & mush */
  87. EPROCLIM: Errno : 67 /* Too many processes */
  88. EUSERS: Errno : 68 /* Too many users */
  89. EDQUOT: Errno : 69 /* Disc quota exceeded */
  90. /* Network File System */
  91. ESTALE: Errno : 70 /* Stale NFS file handle */
  92. EREMOTE: Errno : 71 /* Too many levels of remote in path */
  93. EBADRPC: Errno : 72 /* RPC struct is bad */
  94. ERPCMISMATCH: Errno : 73 /* RPC version wrong */
  95. EPROGUNAVAIL: Errno : 74 /* RPC prog. not avail */
  96. EPROGMISMATCH: Errno : 75 /* Program version wrong */
  97. EPROCUNAVAIL: Errno : 76 /* Bad procedure for program */
  98. ENOLCK: Errno : 77 /* No locks available */
  99. ENOSYS: Errno : 78 /* Function not implemented */
  100. EFTYPE: Errno : 79 /* Inappropriate file type or format */
  101. EAUTH: Errno : 80 /* Authentication error */
  102. ENEEDAUTH: Errno : 81 /* Need authenticator */
  103. /* Intelligent device errors */
  104. EPWROFF: Errno : 82 /* Device power is off */
  105. EDEVERR: Errno : 83 /* Device error, e.g. paper out */
  106. EOVERFLOW: Errno : 84 /* Value too large to be stored in data type */
  107. /* Program loading errors */
  108. EBADEXEC: Errno : 85 /* Bad executable */
  109. EBADARCH: Errno : 86 /* Bad CPU type in executable */
  110. ESHLIBVERS: Errno : 87 /* Shared library version mismatch */
  111. EBADMACHO: Errno : 88 /* Malformed Macho file */
  112. ECANCELED: Errno : 89 /* Operation canceled */
  113. EIDRM: Errno : 90 /* Identifier removed */
  114. ENOMSG: Errno : 91 /* No message of desired type */
  115. EILSEQ: Errno : 92 /* Illegal byte sequence */
  116. ENOATTR: Errno : 93 /* Attribute not found */
  117. EBADMSG: Errno : 94 /* Bad message */
  118. EMULTIHOP: Errno : 95 /* Reserved */
  119. ENODATA: Errno : 96 /* No message available on STREAM */
  120. ENOLINK: Errno : 97 /* Reserved */
  121. ENOSR: Errno : 98 /* No STREAM resources */
  122. ENOSTR: Errno : 99 /* Not a STREAM */
  123. EPROTO: Errno : 100 /* Protocol error */
  124. ETIME: Errno : 101 /* STREAM ioctl timeout */
  125. ENOPOLICY: Errno : 103 /* No such policy registered */
  126. ENOTRECOVERABLE: Errno : 104 /* State not recoverable */
  127. EOWNERDEAD: Errno : 105 /* Previous owner died */
  128. EQFULL: Errno : 106 /* Interface output queue is full */
  129. ELAST: Errno : 106 /* Must be equal largest errno */
  130. O_RDONLY :: 0x0000
  131. O_WRONLY :: 0x0001
  132. O_RDWR :: 0x0002
  133. O_CREATE :: 0x0200
  134. O_EXCL :: 0x0800
  135. O_NOCTTY :: 0
  136. O_TRUNC :: 0x0400
  137. O_NONBLOCK :: 0x0004
  138. O_APPEND :: 0x0008
  139. O_SYNC :: 0x0080
  140. O_ASYNC :: 0x0040
  141. O_CLOEXEC :: 0x1000000
  142. SEEK_DATA :: 3
  143. SEEK_HOLE :: 4
  144. SEEK_MAX :: SEEK_HOLE
  145. // NOTE(zangent): These are OS specific!
  146. // Do not mix these up!
  147. RTLD_LAZY :: 0x1
  148. RTLD_NOW :: 0x2
  149. RTLD_LOCAL :: 0x4
  150. RTLD_GLOBAL :: 0x8
  151. RTLD_NODELETE :: 0x80
  152. RTLD_NOLOAD :: 0x10
  153. RTLD_FIRST :: 0x100
  154. SOL_SOCKET :: 0xFFFF
  155. SOCK_STREAM :: 1
  156. SOCK_DGRAM :: 2
  157. SOCK_RAW :: 3
  158. SOCK_RDM :: 4
  159. SOCK_SEQPACKET :: 5
  160. SO_DEBUG :: 0x0001
  161. SO_ACCEPTCONN :: 0x0002
  162. SO_REUSEADDR :: 0x0004
  163. SO_KEEPALIVE :: 0x0008
  164. SO_DONTROUTE :: 0x0010
  165. SO_BROADCAST :: 0x0020
  166. SO_USELOOPBACK :: 0x0040
  167. SO_LINGER :: 0x0080
  168. SO_OOBINLINE :: 0x0100
  169. SO_REUSEPORT :: 0x0200
  170. SO_TIMESTAMP :: 0x0400
  171. SO_DONTTRUNC :: 0x2000
  172. SO_WANTMORE :: 0x4000
  173. SO_WANTOOBFLAG :: 0x8000
  174. SO_SNDBUF :: 0x1001
  175. SO_RCVBUF :: 0x1002
  176. SO_SNDLOWAT :: 0x1003
  177. SO_RCVLOWAT :: 0x1004
  178. SO_SNDTIMEO :: 0x1005
  179. SO_RCVTIMEO :: 0x1006
  180. SO_ERROR :: 0x1007
  181. SO_TYPE :: 0x1008
  182. SO_PRIVSTATE :: 0x1009
  183. SO_NREAD :: 0x1020
  184. SO_NKE :: 0x1021
  185. AF_UNSPEC :: 0
  186. AF_LOCAL :: 1
  187. AF_UNIX :: AF_LOCAL
  188. AF_INET :: 2
  189. AF_IMPLINK :: 3
  190. AF_PUP :: 4
  191. AF_CHAOS :: 5
  192. AF_NS :: 6
  193. AF_ISO :: 7
  194. AF_OSI :: AF_ISO
  195. AF_ECMA :: 8
  196. AF_DATAKIT :: 9
  197. AF_CCITT :: 10
  198. AF_SNA :: 11
  199. AF_DECnet :: 12
  200. AF_DLI :: 13
  201. AF_LAT :: 14
  202. AF_HYLINK :: 15
  203. AF_APPLETALK :: 16
  204. AF_ROUTE :: 17
  205. AF_LINK :: 18
  206. pseudo_AF_XTP :: 19
  207. AF_COIP :: 20
  208. AF_CNT :: 21
  209. pseudo_AF_RTIP :: 22
  210. AF_IPX :: 23
  211. AF_SIP :: 24
  212. pseudo_AF_PIP :: 25
  213. pseudo_AF_BLUE :: 26
  214. AF_NDRV :: 27
  215. AF_ISDN :: 28
  216. AF_E164 :: AF_ISDN
  217. pseudo_AF_KEY :: 29
  218. AF_INET6 :: 30
  219. AF_NATM :: 31
  220. AF_SYSTEM :: 32
  221. AF_NETBIOS :: 33
  222. AF_PPP :: 34
  223. TCP_NODELAY :: 0x01
  224. TCP_MAXSEG :: 0x02
  225. TCP_NOPUSH :: 0x04
  226. TCP_NOOPT :: 0x08
  227. IPPROTO_ICMP :: 1
  228. IPPROTO_TCP :: 6
  229. IPPROTO_UDP :: 17
  230. SHUT_RD :: 0
  231. SHUT_WR :: 1
  232. SHUT_RDWR :: 2
  233. F_GETFL: int : 3 /* Get file flags */
  234. F_SETFL: int : 4 /* Set file flags */
  235. // "Argv" arguments converted to Odin strings
  236. args := _alloc_command_line_arguments()
  237. Unix_File_Time :: struct {
  238. seconds: i64,
  239. nanoseconds: i64,
  240. }
  241. OS_Stat :: struct {
  242. device_id: i32, // ID of device containing file
  243. mode: u16, // Mode of the file
  244. nlink: u16, // Number of hard links
  245. serial: u64, // File serial number
  246. uid: u32, // User ID of the file's owner
  247. gid: u32, // Group ID of the file's group
  248. rdev: i32, // Device ID, if device
  249. last_access: Unix_File_Time, // Time of last access
  250. modified: Unix_File_Time, // Time of last modification
  251. status_change: Unix_File_Time, // Time of last status change
  252. created: Unix_File_Time, // Time of creation
  253. size: i64, // Size of the file, in bytes
  254. blocks: i64, // Number of blocks allocated for the file
  255. block_size: i32, // Optimal blocksize for I/O
  256. flags: u32, // User-defined flags for the file
  257. gen_num: u32, // File generation number ..?
  258. _spare: i32, // RESERVED
  259. _reserve1,
  260. _reserve2: i64, // RESERVED
  261. }
  262. DARWIN_MAXPATHLEN :: 1024
  263. Dirent :: struct {
  264. ino: u64,
  265. off: u64,
  266. reclen: u16,
  267. namlen: u16,
  268. type: u8,
  269. name: [DARWIN_MAXPATHLEN]byte,
  270. }
  271. Dir :: distinct rawptr // DIR*
  272. ADDRESS_FAMILY :: c.char
  273. SOCKADDR :: struct #packed {
  274. len: c.char,
  275. family: ADDRESS_FAMILY,
  276. sa_data: [14]c.char,
  277. }
  278. SOCKADDR_STORAGE_LH :: struct #packed {
  279. len: c.char,
  280. family: ADDRESS_FAMILY,
  281. __ss_pad1: [6]c.char,
  282. __ss_align: i64,
  283. __ss_pad2: [112]c.char,
  284. }
  285. sockaddr_in :: struct #packed {
  286. sin_len: c.char,
  287. sin_family: ADDRESS_FAMILY,
  288. sin_port: u16be,
  289. sin_addr: in_addr,
  290. sin_zero: [8]c.char,
  291. }
  292. sockaddr_in6 :: struct #packed {
  293. sin6_len: c.char,
  294. sin6_family: ADDRESS_FAMILY,
  295. sin6_port: u16be,
  296. sin6_flowinfo: c.uint,
  297. sin6_addr: in6_addr,
  298. sin6_scope_id: c.uint,
  299. }
  300. in_addr :: struct #packed {
  301. s_addr: u32,
  302. }
  303. in6_addr :: struct #packed {
  304. s6_addr: [16]u8,
  305. }
  306. SIOCGIFFLAG :: enum c.int {
  307. UP = 0, /* Interface is up. */
  308. BROADCAST = 1, /* Broadcast address valid. */
  309. DEBUG = 2, /* Turn on debugging. */
  310. LOOPBACK = 3, /* Is a loopback net. */
  311. POINT_TO_POINT = 4, /* Interface is point-to-point link. */
  312. NO_TRAILERS = 5, /* Avoid use of trailers. */
  313. RUNNING = 6, /* Resources allocated. */
  314. NOARP = 7, /* No address resolution protocol. */
  315. PROMISC = 8, /* Receive all packets. */
  316. ALL_MULTI = 9, /* Receive all multicast packets. Unimplemented. */
  317. }
  318. SIOCGIFFLAGS :: bit_set[SIOCGIFFLAG; c.int]
  319. ifaddrs :: struct {
  320. next: ^ifaddrs,
  321. name: cstring,
  322. flags: SIOCGIFFLAGS,
  323. address: ^SOCKADDR,
  324. netmask: ^SOCKADDR,
  325. broadcast_or_dest: ^SOCKADDR, // Broadcast or Point-to-Point address
  326. data: rawptr, // Address-specific data.
  327. }
  328. Timeval :: struct {
  329. seconds: i64,
  330. microseconds: int,
  331. }
  332. Linger :: struct {
  333. onoff: int,
  334. linger: int,
  335. }
  336. Socket :: distinct int
  337. socklen_t :: c.int
  338. // File type
  339. S_IFMT :: 0o170000 // Type of file mask
  340. S_IFIFO :: 0o010000 // Named pipe (fifo)
  341. S_IFCHR :: 0o020000 // Character special
  342. S_IFDIR :: 0o040000 // Directory
  343. S_IFBLK :: 0o060000 // Block special
  344. S_IFREG :: 0o100000 // Regular
  345. S_IFLNK :: 0o120000 // Symbolic link
  346. S_IFSOCK :: 0o140000 // Socket
  347. // File mode
  348. // Read, write, execute/search by owner
  349. S_IRWXU :: 0o0700 // RWX mask for owner
  350. S_IRUSR :: 0o0400 // R for owner
  351. S_IWUSR :: 0o0200 // W for owner
  352. S_IXUSR :: 0o0100 // X for owner
  353. // Read, write, execute/search by group
  354. S_IRWXG :: 0o0070 // RWX mask for group
  355. S_IRGRP :: 0o0040 // R for group
  356. S_IWGRP :: 0o0020 // W for group
  357. S_IXGRP :: 0o0010 // X for group
  358. // Read, write, execute/search by others
  359. S_IRWXO :: 0o0007 // RWX mask for other
  360. S_IROTH :: 0o0004 // R for other
  361. S_IWOTH :: 0o0002 // W for other
  362. S_IXOTH :: 0o0001 // X for other
  363. S_ISUID :: 0o4000 // Set user id on execution
  364. S_ISGID :: 0o2000 // Set group id on execution
  365. S_ISVTX :: 0o1000 // Directory restrcted delete
  366. S_ISLNK :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFLNK }
  367. S_ISREG :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFREG }
  368. S_ISDIR :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFDIR }
  369. S_ISCHR :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFCHR }
  370. S_ISBLK :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFBLK }
  371. S_ISFIFO :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFIFO }
  372. S_ISSOCK :: #force_inline proc(m: u16) -> bool { return (m & S_IFMT) == S_IFSOCK }
  373. R_OK :: 4 // Test for read permission
  374. W_OK :: 2 // Test for write permission
  375. X_OK :: 1 // Test for execute permission
  376. F_OK :: 0 // Test for file existance
  377. F_GETPATH :: 50 // return the full path of the fd
  378. foreign libc {
  379. @(link_name="__error") __error :: proc() -> ^c.int ---
  380. @(link_name="open") _unix_open :: proc(path: cstring, flags: i32, #c_vararg args: ..any) -> Handle ---
  381. @(link_name="close") _unix_close :: proc(handle: Handle) -> c.int ---
  382. @(link_name="read") _unix_read :: proc(handle: Handle, buffer: rawptr, count: c.size_t) -> int ---
  383. @(link_name="write") _unix_write :: proc(handle: Handle, buffer: rawptr, count: c.size_t) -> int ---
  384. @(link_name="pread") _unix_pread :: proc(handle: Handle, buffer: rawptr, count: c.size_t, offset: i64) -> int ---
  385. @(link_name="pwrite") _unix_pwrite :: proc(handle: Handle, buffer: rawptr, count: c.size_t, offset: i64) -> int ---
  386. @(link_name="lseek") _unix_lseek :: proc(fs: Handle, offset: int, whence: c.int) -> int ---
  387. @(link_name="gettid") _unix_gettid :: proc() -> u64 ---
  388. @(link_name="getpagesize") _unix_getpagesize :: proc() -> i32 ---
  389. @(link_name="stat64") _unix_stat :: proc(path: cstring, stat: ^OS_Stat) -> c.int ---
  390. @(link_name="lstat64") _unix_lstat :: proc(path: cstring, stat: ^OS_Stat) -> c.int ---
  391. @(link_name="fstat64") _unix_fstat :: proc(fd: Handle, stat: ^OS_Stat) -> c.int ---
  392. @(link_name="readlink") _unix_readlink :: proc(path: cstring, buf: ^byte, bufsiz: c.size_t) -> c.ssize_t ---
  393. @(link_name="access") _unix_access :: proc(path: cstring, mask: c.int) -> c.int ---
  394. @(link_name="fsync") _unix_fsync :: proc(handle: Handle) -> c.int ---
  395. @(link_name="fdopendir$INODE64") _unix_fdopendir_amd64 :: proc(fd: Handle) -> Dir ---
  396. @(link_name="readdir_r$INODE64") _unix_readdir_r_amd64 :: proc(dirp: Dir, entry: ^Dirent, result: ^^Dirent) -> c.int ---
  397. @(link_name="fdopendir") _unix_fdopendir_arm64 :: proc(fd: Handle) -> Dir ---
  398. @(link_name="readdir_r") _unix_readdir_r_arm64 :: proc(dirp: Dir, entry: ^Dirent, result: ^^Dirent) -> c.int ---
  399. @(link_name="closedir") _unix_closedir :: proc(dirp: Dir) -> c.int ---
  400. @(link_name="rewinddir") _unix_rewinddir :: proc(dirp: Dir) ---
  401. @(link_name="__fcntl") _unix__fcntl :: proc(fd: Handle, cmd: c.int, arg: uintptr) -> c.int ---
  402. @(link_name="rename") _unix_rename :: proc(old: cstring, new: cstring) -> c.int ---
  403. @(link_name="remove") _unix_remove :: proc(path: cstring) -> c.int ---
  404. @(link_name="fchmod") _unix_fchmod :: proc(fd: Handle, mode: u16) -> c.int ---
  405. @(link_name="malloc") _unix_malloc :: proc(size: int) -> rawptr ---
  406. @(link_name="calloc") _unix_calloc :: proc(num, size: int) -> rawptr ---
  407. @(link_name="free") _unix_free :: proc(ptr: rawptr) ---
  408. @(link_name="realloc") _unix_realloc :: proc(ptr: rawptr, size: int) -> rawptr ---
  409. @(link_name="getenv") _unix_getenv :: proc(cstring) -> cstring ---
  410. @(link_name="getcwd") _unix_getcwd :: proc(buf: cstring, len: c.size_t) -> cstring ---
  411. @(link_name="chdir") _unix_chdir :: proc(buf: cstring) -> c.int ---
  412. @(link_name="mkdir") _unix_mkdir :: proc(buf: cstring, mode: u16) -> c.int ---
  413. @(link_name="realpath") _unix_realpath :: proc(path: cstring, resolved_path: rawptr) -> rawptr ---
  414. @(link_name="strerror") _darwin_string_error :: proc(num : c.int) -> cstring ---
  415. @(link_name="sysctlbyname") _sysctlbyname :: proc(path: cstring, oldp: rawptr, oldlenp: rawptr, newp: rawptr, newlen: int) -> c.int ---
  416. @(link_name="socket") _unix_socket :: proc(domain: int, type: int, protocol: int) -> int ---
  417. @(link_name="listen") _unix_listen :: proc(socket: int, backlog: int) -> int ---
  418. @(link_name="accept") _unix_accept :: proc(socket: int, addr: rawptr, addr_len: rawptr) -> int ---
  419. @(link_name="connect") _unix_connect :: proc(socket: int, addr: rawptr, addr_len: socklen_t) -> int ---
  420. @(link_name="bind") _unix_bind :: proc(socket: int, addr: rawptr, addr_len: socklen_t) -> int ---
  421. @(link_name="setsockopt") _unix_setsockopt :: proc(socket: int, level: int, opt_name: int, opt_val: rawptr, opt_len: socklen_t) -> int ---
  422. @(link_name="getsockopt") _unix_getsockopt :: proc(socket: int, level: int, opt_name: int, opt_val: rawptr, opt_len: socklen_t) -> int ---
  423. @(link_name="recvfrom") _unix_recvfrom :: proc(socket: int, buffer: rawptr, buffer_len: c.size_t, flags: int, addr: rawptr, addr_len: ^socklen_t) -> c.ssize_t ---
  424. @(link_name="recv") _unix_recv :: proc(socket: int, buffer: rawptr, buffer_len: c.size_t, flags: int) -> c.ssize_t ---
  425. @(link_name="sendto") _unix_sendto :: proc(socket: int, buffer: rawptr, buffer_len: c.size_t, flags: int, addr: rawptr, addr_len: socklen_t) -> c.ssize_t ---
  426. @(link_name="send") _unix_send :: proc(socket: int, buffer: rawptr, buffer_len: c.size_t, flags: int) -> c.ssize_t ---
  427. @(link_name="shutdown") _unix_shutdown :: proc(socket: int, how: int) -> int ---
  428. @(link_name="getifaddrs") _getifaddrs :: proc(ifap: ^^ifaddrs) -> (c.int) ---
  429. @(link_name="freeifaddrs") _freeifaddrs :: proc(ifa: ^ifaddrs) ---
  430. @(link_name="exit") _unix_exit :: proc(status: c.int) -> ! ---
  431. }
  432. when ODIN_ARCH != .arm64 {
  433. _unix_fdopendir :: proc {_unix_fdopendir_amd64}
  434. _unix_readdir_r :: proc {_unix_readdir_r_amd64}
  435. } else {
  436. _unix_fdopendir :: proc {_unix_fdopendir_arm64}
  437. _unix_readdir_r :: proc {_unix_readdir_r_arm64}
  438. }
  439. foreign dl {
  440. @(link_name="dlopen") _unix_dlopen :: proc(filename: cstring, flags: int) -> rawptr ---
  441. @(link_name="dlsym") _unix_dlsym :: proc(handle: rawptr, symbol: cstring) -> rawptr ---
  442. @(link_name="dlclose") _unix_dlclose :: proc(handle: rawptr) -> int ---
  443. @(link_name="dlerror") _unix_dlerror :: proc() -> cstring ---
  444. }
  445. get_last_error :: proc "contextless" () -> int {
  446. return int(__error()^)
  447. }
  448. get_last_error_string :: proc() -> string {
  449. return cast(string)_darwin_string_error(cast(c.int)get_last_error())
  450. }
  451. open :: proc(path: string, flags: int = O_RDWR, mode: int = 0) -> (Handle, Errno) {
  452. isDir := is_dir_path(path)
  453. flags := flags
  454. if isDir {
  455. /*
  456. @INFO(Platin): To make it impossible to use the wrong flag for dir's
  457. as you can't write to a dir only read which makes it fail to open
  458. */
  459. flags = O_RDONLY
  460. }
  461. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  462. cstr := strings.clone_to_cstring(path, context.temp_allocator)
  463. handle := _unix_open(cstr, i32(flags), u16(mode))
  464. if handle == -1 {
  465. return INVALID_HANDLE, cast(Errno)get_last_error()
  466. }
  467. /*
  468. @INFO(Platin): this is only done because O_CREATE for some reason fails to apply mode
  469. should not happen if the handle is a directory
  470. */
  471. if mode != 0 && !isDir {
  472. err := fchmod(handle, cast(u16)mode)
  473. if err != 0 {
  474. _unix_close(handle)
  475. return INVALID_HANDLE, cast(Errno)err
  476. }
  477. }
  478. return handle, 0
  479. }
  480. fchmod :: proc(fd: Handle, mode: u16) -> Errno {
  481. return cast(Errno)_unix_fchmod(fd, mode)
  482. }
  483. close :: proc(fd: Handle) -> Errno {
  484. return cast(Errno)_unix_close(fd)
  485. }
  486. // If you read or write more than `SSIZE_MAX` bytes, most darwin implementations will return `EINVAL`
  487. // but it is really implementation defined. `SSIZE_MAX` is also implementation defined but usually
  488. // the max of an i32 on Darwin.
  489. // In practice a read/write call would probably never read/write these big buffers all at once,
  490. // which is why the number of bytes is returned and why there are procs that will call this in a
  491. // loop for you.
  492. // We set a max of 1GB to keep alignment and to be safe.
  493. @(private)
  494. MAX_RW :: 1 << 30
  495. write :: proc(fd: Handle, data: []byte) -> (int, Errno) {
  496. if len(data) == 0 {
  497. return 0, ERROR_NONE
  498. }
  499. to_write := min(c.size_t(len(data)), MAX_RW)
  500. bytes_written := _unix_write(fd, raw_data(data), to_write)
  501. if bytes_written < 0 {
  502. return -1, Errno(get_last_error())
  503. }
  504. return bytes_written, ERROR_NONE
  505. }
  506. read :: proc(fd: Handle, data: []u8) -> (int, Errno) {
  507. if len(data) == 0 {
  508. return 0, ERROR_NONE
  509. }
  510. to_read := min(c.size_t(len(data)), MAX_RW)
  511. bytes_read := _unix_read(fd, raw_data(data), to_read)
  512. if bytes_read < 0 {
  513. return -1, Errno(get_last_error())
  514. }
  515. return bytes_read, ERROR_NONE
  516. }
  517. read_at :: proc(fd: Handle, data: []byte, offset: i64) -> (int, Errno) {
  518. if len(data) == 0 {
  519. return 0, ERROR_NONE
  520. }
  521. to_read := min(c.size_t(len(data)), MAX_RW)
  522. bytes_read := _unix_pread(fd, raw_data(data), to_read, offset)
  523. if bytes_read < 0 {
  524. return -1, Errno(get_last_error())
  525. }
  526. return bytes_read, ERROR_NONE
  527. }
  528. write_at :: proc(fd: Handle, data: []byte, offset: i64) -> (int, Errno) {
  529. if len(data) == 0 {
  530. return 0, ERROR_NONE
  531. }
  532. to_write := min(c.size_t(len(data)), MAX_RW)
  533. bytes_written := _unix_pwrite(fd, raw_data(data), to_write, offset)
  534. if bytes_written < 0 {
  535. return -1, Errno(get_last_error())
  536. }
  537. return bytes_written, ERROR_NONE
  538. }
  539. seek :: proc(fd: Handle, offset: i64, whence: int) -> (i64, Errno) {
  540. assert(fd != -1)
  541. final_offset := i64(_unix_lseek(fd, int(offset), c.int(whence)))
  542. if final_offset == -1 {
  543. return 0, 1
  544. }
  545. return final_offset, 0
  546. }
  547. file_size :: proc(fd: Handle) -> (i64, Errno) {
  548. prev, _ := seek(fd, 0, SEEK_CUR)
  549. size, err := seek(fd, 0, SEEK_END)
  550. seek(fd, prev, SEEK_SET)
  551. return i64(size), err
  552. }
  553. // NOTE(bill): Uses startup to initialize it
  554. stdin: Handle = 0 // get_std_handle(win32.STD_INPUT_HANDLE);
  555. stdout: Handle = 1 // get_std_handle(win32.STD_OUTPUT_HANDLE);
  556. stderr: Handle = 2 // get_std_handle(win32.STD_ERROR_HANDLE);
  557. last_write_time :: proc(fd: Handle) -> (File_Time, Errno) {
  558. s, err := _fstat(fd)
  559. if err != ERROR_NONE {
  560. return 0, err
  561. }
  562. modified := s.modified.seconds * 1_000_000_000 + s.modified.nanoseconds
  563. return File_Time(modified), ERROR_NONE
  564. }
  565. last_write_time_by_name :: proc(name: string) -> (File_Time, Errno) {
  566. s, err := _stat(name)
  567. if err != ERROR_NONE {
  568. return 0, err
  569. }
  570. modified := s.modified.seconds * 1_000_000_000 + s.modified.nanoseconds
  571. return File_Time(modified), ERROR_NONE
  572. }
  573. is_path_separator :: proc(r: rune) -> bool {
  574. return r == '/'
  575. }
  576. is_file_handle :: proc(fd: Handle) -> bool {
  577. s, err := _fstat(fd)
  578. if err != ERROR_NONE {
  579. return false
  580. }
  581. return S_ISREG(s.mode)
  582. }
  583. is_file_path :: proc(path: string, follow_links: bool = true) -> bool {
  584. s: OS_Stat
  585. err: Errno
  586. if follow_links {
  587. s, err = _stat(path)
  588. } else {
  589. s, err = _lstat(path)
  590. }
  591. if err != ERROR_NONE {
  592. return false
  593. }
  594. return S_ISREG(s.mode)
  595. }
  596. is_dir_handle :: proc(fd: Handle) -> bool {
  597. s, err := _fstat(fd)
  598. if err != ERROR_NONE {
  599. return false
  600. }
  601. return S_ISDIR(s.mode)
  602. }
  603. is_dir_path :: proc(path: string, follow_links: bool = true) -> bool {
  604. s: OS_Stat
  605. err: Errno
  606. if follow_links {
  607. s, err = _stat(path)
  608. } else {
  609. s, err = _lstat(path)
  610. }
  611. if err != ERROR_NONE {
  612. return false
  613. }
  614. return S_ISDIR(s.mode)
  615. }
  616. is_file :: proc {is_file_path, is_file_handle}
  617. is_dir :: proc {is_dir_path, is_dir_handle}
  618. exists :: proc(path: string) -> bool {
  619. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  620. cpath := strings.clone_to_cstring(path, context.temp_allocator)
  621. res := _unix_access(cpath, O_RDONLY)
  622. return res == 0
  623. }
  624. rename :: proc(old: string, new: string) -> bool {
  625. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  626. old_cstr := strings.clone_to_cstring(old, context.temp_allocator)
  627. new_cstr := strings.clone_to_cstring(new, context.temp_allocator)
  628. return _unix_rename(old_cstr, new_cstr) != -1
  629. }
  630. remove :: proc(path: string) -> Errno {
  631. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  632. path_cstr := strings.clone_to_cstring(path, context.temp_allocator)
  633. res := _unix_remove(path_cstr)
  634. if res == -1 {
  635. return Errno(get_last_error())
  636. }
  637. return ERROR_NONE
  638. }
  639. @private
  640. _stat :: proc(path: string) -> (OS_Stat, Errno) {
  641. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  642. cstr := strings.clone_to_cstring(path, context.temp_allocator)
  643. s: OS_Stat
  644. result := _unix_stat(cstr, &s)
  645. if result == -1 {
  646. return s, Errno(get_last_error())
  647. }
  648. return s, ERROR_NONE
  649. }
  650. @private
  651. _lstat :: proc(path: string) -> (OS_Stat, Errno) {
  652. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  653. cstr := strings.clone_to_cstring(path, context.temp_allocator)
  654. s: OS_Stat
  655. result := _unix_lstat(cstr, &s)
  656. if result == -1 {
  657. return s, Errno(get_last_error())
  658. }
  659. return s, ERROR_NONE
  660. }
  661. @private
  662. _fstat :: proc(fd: Handle) -> (OS_Stat, Errno) {
  663. s: OS_Stat
  664. result := _unix_fstat(fd, &s)
  665. if result == -1 {
  666. return s, Errno(get_last_error())
  667. }
  668. return s, ERROR_NONE
  669. }
  670. @private
  671. _fdopendir :: proc(fd: Handle) -> (Dir, Errno) {
  672. dirp := _unix_fdopendir(fd)
  673. if dirp == cast(Dir)nil {
  674. return nil, Errno(get_last_error())
  675. }
  676. return dirp, ERROR_NONE
  677. }
  678. @private
  679. _closedir :: proc(dirp: Dir) -> Errno {
  680. rc := _unix_closedir(dirp)
  681. if rc != 0 {
  682. return Errno(get_last_error())
  683. }
  684. return ERROR_NONE
  685. }
  686. @private
  687. _rewinddir :: proc(dirp: Dir) {
  688. _unix_rewinddir(dirp)
  689. }
  690. @private
  691. _readdir :: proc(dirp: Dir) -> (entry: Dirent, err: Errno, end_of_stream: bool) {
  692. result: ^Dirent
  693. rc := _unix_readdir_r(dirp, &entry, &result)
  694. if rc != 0 {
  695. err = Errno(get_last_error())
  696. return
  697. }
  698. err = ERROR_NONE
  699. if result == nil {
  700. end_of_stream = true
  701. return
  702. }
  703. end_of_stream = false
  704. return
  705. }
  706. @private
  707. _readlink :: proc(path: string) -> (string, Errno) {
  708. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD(ignore = context.temp_allocator == context.allocator)
  709. path_cstr := strings.clone_to_cstring(path, context.temp_allocator)
  710. bufsz : uint = 256
  711. buf := make([]byte, bufsz)
  712. for {
  713. rc := _unix_readlink(path_cstr, &(buf[0]), bufsz)
  714. if rc == -1 {
  715. delete(buf)
  716. return "", Errno(get_last_error())
  717. } else if rc == int(bufsz) {
  718. // NOTE(laleksic, 2021-01-21): Any cleaner way to resize the slice?
  719. bufsz *= 2
  720. delete(buf)
  721. buf = make([]byte, bufsz)
  722. } else {
  723. return strings.string_from_ptr(&buf[0], rc), ERROR_NONE
  724. }
  725. }
  726. }
  727. absolute_path_from_handle :: proc(fd: Handle) -> (string, Errno) {
  728. buf: [DARWIN_MAXPATHLEN]byte
  729. _, err := fcntl(int(fd), F_GETPATH, int(uintptr(&buf[0])))
  730. if err != ERROR_NONE {
  731. return "", err
  732. }
  733. path := strings.clone_from_cstring(cstring(&buf[0]))
  734. return path, err
  735. }
  736. absolute_path_from_relative :: proc(rel: string) -> (path: string, err: Errno) {
  737. rel := rel
  738. if rel == "" {
  739. rel = "."
  740. }
  741. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD(ignore = context.temp_allocator == context.allocator)
  742. rel_cstr := strings.clone_to_cstring(rel, context.temp_allocator)
  743. path_ptr := _unix_realpath(rel_cstr, nil)
  744. if path_ptr == nil {
  745. return "", Errno(get_last_error())
  746. }
  747. defer _unix_free(path_ptr)
  748. path_cstr := transmute(cstring)path_ptr
  749. path = strings.clone( string(path_cstr) )
  750. return path, ERROR_NONE
  751. }
  752. access :: proc(path: string, mask: int) -> bool {
  753. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  754. cstr := strings.clone_to_cstring(path, context.temp_allocator)
  755. return _unix_access(cstr, c.int(mask)) == 0
  756. }
  757. flush :: proc(fd: Handle) -> Errno {
  758. return cast(Errno)_unix_fsync(fd)
  759. }
  760. lookup_env :: proc(key: string, allocator := context.allocator) -> (value: string, found: bool) {
  761. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD(ignore = context.temp_allocator == allocator)
  762. path_str := strings.clone_to_cstring(key, context.temp_allocator)
  763. cstr := _unix_getenv(path_str)
  764. if cstr == nil {
  765. return "", false
  766. }
  767. return strings.clone(string(cstr), allocator), true
  768. }
  769. get_env :: proc(key: string, allocator := context.allocator) -> (value: string) {
  770. value, _ = lookup_env(key, allocator)
  771. return
  772. }
  773. get_current_directory :: proc() -> string {
  774. page_size := get_page_size() // NOTE(tetra): See note in os_linux.odin/get_current_directory.
  775. buf := make([dynamic]u8, page_size)
  776. for {
  777. cwd := _unix_getcwd(cstring(raw_data(buf)), c.size_t(len(buf)))
  778. if cwd != nil {
  779. return string(cwd)
  780. }
  781. if Errno(get_last_error()) != ERANGE {
  782. delete(buf)
  783. return ""
  784. }
  785. resize(&buf, len(buf)+page_size)
  786. }
  787. unreachable()
  788. }
  789. set_current_directory :: proc(path: string) -> (err: Errno) {
  790. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  791. cstr := strings.clone_to_cstring(path, context.temp_allocator)
  792. res := _unix_chdir(cstr)
  793. if res == -1 {
  794. return Errno(get_last_error())
  795. }
  796. return ERROR_NONE
  797. }
  798. make_directory :: proc(path: string, mode: u16 = 0o775) -> Errno {
  799. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  800. path_cstr := strings.clone_to_cstring(path, context.temp_allocator)
  801. res := _unix_mkdir(path_cstr, mode)
  802. if res == -1 {
  803. return Errno(get_last_error())
  804. }
  805. return ERROR_NONE
  806. }
  807. exit :: proc "contextless" (code: int) -> ! {
  808. runtime._cleanup_runtime_contextless()
  809. _unix_exit(i32(code))
  810. }
  811. current_thread_id :: proc "contextless" () -> int {
  812. tid: u64
  813. // NOTE(Oskar): available from OSX 10.6 and iOS 3.2.
  814. // For older versions there is `syscall(SYS_thread_selfid)`, but not really
  815. // the same thing apparently.
  816. foreign pthread { pthread_threadid_np :: proc "c" (rawptr, ^u64) -> c.int --- }
  817. pthread_threadid_np(nil, &tid)
  818. return int(tid)
  819. }
  820. dlopen :: proc(filename: string, flags: int) -> rawptr {
  821. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  822. cstr := strings.clone_to_cstring(filename, context.temp_allocator)
  823. handle := _unix_dlopen(cstr, flags)
  824. return handle
  825. }
  826. dlsym :: proc(handle: rawptr, symbol: string) -> rawptr {
  827. assert(handle != nil)
  828. runtime.DEFAULT_TEMP_ALLOCATOR_TEMP_GUARD()
  829. cstr := strings.clone_to_cstring(symbol, context.temp_allocator)
  830. proc_handle := _unix_dlsym(handle, cstr)
  831. return proc_handle
  832. }
  833. dlclose :: proc(handle: rawptr) -> bool {
  834. assert(handle != nil)
  835. return _unix_dlclose(handle) == 0
  836. }
  837. dlerror :: proc() -> string {
  838. return string(_unix_dlerror())
  839. }
  840. get_page_size :: proc() -> int {
  841. // NOTE(tetra): The page size never changes, so why do anything complicated
  842. // if we don't have to.
  843. @static page_size := -1
  844. if page_size != -1 {
  845. return page_size
  846. }
  847. page_size = int(_unix_getpagesize())
  848. return page_size
  849. }
  850. @(private)
  851. _processor_core_count :: proc() -> int {
  852. count : int = 0
  853. count_size := size_of(count)
  854. if _sysctlbyname("hw.logicalcpu", &count, &count_size, nil, 0) == 0 {
  855. if count > 0 {
  856. return count
  857. }
  858. }
  859. return 1
  860. }
  861. _alloc_command_line_arguments :: proc() -> []string {
  862. res := make([]string, len(runtime.args__))
  863. for _, i in res {
  864. res[i] = string(runtime.args__[i])
  865. }
  866. return res
  867. }
  868. socket :: proc(domain: int, type: int, protocol: int) -> (Socket, Errno) {
  869. result := _unix_socket(domain, type, protocol)
  870. if result < 0 {
  871. return 0, Errno(get_last_error())
  872. }
  873. return Socket(result), ERROR_NONE
  874. }
  875. connect :: proc(sd: Socket, addr: ^SOCKADDR, len: socklen_t) -> (Errno) {
  876. result := _unix_connect(int(sd), addr, len)
  877. if result < 0 {
  878. return Errno(get_last_error())
  879. }
  880. return ERROR_NONE
  881. }
  882. bind :: proc(sd: Socket, addr: ^SOCKADDR, len: socklen_t) -> (Errno) {
  883. result := _unix_bind(int(sd), addr, len)
  884. if result < 0 {
  885. return Errno(get_last_error())
  886. }
  887. return ERROR_NONE
  888. }
  889. accept :: proc(sd: Socket, addr: ^SOCKADDR, len: rawptr) -> (Socket, Errno) {
  890. result := _unix_accept(int(sd), rawptr(addr), len)
  891. if result < 0 {
  892. return 0, Errno(get_last_error())
  893. }
  894. return Socket(result), ERROR_NONE
  895. }
  896. listen :: proc(sd: Socket, backlog: int) -> (Errno) {
  897. result := _unix_listen(int(sd), backlog)
  898. if result < 0 {
  899. return Errno(get_last_error())
  900. }
  901. return ERROR_NONE
  902. }
  903. setsockopt :: proc(sd: Socket, level: int, optname: int, optval: rawptr, optlen: socklen_t) -> (Errno) {
  904. result := _unix_setsockopt(int(sd), level, optname, optval, optlen)
  905. if result < 0 {
  906. return Errno(get_last_error())
  907. }
  908. return ERROR_NONE
  909. }
  910. getsockopt :: proc(sd: Socket, level: int, optname: int, optval: rawptr, optlen: socklen_t) -> Errno {
  911. result := _unix_getsockopt(int(sd), level, optname, optval, optlen)
  912. if result < 0 {
  913. return Errno(get_last_error())
  914. }
  915. return ERROR_NONE
  916. }
  917. recvfrom :: proc(sd: Socket, data: []byte, flags: int, addr: ^SOCKADDR, addr_size: ^socklen_t) -> (u32, Errno) {
  918. result := _unix_recvfrom(int(sd), raw_data(data), len(data), flags, addr, addr_size)
  919. if result < 0 {
  920. return 0, Errno(get_last_error())
  921. }
  922. return u32(result), ERROR_NONE
  923. }
  924. recv :: proc(sd: Socket, data: []byte, flags: int) -> (u32, Errno) {
  925. result := _unix_recv(int(sd), raw_data(data), len(data), flags)
  926. if result < 0 {
  927. return 0, Errno(get_last_error())
  928. }
  929. return u32(result), ERROR_NONE
  930. }
  931. sendto :: proc(sd: Socket, data: []u8, flags: int, addr: ^SOCKADDR, addrlen: socklen_t) -> (u32, Errno) {
  932. result := _unix_sendto(int(sd), raw_data(data), len(data), flags, addr, addrlen)
  933. if result < 0 {
  934. return 0, Errno(get_last_error())
  935. }
  936. return u32(result), ERROR_NONE
  937. }
  938. send :: proc(sd: Socket, data: []byte, flags: int) -> (u32, Errno) {
  939. result := _unix_send(int(sd), raw_data(data), len(data), 0)
  940. if result < 0 {
  941. return 0, Errno(get_last_error())
  942. }
  943. return u32(result), ERROR_NONE
  944. }
  945. shutdown :: proc(sd: Socket, how: int) -> (Errno) {
  946. result := _unix_shutdown(int(sd), how)
  947. if result < 0 {
  948. return Errno(get_last_error())
  949. }
  950. return ERROR_NONE
  951. }
  952. fcntl :: proc(fd: int, cmd: int, arg: int) -> (int, Errno) {
  953. result := _unix__fcntl(Handle(fd), c.int(cmd), uintptr(arg))
  954. if result < 0 {
  955. return 0, Errno(get_last_error())
  956. }
  957. return int(result), ERROR_NONE
  958. }