Update os2 to new io.Stream

core/os/os2/file_stream.odin

@@ -3,17 +3,13 @@ package os2
 import "core:io"
 
 to_stream :: proc(f: ^File) -> (s: io.Stream) {
-	s.stream_data = f
+	s.data = f
-	s.stream_vtable = &_file_stream_vtable
+	s.procedure = _file_stream_proc
 	return
 }
 
-to_writer :: proc(f: ^File) -> (s: io.Writer) {
+to_writer :: to_stream
-	return {to_stream(f)}
+to_reader :: to_stream
-}
-to_reader :: proc(f: ^File) -> (s: io.Reader) {
-	return {to_stream(f)}
-}
 
 
 @(private)
@@ -26,68 +22,52 @@ error_to_io_error :: proc(ferr: Error) -> io.Error {
 
 
 @(private)
-_file_stream_vtable := io.Stream_VTable{
+_file_stream_proc :: proc(stream_data: rawptr, mode: io.Stream_Mode, p: []byte, offset: i64, whence: io.Seek_From) -> (n: i64, err: io.Error) {
-	impl_read = proc(s: io.Stream, p: []byte) -> (n: int, err: io.Error) {
+	f := (^File)(stream_data)
-		f := (^File)(s.stream_data)
+	ferr: Error
-		ferr: Error
+	i: int
-		n, ferr = read(f, p)
+	switch mode {
+	case .Read:
+		i, ferr = read(f, p)
+		n = i64(i)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Read_At:
-	impl_read_at = proc(s: io.Stream, p: []byte, offset: i64) -> (n: int, err: io.Error) {
+		i, ferr = read_at(f, p, offset)
-		f := (^File)(s.stream_data)
+		n = i64(i)
-		ferr: Error
-		n, ferr = read_at(f, p, offset)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Write:
-	impl_write_to = proc(s: io.Stream, w: io.Writer) -> (n: i64, err: io.Error) {
+		i, ferr = write(f, p)
-		f := (^File)(s.stream_data)
+		n = i64(i)
-		ferr: Error
-		n, ferr = write_to(f, w)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Write_At:
-	impl_write = proc(s: io.Stream, p: []byte) -> (n: int, err: io.Error) {
+		i, ferr = write_at(f, p, offset)
-		f := (^File)(s.stream_data)
+		n = i64(i)
-		ferr: Error
-		n, ferr = write(f, p)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Seek:
-	impl_write_at = proc(s: io.Stream, p: []byte, offset: i64) -> (n: int, err: io.Error) {
+		n, ferr = seek(f, offset, Seek_From(whence))
-		f := (^File)(s.stream_data)
-		ferr: Error
-		n, ferr = write_at(f, p, offset)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Size:
-	impl_read_from = proc(s: io.Stream, r: io.Reader) -> (n: i64, err: io.Error) {
+		n, ferr = file_size(f)
-		f := (^File)(s.stream_data)
-		ferr: Error
-		n, ferr = read_from(f, r)
 		err = error_to_io_error(ferr)
 		return
-	},
+	case .Flush:
-	impl_seek = proc(s: io.Stream, offset: i64, whence: io.Seek_From) -> (i64, io.Error) {
+		ferr = flush(f)
-		f := (^File)(s.stream_data)
+		err = error_to_io_error(ferr)
-		n, ferr := seek(f, offset, Seek_From(whence))
+		return
-		err := error_to_io_error(ferr)
+	case .Close:
-		return n, err
+		ferr = close(f)
-	},
+		err = error_to_io_error(ferr)
-	impl_size = proc(s: io.Stream) -> i64 {
+		return
-		f := (^File)(s.stream_data)
+	case .Query:
-		sz, _ := file_size(f)
+		return io.query_utility({.Read, .Read_At, .Write, .Write_At, .Seek, .Size, .Flush, .Close, .Query})
-		return sz
+	case .Destroy:
-	},
+		return 0, .Empty
-	impl_flush = proc(s: io.Stream) -> io.Error {
+	}
-		f := (^File)(s.stream_data)
+	return 0, .Empty
-		ferr := flush(f)
-		return error_to_io_error(ferr)
-	},
-	impl_close = proc(s: io.Stream) -> io.Error {
-		f := (^File)(s.stream_data)
-		ferr := close(f)
-		return error_to_io_error(ferr)
-	},
 }
+

core/os/os2/path_windows.odin

@@ -23,7 +23,7 @@ _mkdir_all :: proc(path: string, perm: File_Mode) -> Error {
 	fix_root_directory :: proc(p: string) -> (s: string, allocated: bool, err: runtime.Allocator_Error) {
 		if len(p) == len(`\\?\c:`) {
 			if is_path_separator(p[0]) && is_path_separator(p[1]) && p[2] == '?' && is_path_separator(p[3]) && p[5] == ':' {
-				s = strings.concatenate_safe({p, `\`}, _file_allocator()) or_return
+				s = strings.concatenate({p, `\`}, _file_allocator()) or_return
 				allocated = true
 				return
 			}