initial import of the C runtime

1 files changed, 270 insertions, 0 deletions

diff --git a/src/runtime/c/gu/string.c b/src/runtime/c/gu/string.c
new file mode 100644
index 000000000..b24eeeb06
--- /dev/null
+++ b/src/runtime/c/gu/string.c
@@ -0,0 +1,270 @@
+#include <gu/type.h>
+#include <gu/out.h>
+#include <gu/seq.h>
+#include <gu/map.h>
+#include <gu/string.h>
+#include <gu/utf8.h>
+#include <gu/assert.h>
+#include "config.h"
+
+const GuString gu_empty_string = { 1 };
+
+struct GuStringBuf {
+	GuByteBuf* bbuf;
+	GuWriter* wtr;
+};
+
+GuStringBuf*
+gu_string_buf(GuPool* pool)
+{
+	GuBuf* buf = gu_new_buf(uint8_t, pool);
+	GuOut* out = gu_buf_out(buf, pool);
+	GuWriter* wtr = gu_new_utf8_writer(out, pool);
+	return gu_new_s(pool, GuStringBuf,
+			.bbuf = buf,
+			.wtr = wtr);
+}
+
+GuWriter*
+gu_string_buf_writer(GuStringBuf* sb)
+{
+	return sb->wtr;
+}
+
+static GuString
+gu_utf8_string(const uint8_t* buf, size_t sz, GuPool* pool)
+{
+	if (sz < GU_MIN(sizeof(GuWord), 128)) {
+		GuWord w = 0;
+		for (size_t n = 0; n < sz; n++) {
+			w = w << 8 | buf[n];
+		}
+		w = w << 8 | (sz << 1) | 1;
+		return (GuString) { w };
+	}
+	uint8_t* p = NULL;
+	if (sz < 256) {
+		p = gu_malloc_aligned(pool, 1 + sz, 2);
+		p[0] = (uint8_t) sz;
+	} else {
+		uint8_t* p =
+			gu_malloc_prefixed(pool, gu_alignof(size_t),
+					   sizeof(size_t), 1, 1 + sizeof(sz));
+		((size_t*) p)[-1] = sz;
+		p[0] = 0;
+	}
+	memcpy(&p[1], buf, sz);
+	return (GuString) { (GuWord) (void*) p };
+}
+
+
+
+GuString
+gu_string_buf_freeze(GuStringBuf* sb, GuPool* pool)
+{
+	gu_writer_flush(sb->wtr, NULL);
+	uint8_t* data = gu_buf_data(sb->bbuf);
+	size_t len = gu_buf_length(sb->bbuf);
+	return gu_utf8_string(data, len, pool);
+}
+
+GuReader*
+gu_string_reader(GuString s, GuPool* pool)
+{
+	GuWord w = s.w_;
+	uint8_t* buf = NULL;
+	size_t len = 0;
+	if (w & 1) {
+		len = (w & 0xff) >> 1;
+		buf = gu_new_n(uint8_t, len, pool);
+		for (int i = len - 1; i >= 0; i--) {
+			w >>= 8;
+			buf[i] = w & 0xff;
+		}
+	} else {
+		uint8_t* p = (void*) w;
+		len = (p[0] == 0) ? ((size_t*) p)[-1] : p[0];
+		buf = &p[1];
+	}
+	GuIn* in = gu_data_in(buf, len, pool);
+	GuReader* rdr = gu_new_utf8_reader(in, pool);
+	return rdr;
+}
+
+static bool
+gu_string_is_long(GuString s) 
+{
+	return !(s.w_ & 1);
+}
+
+bool
+gu_string_is_stable(GuString s)
+{
+	return !gu_string_is_long(s);
+}
+
+static size_t
+gu_string_long_length(GuString s)
+{
+	gu_assert(gu_string_is_long(s));
+	uint8_t* p = (void*) s.w_;
+	uint8_t len = p[0];
+	if (len > 0) {
+		return len;
+	}
+	return ((size_t*) p)[-1];
+}
+
+size_t
+gu_string_length(GuString s)
+{
+	if (gu_string_is_long(s)) {
+		return gu_string_long_length(s);
+	}
+	return (s.w_ & 0xff) >> 1;
+}
+
+static uint8_t*
+gu_string_long_data(GuString s)
+{
+	gu_require(gu_string_is_long(s));
+	uint8_t* p = (void*) s.w_;
+	return &p[1];
+}
+
+GuString
+gu_string_copy(GuString string, GuPool* pool)
+{
+	if (gu_string_is_long(string)) {
+		uint8_t* data = gu_string_long_data(string);
+		size_t len = gu_string_long_length(string);
+		return gu_utf8_string(data, len, pool);
+	} else {
+		return string;
+	}
+}
+
+
+void
+gu_string_write(GuString s, GuWriter* wtr, GuExn* err)
+{
+	GuWord w = s.w_;
+	uint8_t buf[sizeof(GuWord)];
+	uint8_t* src;
+	size_t sz;
+	if (w & 1) {
+		sz = (w & 0xff) >> 1;
+		gu_assert(sz <= sizeof(GuWord));
+		size_t i = sz;
+		while (i > 0) {
+			w >>= 8;
+			buf[--i] = w & 0xff;
+		}
+		src = buf;
+	} else {
+		uint8_t* p = (void*) w;
+		sz = (p[0] == 0) ? ((size_t*) p)[-1] : p[0];
+		src = &p[1];
+	}
+	gu_utf8_write(src, sz, wtr, err);
+}
+
+GuString
+gu_format_string_v(const char* fmt, va_list args, GuPool* pool)
+{
+	GuPool* tmp_pool = gu_local_pool();
+	GuStringBuf* sb = gu_string_buf(tmp_pool);
+	GuWriter* wtr = gu_string_buf_writer(sb);
+	gu_vprintf(fmt, args, wtr, NULL);
+	gu_writer_flush(wtr, NULL);
+	GuString s = gu_string_buf_freeze(sb, pool);
+	gu_pool_free(tmp_pool);
+	return s;
+}
+
+GuString
+gu_format_string(GuPool* pool, const char* fmt, ...)
+{
+	va_list args;
+	va_start(args, fmt);
+	GuString s = gu_format_string_v(fmt, args, pool);
+	va_end(args);
+	return s;
+}
+
+GuString
+gu_str_string(const char* str, GuPool* pool)
+{
+#ifdef GU_CHAR_ASCII
+	return gu_utf8_string((const uint8_t*) str, strlen(str), pool);
+#else
+	GuPool* tmp_pool = gu_local_pool();
+	GuStringBuf* sb = gu_string_buf(tmp_pool);
+	GuWriter* wtr = gu_string_buf_writer(sb);
+	gu_puts(str, wtr, NULL);
+	gu_writer_flush(wtr, NULL);
+	GuString s = gu_string_buf_freeze(sb, pool);
+	gu_pool_free(tmp_pool);
+	return s;
+#endif
+}
+
+GuWord
+gu_string_hash(GuString s)
+{
+	if (s.w_ & 1) {
+		return s.w_;
+	}
+	size_t len = gu_string_length(s);
+	uint8_t* data = gu_string_long_data(s);
+	return gu_hash_bytes(0, data, len);
+}
+
+bool
+gu_string_eq(GuString s1, GuString s2)
+{
+	if (s1.w_ == s2.w_) {
+		return true;
+	} else if (gu_string_is_long(s1) && gu_string_is_long(s2)) {
+		size_t len1 = gu_string_long_length(s1);
+		size_t len2 = gu_string_long_length(s2);
+		if (len1 != len2) {
+			return false;
+		}
+		uint8_t* data1 = gu_string_long_data(s1);
+		uint8_t* data2 = gu_string_long_data(s2);
+		return (memcmp(data1, data2, len1) == 0);
+	}
+	return false;
+
+}
+
+
+static GuHash
+gu_string_hasher_hash(GuHasher* self, const void* p)
+{
+	(void) self;
+	const GuString* sp = p;
+	return gu_string_hash(*sp);
+}
+
+static bool
+gu_string_eq_fn(GuEquality* self, const void* p1, const void* p2)
+{
+	(void) self;
+	const GuString* sp1 = p1;
+	const GuString* sp2 = p2;
+	return gu_string_eq(*sp1, *sp2);
+}
+
+GuHasher gu_string_hasher[1] = {
+	{
+		.eq = { gu_string_eq_fn },
+		.hash = gu_string_hasher_hash
+	}
+};
+
+
+GU_DEFINE_TYPE(GuString, GuOpaque, _);
+GU_DEFINE_TYPE(GuStrings, GuSeq, gu_type(GuString));
+GU_DEFINE_KIND(GuStringMap, GuMap);