From 567edc1c981a793eab2a4c9b4773a20bd55811d5 Mon Sep 17 00:00:00 2001 From: Pjotr Prins Date: Tue, 25 Dec 2018 08:07:24 +0000 Subject: [PATCH] Added undead.cstream: sambamba strip_bcf_header.d still uses it --- contrib/undead/cstream.d | 249 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 249 insertions(+) create mode 100644 contrib/undead/cstream.d diff --git a/contrib/undead/cstream.d b/contrib/undead/cstream.d new file mode 100644 index 0000000..e20ed7c --- /dev/null +++ b/contrib/undead/cstream.d @@ -0,0 +1,249 @@ +// Written in the D programming language. + +/** + * $(RED Deprecated: This module is considered out-dated and not up to Phobos' + * current standards.) + * + * The std.cstream module bridges core.stdc.stdio (or std.stdio) and std.stream. + * Both core.stdc.stdio and std.stream are publicly imported by std.cstream. + * + * Macros: + * WIKI=Phobos/StdCstream + * + * Copyright: Copyright Ben Hinkle 2007 - 2009. + * License: $(WEB www.boost.org/LICENSE_1_0.txt, Boost License 1.0). + * Authors: Ben Hinkle + * Source: $(PHOBOSSRC std/_cstream.d) + */ +/* Copyright Ben Hinkle 2007 - 2009. + * Distributed under the Boost Software License, Version 1.0. + * (See accompanying file LICENSE_1_0.txt or copy at + * http://www.boost.org/LICENSE_1_0.txt) + */ +module undead.cstream; + +public import core.stdc.stdio; +public import undead.stream; +version(unittest) import std.stdio; + +import std.algorithm; + +/** + * A Stream wrapper for a C file of type FILE*. + */ +class CFile : Stream { + protected FILE* cfile; + + /** + * Create the stream wrapper for the given C file. + * Params: + * cfile = a valid C $(B FILE) pointer to wrap. + * mode = a bitwise combination of $(B FileMode.In) for a readable file + * and $(B FileMode.Out) for a writeable file. + * seekable = indicates if the stream should be _seekable. + */ + this(FILE* cfile, FileMode mode, bool seekable = false) { + super(); + this.file = cfile; + readable = cast(bool)(mode & FileMode.In); + writeable = cast(bool)(mode & FileMode.Out); + this.seekable = seekable; + } + + /** + * Closes the stream. + */ + ~this() { close(); } + + /** + * Property to get or set the underlying file for this stream. + * Setting the file marks the stream as open. + */ + @property FILE* file() { return cfile; } + + /** + * Ditto + */ + @property void file(FILE* cfile) { + this.cfile = cfile; + isopen = true; + } + + /** + * Overrides of the $(B Stream) methods to call the underlying $(B FILE*) + * C functions. + */ + override void flush() { fflush(cfile); } + + /** + * Ditto + */ + override void close() { + if (isopen) + fclose(cfile); + isopen = readable = writeable = seekable = false; + } + + /** + * Ditto + */ + override bool eof() { + return cast(bool)(readEOF || feof(cfile)); + } + + /** + * Ditto + */ + override char getc() { + return cast(char)fgetc(cfile); + } + + /** + * Ditto + */ + override char ungetc(char c) { + return cast(char)core.stdc.stdio.ungetc(c,cfile); + } + + /** + * Ditto + */ + override size_t readBlock(void* buffer, size_t size) { + size_t n = fread(buffer,1,size,cfile); + readEOF = cast(bool)(n == 0); + return n; + } + + /** + * Ditto + */ + override size_t writeBlock(const void* buffer, size_t size) { + return fwrite(buffer,1,size,cfile); + } + + /** + * Ditto + */ + override ulong seek(long offset, SeekPos rel) { + readEOF = false; + if (fseek(cfile,cast(int)offset,rel) != 0) + throw new SeekException("unable to move file pointer"); + return ftell(cfile); + } + + /** + * Ditto + */ + override void writeLine(const(char)[] s) { + writeString(s); + writeString("\n"); + } + + /** + * Ditto + */ + override void writeLineW(const(wchar)[] s) { + writeStringW(s); + writeStringW("\n"); + } + + // run a few tests + unittest { + import undead.internal.file; + import std.internal.cstring : tempCString; + + auto stream_file = (undead.internal.file.deleteme ~ "-stream.txt").tempCString(); + FILE* f = fopen(stream_file,"w"); + assert(f !is null); + CFile file = new CFile(f,FileMode.Out); + int i = 666; + // should be ok to write + assert(file.writeable); + file.writeLine("Testing stream.d:"); + file.writeString("Hello, world!"); + file.write(i); + // string#1 + string#2 + int should give exacly that + version (Windows) + assert(file.position == 19 + 13 + 4); + version (Posix) + assert(file.position == 18 + 13 + 4); + file.close(); + // no operations are allowed when file is closed + assert(!file.readable && !file.writeable && !file.seekable); + f = fopen(stream_file,"r"); + file = new CFile(f,FileMode.In,true); + // should be ok to read + assert(file.readable); + auto line = file.readLine(); + auto exp = "Testing stream.d:"; + assert(line[0] == 'T'); + assert(line.length == exp.length); + assert(!std.algorithm.cmp(line, "Testing stream.d:")); + // jump over "Hello, " + file.seek(7, SeekPos.Current); + version (Windows) + assert(file.position == 19 + 7); + version (Posix) + assert(file.position == 18 + 7); + assert(!std.algorithm.cmp(file.readString(6), "world!")); + i = 0; file.read(i); + assert(i == 666); + // string#1 + string#2 + int should give exacly that + version (Windows) + assert(file.position == 19 + 13 + 4); + version (Posix) + assert(file.position == 18 + 13 + 4); + // we must be at the end of file + file.close(); + f = fopen(stream_file,"w+"); + file = new CFile(f,FileMode.In|FileMode.Out,true); + file.writeLine("Testing stream.d:"); + file.writeLine("Another line"); + file.writeLine(""); + file.writeLine("That was blank"); + file.position = 0; + char[][] lines; + foreach(char[] line; file) { + lines ~= line.dup; + } + assert( lines.length == 5 ); + assert( lines[0] == "Testing stream.d:"); + assert( lines[1] == "Another line"); + assert( lines[2] == ""); + assert( lines[3] == "That was blank"); + file.position = 0; + lines = new char[][5]; + foreach(ulong n, char[] line; file) { + lines[cast(size_t)(n-1)] = line.dup; + } + assert( lines[0] == "Testing stream.d:"); + assert( lines[1] == "Another line"); + assert( lines[2] == ""); + assert( lines[3] == "That was blank"); + file.close(); + remove(stream_file); + } +} + +/** + * CFile wrapper of core.stdc.stdio.stdin (not seekable). + */ +__gshared CFile din; + +/** + * CFile wrapper of core.stdc.stdio.stdout (not seekable). + */ +__gshared CFile dout; + +/** + * CFile wrapper of core.stdc.stdio.stderr (not seekable). + */ +__gshared CFile derr; + +shared static this() { + // open standard I/O devices + din = new CFile(core.stdc.stdio.stdin,FileMode.In); + dout = new CFile(core.stdc.stdio.stdout,FileMode.Out); + derr = new CFile(core.stdc.stdio.stderr,FileMode.Out); +} +