initial import of the C runtime

1 files changed, 166 insertions, 0 deletions

diff --git a/src/runtime/c/gu/out.h b/src/runtime/c/gu/out.h
new file mode 100644
index 000000000..df2638c72
--- /dev/null
+++ b/src/runtime/c/gu/out.h
@@ -0,0 +1,166 @@
+#ifndef GU_OUT_H_
+#define GU_OUT_H_
+
+#include <gu/defs.h>
+#include <gu/assert.h>
+#include <gu/exn.h>
+
+typedef struct GuOut GuOut;
+
+typedef struct GuOutStream GuOutStream;
+
+struct GuOutStream {
+	uint8_t* (*begin_buf)(GuOutStream* self, size_t req, size_t* sz_out,
+			      GuExn* err);
+	void (*end_buf)(GuOutStream* self, size_t span, GuExn* err);
+	size_t (*output)(GuOutStream* self, const uint8_t* buf, size_t size,
+			 GuExn* err);
+	void (*flush)(GuOutStream* self, GuExn* err);
+};
+
+
+struct GuOut {
+	uint8_t* restrict buf_end;
+	ptrdiff_t buf_curr;
+	size_t buf_size;
+	GuOutStream* stream;
+	GuFinalizer fini;
+};
+
+
+GuOut
+gu_init_out(GuOutStream* stream);
+
+GuOut*
+gu_new_out(GuOutStream* stream, GuPool* pool);
+
+inline bool
+gu_out_is_buffered(GuOut* out)
+{
+	return !!out->stream->begin_buf;
+}
+
+GuOutStream*
+gu_out_proxy_stream(GuOut* out, GuPool* pool);
+
+GuOut*
+gu_new_buffered_out(GuOut* out, size_t buf_sz, GuPool* pool);
+
+GuOut*
+gu_out_buffered(GuOut* out, GuPool* pool);
+
+uint8_t*
+gu_out_begin_span(GuOut* out, size_t req, size_t* sz_out, GuExn* err);
+
+uint8_t*
+gu_out_force_span(GuOut* out, size_t min, size_t max, size_t* sz_out,
+		  GuExn* err);
+
+void
+gu_out_end_span(GuOut* out, size_t sz);
+
+size_t
+gu_out_bytes_(GuOut* restrict out, const uint8_t* restrict src, 
+	      size_t len, GuExn* err);
+
+inline bool
+gu_out_try_buf_(GuOut* restrict out, const uint8_t* restrict src, size_t len)
+{
+	gu_require(len <= PTRDIFF_MAX);
+	ptrdiff_t curr = out->buf_curr;
+	ptrdiff_t new_curr = curr + (ptrdiff_t) len;
+	if (GU_UNLIKELY(new_curr > 0)) {
+		return false;
+	}
+	memcpy(&out->buf_end[curr], src, len);
+	out->buf_curr = new_curr;
+	return true;
+}
+
+inline size_t
+gu_out_bytes(GuOut* restrict out, const uint8_t* restrict src, size_t len, 
+	     GuExn* err)
+{
+	if (GU_LIKELY(gu_out_try_buf_(out, src, len))) {
+		return len;
+	}
+	return gu_out_bytes_(out, src, len, err);
+}
+
+void
+gu_out_flush(GuOut* out, GuExn* err);
+
+inline bool
+gu_out_try_u8_(GuOut* restrict out, uint8_t u)
+{
+	ptrdiff_t curr = out->buf_curr;
+	ptrdiff_t new_curr = curr + 1;
+	if (GU_UNLIKELY(new_curr > 0)) {
+		return false;
+	}
+	out->buf_end[curr] = u;
+	out->buf_curr = new_curr;
+	return true;
+}
+
+inline void
+gu_out_u8(GuOut* restrict out, uint8_t u, GuExn* err)
+{
+	if (GU_UNLIKELY(!gu_out_try_u8_(out, u))) {
+		extern void gu_out_u8_(GuOut* restrict out, uint8_t u, 
+				       GuExn* err);
+		gu_out_u8_(out, u, err);
+	}
+}
+
+inline void
+gu_out_s8(GuOut* restrict out, int8_t i, GuExn* err)
+{
+	gu_out_u8(out, (uint8_t) i, err);
+}
+
+
+
+void
+gu_out_u16le(GuOut* out, uint16_t u, GuExn* err);
+
+void
+gu_out_u16be(GuOut* out, uint16_t u, GuExn* err);
+
+void
+gu_out_s16le(GuOut* out, int16_t u, GuExn* err);
+
+void
+gu_out_s16be(GuOut* out, int16_t u, GuExn* err);
+
+void
+gu_out_u32le(GuOut* out, uint32_t u, GuExn* err);
+
+void
+gu_out_u32be(GuOut* out, uint32_t u, GuExn* err);
+
+void
+gu_out_s32le(GuOut* out, int32_t u, GuExn* err);
+
+void
+gu_out_s32be(GuOut* out, int32_t u, GuExn* err);
+
+void
+gu_out_u64le(GuOut* out, uint64_t u, GuExn* err);
+
+void
+gu_out_u64be(GuOut* out, uint64_t u, GuExn* err);
+
+void
+gu_out_s64le(GuOut* out, int64_t u, GuExn* err);
+
+void
+gu_out_s64be(GuOut* out, int64_t u, GuExn* err);
+
+void
+gu_out_f64le(GuOut* out, double d, GuExn* err);
+
+void
+gu_out_f64be(GuOut* out, double d, GuExn* err);
+
+#endif // GU_OUT_H_