file_util.odin 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. package os2
  2. import "base:runtime"
  3. import "core:strconv"
  4. import "core:unicode/utf8"
  5. write_string :: proc(f: ^File, s: string) -> (n: int, err: Error) {
  6. return write(f, transmute([]byte)s)
  7. }
  8. write_strings :: proc(f: ^File, strings: ..string) -> (n: int, err: Error) {
  9. for s in strings {
  10. m: int
  11. m, err = write_string(f, s)
  12. n += m
  13. if err != nil {
  14. return
  15. }
  16. }
  17. return
  18. }
  19. write_byte :: proc(f: ^File, b: byte) -> (n: int, err: Error) {
  20. return write(f, []byte{b})
  21. }
  22. write_rune :: proc(f: ^File, r: rune) -> (n: int, err: Error) {
  23. if r < utf8.RUNE_SELF {
  24. return write_byte(f, byte(r))
  25. }
  26. b: [4]byte
  27. b, n = utf8.encode_rune(r)
  28. return write(f, b[:n])
  29. }
  30. write_encoded_rune :: proc(f: ^File, r: rune) -> (n: int, err: Error) {
  31. wrap :: proc(m: int, merr: Error, n: ^int, err: ^Error) -> bool {
  32. n^ += m
  33. if merr != nil {
  34. err^ = merr
  35. return true
  36. }
  37. return false
  38. }
  39. if wrap(write_byte(f, '\''), &n, &err) { return }
  40. switch r {
  41. case '\a': if wrap(write_string(f, "\\a"), &n, &err) { return }
  42. case '\b': if wrap(write_string(f, "\\b"), &n, &err) { return }
  43. case '\e': if wrap(write_string(f, "\\e"), &n, &err) { return }
  44. case '\f': if wrap(write_string(f, "\\f"), &n, &err) { return }
  45. case '\n': if wrap(write_string(f, "\\n"), &n, &err) { return }
  46. case '\r': if wrap(write_string(f, "\\r"), &n, &err) { return }
  47. case '\t': if wrap(write_string(f, "\\t"), &n, &err) { return }
  48. case '\v': if wrap(write_string(f, "\\v"), &n, &err) { return }
  49. case:
  50. if r < 32 {
  51. if wrap(write_string(f, "\\x"), &n, &err) { return }
  52. b: [2]byte
  53. s := strconv.append_bits(b[:], u64(r), 16, true, 64, strconv.digits, nil)
  54. switch len(s) {
  55. case 0: if wrap(write_string(f, "00"), &n, &err) { return }
  56. case 1: if wrap(write_rune(f, '0'), &n, &err) { return }
  57. case 2: if wrap(write_string(f, s), &n, &err) { return }
  58. }
  59. } else {
  60. if wrap(write_rune(f, r), &n, &err) { return }
  61. }
  62. }
  63. _ = wrap(write_byte(f, '\''), &n, &err)
  64. return
  65. }
  66. write_ptr :: proc(f: ^File, data: rawptr, len: int) -> (n: int, err: Error) {
  67. return write(f, ([^]byte)(data)[:len])
  68. }
  69. read_ptr :: proc(f: ^File, data: rawptr, len: int) -> (n: int, err: Error) {
  70. return read(f, ([^]byte)(data)[:len])
  71. }
  72. read_entire_file :: proc{
  73. read_entire_file_from_path,
  74. read_entire_file_from_file,
  75. }
  76. @(require_results)
  77. read_entire_file_from_path :: proc(name: string, allocator: runtime.Allocator) -> (data: []byte, err: Error) {
  78. f, ferr := open(name)
  79. if ferr != nil {
  80. return nil, ferr
  81. }
  82. defer close(f)
  83. return read_entire_file_from_file(f, allocator)
  84. }
  85. @(require_results)
  86. read_entire_file_from_file :: proc(f: ^File, allocator: runtime.Allocator) -> (data: []byte, err: Error) {
  87. size: int
  88. has_size := true
  89. if size64, serr := file_size(f); serr == nil {
  90. if i64(int(size64)) != size64 {
  91. size = int(size64)
  92. }
  93. } else if serr == .No_Size {
  94. has_size = false
  95. } else {
  96. return
  97. }
  98. size += 1 // for EOF
  99. // TODO(bill): Is this correct logic?
  100. if has_size {
  101. total: int
  102. data = make([]byte, size, allocator) or_return
  103. for {
  104. n: int
  105. n, err = read(f, data[total:])
  106. total += n
  107. if err != nil {
  108. if err == .EOF {
  109. err = nil
  110. }
  111. data = data[:total]
  112. return
  113. }
  114. }
  115. } else {
  116. buffer: [1024]u8
  117. out_buffer := make([dynamic]u8, 0, 0, allocator)
  118. total := 0
  119. for {
  120. n: int = ---
  121. n, err = read(f, buffer[:])
  122. total += n
  123. append_elems(&out_buffer, ..buffer[:total])
  124. if err != nil {
  125. if err == .EOF || err == .Broken_Pipe {
  126. err = nil
  127. }
  128. data = out_buffer[:total]
  129. return
  130. }
  131. }
  132. }
  133. }
  134. @(require_results)
  135. write_entire_file :: proc(name: string, data: []byte, perm: int, truncate := true) -> Error {
  136. flags := O_WRONLY|O_CREATE
  137. if truncate {
  138. flags |= O_TRUNC
  139. }
  140. f, err := open(name, flags, perm)
  141. if err != nil {
  142. return err
  143. }
  144. _, err = write(f, data)
  145. if cerr := close(f); cerr != nil && err == nil {
  146. err = cerr
  147. }
  148. return err
  149. }