4 local h = io.open("types.h", "w")
5 local c = io.open("types.c", "w")
6 local def = io.open("types.def", "r")
8 local function emit_h(str)
12 local function emit_c(str)
16 local function emit(fun, code)
18 emit_c(fun .. "\n" .. code)
22 local export_prefix = ""
23 local local_prefix = "__attribute__((unused)) static inline "
29 This file was automatically generated by Dragontype.
30 DO NOT EDIT it manually. Instead, edit types.def and re-run dragontype typegen.
37 #ifndef _DRAGONTYPE_TYPES_H_
38 #define _DRAGONTYPE_TYPES_H_
41 #include <dragonnet/peer.h>
61 #include <dragonnet/send.h>
62 #include <dragonnet/recv.h>
65 #include <endian.h/endian.h>
77 ]] .. local_prefix .. [[void raw_write(Blob *buffer, const void *data, size_t len)
79 buffer->data = realloc(buffer->data, len + buffer->siz);
80 memcpy(&buffer->data[buffer->siz], data, len);
84 ]] .. local_prefix .. [[bool raw_read(Blob *buffer, void *data, size_t len)
89 if (buffer->siz < len) {
90 fprintf(stderr, "warning: buffer exhausted (requested bytes: %lu, remaining bytes: %lu)\n", len, buffer->siz);
94 memcpy(data, buffer->data, len);
104 local existing_types = {}
105 local has_deallocator = {}
109 local base_vector_components = {"x", "y", "z", "w"}
110 local vector_components = {}
113 local components = {}
116 table.insert(components, base_vector_components[j])
119 vector_components[i] = components
124 local function emit_vector(type, l)
125 local name = "v" .. l .. type
126 local box = "aabb" .. l .. type
128 existing_types[name] = true
129 has_deallocator[name] = false
131 local typedef, equals, add, clamp, mix, write, read, send, recv =
132 "", "", "", "", "", "", "", "", ""
134 typedef = typedef .. "\t" .. type .. " "
135 equals = equals .. "\treturn "
136 add = add .. "\treturn (" .. name .. ") {"
137 clamp = clamp .. "\treturn (" .. name .. ") {"
138 mix = mix .. "\treturn (" .. name .. ") {"
140 for i, c in ipairs(vector_components[l]) do
151 .. "a." .. c .. " == "
159 .. "a." .. c .. " + "
168 .. "val." .. c .. ", "
169 .. "min." .. c .. ", "
170 .. "max." .. c .. ")" ..
187 .. "\t" .. type .. "_write(buffer, &val->" .. c .. ");\n"
190 .. "\tif (! " .. type .. "_read(buffer, &val->" .. c .. "))\n\t\treturn false;\n"
193 .. "\tif (! " .. type .. "_send(peer, " .. (last and "submit" or "false") .. ", &val->" .. c .. "))\n\t\treturn false;\n"
196 .. "\tif (! " .. type .. "_recv(peer, &val->" .. c .. "))\n\t\treturn false;\n"
199 emit_h("typedef struct {\n" .. typedef .. "} " .. name .. ";\n")
201 emit(export_prefix .. "bool " .. name .. "_equals(" .. name .. " a, " .. name .. " b)", "{\n" .. equals .. "}\n\n")
202 emit(export_prefix .. name .. " " .. name .. "_add(" .. name .. " a, " .. name .. " b)", "{\n" .. add .. "}\n\n")
203 emit(export_prefix .. name .. " " .. name .. "_clamp(" .. name .. " val, " .. name .. " min, " .. name .. " max)", "{\n" .. clamp .. "}\n\n")
205 if type:sub(1, 1) == "f" then
206 emit(export_prefix .. name .. " " .. name .. "_mix(" .. name .. " a, " .. name .. " b, " .. type .. " f)", "{\n" .. mix .. "}\n\n")
209 emit(export_prefix .. "void " .. name .. "_write(Blob *buffer, " .. name .. " *val)", "{\n" .. write .. "}\n\n")
210 emit(export_prefix .. "bool " .. name .. "_read(Blob *buffer, " .. name .. " *val)", "{\n" .. read .. "\treturn true;\n}\n\n")
212 emit_c("#ifdef USE_DRAGONNET\n")
213 emit_c(local_prefix .. "bool " .. name .. "_send(DragonnetPeer *peer, bool submit, " .. name .. " *val)\n{\n" .. send .. "\treturn true;\n}\n\n")
214 emit_c(local_prefix .. "bool " .. name .. "_recv(DragonnetPeer *peer, " .. name .. " *val)\n{\n" .. recv .. "\treturn true;\n}\n")
219 emit_h("typedef struct {\n\t" .. name .. " min, max;\n} " .. box .. ";\n")
221 emit(export_prefix .. "void " .. box .. "_write(Blob *buffer, " .. box .. " *val)", "{\n\t" .. name .. "_write(buffer, &val->min);\n\t" .. name .. "_write(buffer, &val->max);\n}\n\n")
222 emit(export_prefix .. "bool " .. box .. "_read(Blob *buffer, " .. box .. " *val)", "{\n\tif (! " .. name .. "_read(buffer, &val->min))\n\t\treturn false;\n\tif (! " .. name .. "_read(buffer, &val->max))\n\t\treturn false;\n\treturn true;\n}\n\n")
224 emit_c("#ifdef USE_DRAGONNET\n")
225 emit_c(local_prefix .. "bool " .. box .. "_send(DragonnetPeer *peer, bool submit, " .. box .. " *val)\n{\n\tif (! " .. name .. "_send(peer, false, &val->min))\n\t\treturn false;\n\tif (! " .. name .. "_send(peer, submit, &val->max))\n\t\treturn false;\n\treturn true;\n}\n\n")
226 emit_c(local_prefix .. "bool " .. box .. "_recv(DragonnetPeer *peer, " .. box .. " *val)\n{\n\tif (! " .. name .. "_recv(peer, &val->min))\n\t\treturn false;\n\t if (! " .. name .. "_recv(peer, &val->max))\n\t\treturn false;\n\treturn true;\n}\n")
232 local function emit_numeric(class, bits, alias)
233 local name = class .. bits
235 existing_types[name] = true
236 has_deallocator[name] = false
238 emit_h("typedef " .. alias .. " " .. name .. ";\n")
240 emit(export_prefix .. name .. " " .. name .. "_min(" .. name .. " a, " .. name .. " b)", "{\n\treturn a < b ? a : b;\n}\n\n")
241 emit(export_prefix .. name .. " " .. name .. "_max(" .. name .. " a, " .. name .. " b)", "{\n\treturn a > b ? a : b;\n}\n\n")
242 emit(export_prefix .. name .. " " .. name .. "_clamp(" .. name .. " val, " .. name .. " min, " .. name .. " max)", "{\n\treturn val < min ? min : val > max ? max : val;\n}\n\n")
245 emit(export_prefix .. name .. " " .. name .. "_mix(" .. name .. " a, " .. name .. " b, " .. name .. " f)", "{\n\treturn (1.0 - f) * a + b * f;\n}\n\n")
248 emit(export_prefix .. "void " .. name .. "_write(Blob *buffer, " .. name .. " *val)", "{\n" .. (class == "u"
249 and "\t" .. name .. " be = htobe" .. bits .. "(*val);\n\traw_write(buffer, &be, sizeof be);\n"
250 or "\tu" .. bits .. "_write(buffer, (u" .. bits .. " *) val);\n"
252 emit(export_prefix .. "bool " .. name .. "_read(Blob *buffer, " .. name .. " *val)", "{\n" .. (class == "u"
253 and "\t" .. name .. " be;\n\tif (! raw_read(buffer, &be, sizeof be))\n\t\treturn false;\n\t*val = be" .. bits .. "toh(be);\n\treturn true;\n"
254 or "\treturn u" .. bits .. "_read(buffer, (u" .. bits .. " *) val);\n"
257 emit_c("#ifdef USE_DRAGONNET\n")
258 emit_c(local_prefix .. "bool " .. name .. "_send(DragonnetPeer *peer, bool submit, " .. name .. " *val)\n{\n" .. (class == "u"
259 and "\t" .. name .. " be = htobe" .. bits .. "(*val);\n\treturn dragonnet_send_raw(peer, submit, &be, sizeof be);\n"
260 or "\treturn u" .. bits .. "_send(peer, submit, (u" .. bits .. " *) val);\n"
262 emit_c(local_prefix .. "bool " .. name .. "_recv(DragonnetPeer *peer, " .. name .. " *val)\n{\n" .. (class == "u"
263 and "\t" .. name .. " be;\n\tif (! dragonnet_recv_raw(peer, &be, sizeof be))\n\t\treturn false;\n\t*val = be" .. bits .. "toh(be);\n\treturn true;\n"
264 or "\treturn u" .. bits .. "_recv(peer, (u" .. bits .. " *) val);\n"
276 local bytes = math.floor(2 ^ i)
277 local bits = 8 * bytes
279 emit_numeric("u", bits, "uint" .. bits .. "_t")
280 emit_numeric("s", bits, "int" .. bits .. "_t")
283 emit_numeric("f", bits, ({"float", "double"})[i - 1])
289 existing_types.String = true
290 has_deallocator.String = true
293 export_prefix .. "void String_free(String *val)", [[
303 export_prefix .. "void String_write(Blob *buffer, String *val)", [[
305 raw_write(buffer, *val, strlen(*val) + 1);
312 export_prefix .. "bool String_read(Blob *buffer, String *val)", [[
314 String v = malloc(1 + (1 << 16));
317 for (u16 i = 0;; i++) {
318 if (! raw_read(buffer, &c, 1)) {
328 *val = realloc(v, strlen(v) + 1);
339 ]] .. local_prefix .. [[bool String_send(DragonnetPeer *peer, bool submit, String *val)
341 return dragonnet_send_raw(peer, submit, *val, strlen(*val) + 1);
344 ]] .. local_prefix .. [[bool String_recv(DragonnetPeer *peer, String *val)
346 String v = malloc(1 + (1 << 16));
349 for (u16 i = 0;; i++) {
350 if (! dragonnet_recv_raw(peer, &c, 1)) {
360 *val = realloc(v, strlen(v) + 1);
373 existing_types.Blob = true
374 has_deallocator.Blob = true
377 export_prefix .. "void Blob_compress(Blob *buffer, Blob *val)", [[
379 buffer->siz = 8 + 2 + val->siz;
380 buffer->data = malloc(buffer->siz);
382 *(u64 *) buffer->data = val->siz;
389 s.avail_in = val->siz;
390 s.next_in = (Bytef *) val->data;
391 s.avail_out = buffer->siz - 8 + 1;
392 s.next_out = (Bytef *) buffer->data + 8;
394 deflateInit(&s, Z_BEST_COMPRESSION);
395 deflate(&s, Z_FINISH);
398 buffer->siz = s.total_out + 8;
405 export_prefix .. "void Blob_decompress(Blob *buffer, Blob *val)", [[
407 buffer->siz = *(u64 *) val->data;
408 buffer->data = malloc(buffer->siz);
415 s.avail_in = val->siz - 8;
416 s.next_in = val->data + 8;
417 s.avail_out = buffer->siz;
418 s.next_out = (Bytef *) buffer->data;
421 inflate(&s, Z_NO_FLUSH);
424 buffer->siz = s.total_out;
431 export_prefix .. "void Blob_shrink(Blob *val)", [[
433 val->data = realloc(val->data, val->siz);
440 export_prefix .. "void Blob_free(Blob *val)", [[
450 export_prefix .. "void Blob_write(Blob *buffer, Blob *val)", [[
452 u64_write(buffer, &val->siz);
453 raw_write(buffer, val->data, val->siz);
460 export_prefix .. "bool Blob_read(Blob *buffer, Blob *val)", [[
462 if (! u64_read(buffer, &val->siz))
465 if (! raw_read(buffer, val->data = malloc(val->siz), val->siz)) {
480 ]] .. local_prefix .. [[bool Blob_send(DragonnetPeer *peer, bool submit, Blob *val)
482 if (! u64_send(peer, false, &val->siz))
484 return dragonnet_send_raw(peer, submit, val->data, val->siz);
487 ]] .. local_prefix .. [[bool Blob_recv(DragonnetPeer *peer, Blob *val)
489 if (! u64_recv(peer, &val->siz))
492 if (! dragonnet_recv_raw(peer, val->data = malloc(val->siz), val->siz)) {
510 ]] .. local_prefix .. [[void raw_write_compressed(Blob *buffer, void *val, void (*val_write)(Blob *, void *))
512 Blob compressed, raw = {0};
513 val_write(&raw, val);
514 Blob_compress(&compressed, &raw);
515 Blob_write(buffer, &compressed);
517 Blob_free(&compressed);
521 ]] .. local_prefix .. [[bool raw_read_compressed(Blob *buffer, void *val, bool (*val_read)(Blob *, void *))
523 Blob compressed, raw = {0};
524 bool success = Blob_read(buffer, &compressed);
527 Blob_decompress(&raw, &compressed);
528 Blob raw_buffer = raw;
529 success = success && val_read(&raw_buffer, val);
532 Blob_free(&compressed);
539 ]] .. local_prefix .. [[bool raw_send_compressed(DragonnetPeer *peer, bool submit, void *val, void (*val_write)(Blob *, void *))
541 Blob compressed, raw = {0};
542 val_write(&raw, val);
543 Blob_compress(&compressed, &raw);
544 bool success = Blob_send(peer, submit, &compressed);
546 Blob_free(&compressed);
552 ]] .. local_prefix .. [[bool raw_recv_compressed(DragonnetPeer *peer, void *val, bool (*val_read)(Blob *, void *))
554 Blob compressed, raw = {0};
555 bool success = Blob_recv(peer, &compressed);
558 Blob_decompress(&raw, &compressed);
559 Blob raw_buffer = raw;
560 success = success && val_read(&raw_buffer, val);
563 Blob_free(&compressed);
573 local custom_types = {}
576 local function consume_name(name)
578 table.insert(custom_types, current_type)
584 current_type = {components = {}, component_names = {}}
586 current_type.flags = name:split(" ")
587 current_type.name = table.remove(current_type.flags, #current_type.flags)
589 if existing_types[current_type.name] then
590 error("redeclaration of type " .. current_type.name)
593 existing_types[current_type.name] = true
594 has_deallocator[current_type.name] = false
598 local function consume_comp(comp)
599 if not current_type then
600 error("component without a type: " .. comp)
605 component.flags = comp:split(" ")
606 component.name = table.remove(component.flags, #component.flags)
607 component.type = table.remove(component.flags, #component.flags)
609 component.full_name = current_type.name .. "." .. component.name
612 local met_brace = false
613 local brace_level = 0
615 for i = 1, #component.type do
616 local c = component.type:sub(i, i)
620 if not met_brace then
625 brace_level = brace_level + 1
627 if brace_level == 1 then
628 table.insert(component.array, "")
633 brace_level = brace_level - 1
635 if brace_level < 0 then
636 error("missing [ in " .. component.full_name)
637 elseif brace_level > 0 then
640 elseif not met_brace then
641 base_type = base_type .. c
642 elseif brace_level == 1 then
644 elseif brace_level == 0 then
645 error("invalid character " .. c .. " outside of braces in " .. component.full_name)
649 component.array[#component.array] = component.array[#component.array] .. c
653 component.type = base_type
655 if brace_level > 0 then
656 error("missing ] in " .. component.full_name)
659 if not existing_types[component.type] then
660 error("type " .. component.type .. " of " .. component.full_name .. " does not exist ")
663 has_deallocator[current_type.name] = has_deallocator[current_type.name] or has_deallocator[component.type]
665 if current_type.component_names[component.name] then
666 error("component " .. component.full_name .. " redeclared")
669 current_type.component_names[component.name] = true
671 table.insert(current_type.components, component)
675 for l in def:lines() do
676 local f = l:sub(1, 1)
679 consume_comp(l:sub(2, #l))
690 local dragonnet_types_h = ""
691 local dragonnet_types_c = ""
693 for _, t in ipairs(custom_types) do
696 for _, f in pairs(t.flags) do
700 error("invalid flag " .. f .. " for " .. t.name)
704 local typedef, free, write, read, send, recv =
705 "", "", "", "", "", ""
707 for ic, c in ipairs(t.components) do
709 .. "\t" .. c.type .. " " .. c.name
713 .. "[" .. table.concat(c.array, "][") .. "]"
719 local compressed = false
721 for _, f in pairs(c.flags) do
722 if f == "compressed" then
725 error("invalid flag " .. f .. " for " .. c.full_name)
732 local array_submit = ""
735 for ia, a in ipairs(c.array) do
738 loop = loop .. indent .. "for (int " .. it .. " = 0; " .. it .. " < " .. a .. "; " .. it .. "++)\n"
739 indent = indent .. "\t"
741 index = index .. "[" .. it .. "]"
743 array_submit = array_submit .. " && " .. it .. " == " .. a
747 local addr = "&val->" .. c.name .. index
749 if has_deallocator[c.type] then
751 .. loop .. indent .. c.type .. "_free(" .. addr .. ");\n"
755 .. loop .. indent .. (compressed
756 and "raw_write_compressed(buffer, " .. addr .. ", (void *) &" .. c.type .. "_write);\n"
757 or c.type .. "_write(buffer, " .. addr .. ");\n"
761 .. loop .. indent .. "if (! " .. (compressed
762 and "raw_read_compressed(buffer, " .. addr .. ", (void *) &" .. c.type .. "_read)"
763 or c.type .. "_read(buffer, " .. addr .. ")"
764 ) .. ")\n" .. indent .. "\treturn false;\n"
766 local submit = ic == #t.components and "submit" .. array_submit or "false"
768 .. loop .. indent .. "if (! " .. (compressed
769 and "raw_send_compressed(peer, " .. submit .. ", " .. addr .. ", (void *) &" .. c.type .. "_write)"
770 or c.type .. "_send(peer, " .. submit .. ", " .. addr .. ")"
771 ) .. ")\n" .. indent .. "\treturn false;\n"
774 .. loop .. indent .. "if (! " .. (compressed
775 and "raw_recv_compressed(peer, " .. addr .. ", (void *) &" .. c.type .. "_read)"
776 or c.type .. "_recv(peer, " .. addr .. ")"
777 ) .. ")\n" .. indent .. "\treturn false;\n"
780 emit_h("typedef struct {\n" .. typedef .. "} " .. t.name .. ";\n")
782 if has_deallocator[t.name] then
783 emit(export_prefix .. "void " .. t.name .. "_free(" .. t.name .. " *val)", "{\n" .. free .. "}\n\n")
786 emit(export_prefix .. "void " .. t.name .. "_write(Blob *buffer, " .. t.name .. " *val)", "{\n" .. write .. "}\n\n")
787 emit(export_prefix .. "bool " .. t.name .. "_read(Blob *buffer, " .. t.name .. " *val)", "{\n" .. read .. "\treturn true;\n}\n\n")
790 emit_h("#ifdef USE_DRAGONNET\n")
793 emit_c("#ifdef USE_DRAGONNET\n")
795 emit_c(local_prefix .. "bool " .. t.name .. "_send(DragonnetPeer *peer, bool submit, " .. t.name .. " *val)\n{\n" .. send .. "\treturn true;\n}\n\n")
796 emit_c(local_prefix .. "bool " .. t.name .. "_recv(DragonnetPeer *peer, " .. t.name .. " *val)\n{\n" .. recv .. "\treturn true;\n}\n")
800 emit_c("static DragonnetTypeId " .. t.name .. "_type_id = DRAGONNET_TYPE_" .. t.name .. ";\n")
802 emit("bool dragonnet_peer_send_" .. t.name .. "(DragonnetPeer *peer, " .. t.name .. " *val)", "{\n\tpthread_mutex_lock(&peer->mtx);\n\tif (! u16_send(peer, false, &" .. t.name .. "_type_id))\n\t\treturn false;\n\tif (! " .. t.name .. "_send(peer, true, val))\n\t\treturn false;\n\treturn true;\n}\n")
805 dragonnet_types_h = dragonnet_types_h
806 .. "\tDRAGONNET_TYPE_" .. t.name .. ",\n"
808 dragonnet_types_c = dragonnet_types_c
809 .. "\t{\n\t\t.siz = sizeof(" .. t.name .. "),\n\t\t.deserialize = (void *) &" .. t.name .. "_recv,\n\t\t.free = " .. (has_deallocator[t.name] and "(void *) &" .. t.name .. "_free" or "NULL") .. ",\n\t},\n"
817 emit_h("#ifdef USE_DRAGONNET\n")
818 emit_h("typedef enum {\n" .. dragonnet_types_h .. "\tDRAGONNET_NUM_TYPES\n} DragonnetTypeNum;\n")
821 emit_c("#ifdef USE_DRAGONNET\n")
822 emit_c("DragonnetTypeId dragonnet_num_types = DRAGONNET_NUM_TYPES;\nDragonnetType dragonnet_types[] = {\n" .. dragonnet_types_c .. "};\n")