Initial commit

Author: marksmith

.gitignore

@@ -0,0 +1,4 @@
+able
+config.mk
+*.o
+*~

LICENSE

@@ -0,0 +1,15 @@
+Copyright (c) 2015 Mark Smith <[email protected]>
+Copyright (c) 2015 Ryan Siddle <[email protected]>
+Copyright (c) 2015 Merj Ltd
+
+Permission to use, copy, modify, and distribute this software for any purpose
+with or without fee is hereby granted, provided that the above copyright notice
+and this permission notice appear in all copies.
+
+THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND
+FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
+OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
+TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF
+THIS SOFTWARE.

Makefile

@@ -0,0 +1,25 @@
+BIN?=able
+SRCS=trap.c libable_shim.c term.c able.c
+LIBS=-lpthread -lable
+
+.include "config.mk"
+
+OBJS+=${SRCS:N*.h:R:S/$/.o/}
+
+.PHONY: build clean install uninstall
+
+build: ${BIN}
+
+clean:
+	-rm -vf ${OBJS} ${BIN}
+	-rm -vf ${BIN}.core
+
+install: ${BIN}
+	@mkdir -p ${BINDIR}
+	install -m 0755 ${BIN} ${BINDIR}/${BIN}
+
+uninstall:
+	-rm -vf ${BINDIR}/${BIN}
+
+${BIN}: ${OBJS}
+	${LD} ${LDFLAGS} -o ${BIN} ${OBJS} ${LIBS}

README

@@ -0,0 +1,49 @@
+WELCOME TO ABLE!
+
+able implements an efficient, portable and secure general-purpose virtual
+machine and virtual network using libable
+
+GETTING STARTED
+
+BSD Make and Clang are required to build and install able
+
+Building and installing on OpenBSD
+
+$ cp config.mk.def config.mk
+$ make install
+...
+$ 
+
+Building and installing on Ubuntu
+
+# apt install bmake clang
+...
+# exit
+$ cp config.mk.def config.mk
+$ bmake -DCOMPAT_LINUX install
+...
+$ 
+
+Building and installing on macOS
+
+# brew install bmake
+...
+# exit
+$ cp config.mk.def config.mk
+$ bmake -DCOMPAT_MACOS install
+...
+$ 
+
+GETTING INVOLVED
+
+Contact Details
+
+Find us online at ablevm.org or email us at [email protected]
+
+Code of Conduct
+
+Respect each other and please don't spam
+
+LICENSE
+
+ISC-style license

able.c

@@ -0,0 +1,178 @@
+#include <stdatomic.h>
+#include <pthread.h>
+#include <able/able.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <err.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <sys/mman.h>
+#include <string.h>
+#include <stdio.h>
+#include <signal.h>
+#include "trap.h"
+#include "libable_shim.h"
+#include "term.h"
+
+extern char *__progname;
+
+void
+usage() {
+	fprintf(stderr, "usage: %s [-hv] [-s size] [file]\n", __progname);
+	exit(1);
+}
+
+long
+eatoi(const char *s) {
+	long v;
+	char *ep;
+	v = strtol(s, &ep, 10);
+	switch (ep[0]) {
+		case 'G':
+			v *= 1024;
+		case 'M':
+			v *= 1024;
+		case 'K':
+		case 'B':
+			v *= 1024;
+	}
+	return v;
+}
+
+int
+main(int argc, char *argv[]) {
+	int v;
+	v = 0;
+	long bc;
+	bc = 0;
+	char *ifn;
+	ifn = NULL;
+
+	char c;
+	while ((c = getopt(argc, argv, "hvs:")) != -1) {
+		switch (c) {
+			case 's':
+				if (bc != 0)
+					usage();
+				bc = eatoi(optarg);
+				break;
+			case 'v':
+				v++;
+				break;
+			case 'h':
+			default:
+				usage();
+		}
+	}
+
+	argc -= optind;
+	argv += optind;
+
+	switch (argc) {
+		case 0:
+			asprintf(&ifn, "%s.img", __progname);
+			break;
+		case 1:
+			ifn = argv[0];
+			break;
+		default:
+			usage();
+	}
+
+	if (bc == 0) {
+		struct stat ifs;
+		int rc;
+		rc = stat(ifn, &ifs);
+		if (rc == -1)
+			err(3, "%s", ifn);
+		bc = ifs.st_size;
+	}
+
+	int ifd;
+	ifd = open(ifn, O_RDWR);
+	if (ifd == -1)
+		err(3, "open");
+	void *b;
+	b = mmap(NULL, bc, PROT_READ|PROT_WRITE, MAP_SHARED, ifd, 0);
+	if (b == MAP_FAILED)
+		err(3, "mmap");
+	close(ifd);
+
+	// virtual machine config
+
+	// terminal input
+	term_recv_t i0;
+	memset(&i0, 0, sizeof(i0));
+
+	able_task_t i0t;
+	memset(&i0t, 0, sizeof(i0t));
+	i0t.f = (able_task_exec_t)term_recv_exec;
+	i0t.u = &i0;
+
+	able_wire_t i0w[256];
+	memset(&i0w, 0, sizeof(i0w));
+
+	// terminal output
+	term_send_t o0;
+	memset(&o0, 0, sizeof(o0));
+	able_node_init(&o0.n);
+	o0.b = malloc(1024);
+	o0.bc = 1024;
+
+	able_task_t o0t;
+	memset(&o0t, 0, sizeof(o0t));
+	o0t.f = (able_task_exec_t)term_send_exec;
+	o0t.u = &o0;
+
+	able_wire_t o0w[256];
+	memset(&o0w, 0, sizeof(o0w));
+
+	// host 0
+	able_node_t h0n;
+	able_node_init(&h0n);
+
+	able_port_t h0p[256];
+	memset(h0p, 0, sizeof(h0p));
+	able_link_t h0l[256];
+	memset(h0l, 0, sizeof(h0l));
+	able_host_t h0;
+	memset(&h0, 0, sizeof(h0));
+	h0.p = h0p;
+	h0.pc = 256;
+	h0.l = h0l;
+	h0.lc = 256;
+	h0.c.b = b;
+	h0.c.bc = bc;
+	h0.u = &h0n;
+	h0.ts = 1000;
+
+	able_task_t h0t;
+	memset(&h0t, 0, sizeof(h0t));
+	h0t.f = (able_task_exec_t)able_host_exec_shim;
+	h0t.u = &h0;
+
+	able_wire_t h0w[256];
+	memset(&h0w, 0, sizeof(h0w));
+
+	trap_data.u = &h0;
+	signal(SIGINT, trap);
+
+	// virtual network config
+
+	// h0.p[0]<-i0.l
+	able_wire_bind(&h0w[1], &h0.p[0], 1, &h0n);
+	able_wire_join(&h0w[1], &i0.l);
+	// o0.p<-h0.l[0]
+	able_wire_bind(&o0w[0], &o0.p, 0, &o0.n);
+	able_wire_join(&o0w[0], &h0.l[0]);
+	// h0.p[0]<-o0.l
+	able_wire_bind(&h0w[0], &h0.p[0], 0, &h0n);
+	able_wire_join(&h0w[0], &o0.l);
+
+	able_task_fork_exec(&i0t);
+	able_task_fork_exec(&o0t);
+	able_task_exec(&h0t);
+
+	// should not happen
+	return 2;
+}

config.mk.def

@@ -0,0 +1,19 @@
+PREFIX?=/usr/local/able
+BINDIR=${PREFIX}/bin
+INCDIR=${PREFIX}/include
+LIBDIR=${PREFIX}/lib
+MANDIR=${PREFIX}/man
+
+CC=clang
+CFLAGS=-I${INCDIR} -g -O2 -std=c11 -pedantic -Wall -Wno-zero-length-array -Wno-gnu-label-as-value -Wno-gnu-designator -Wno-gnu-empty-struct
+
+.ifdef DEBUG
+CFLAGS+=-DDEBUG=${DEBUG}
+.endif
+
+.ifdef COMPAT_LINUX
+CFLAGS+=-DABLE_COMPAT_LINUX -D_GNU_SOURCE
+.endif
+
+LD=${CC}
+LDFLAGS=-L${LIBDIR}

libable_shim.c

@@ -0,0 +1,84 @@
+#include <stdatomic.h>
+#include <pthread.h>
+#include <able/able.h>
+#include "libable_shim.h"
+#include <inttypes.h>
+#include <stdio.h>
+#include <string.h>
+#include "trap.h"
+
+int
+able_host_wait_shim(able_host_t *host, able_edge_t *edge, const struct timespec *time) {
+	return able_node_wait(host->u, edge, time);
+}
+
+int
+able_link_post_shim(able_link_t *link, able_edge_t *edge) {
+	return able_node_post(link->u, edge);
+}
+
+#define P(C, Y) \
+	fprintf(stderr, "%02"PRIX8"(%"PRId8") %"PRId64" %08"PRIX64" %"PRId64"/%"PRIX64" %"PRId64"/%"PRIX64" (%"PRIu8"); %"PRId64"/%"PRIX64" (%"PRIu8")\n", \
+		(C)->i, \
+		(Y), \
+		(C)->ts, \
+		(C)->p, \
+		(C)->d1, (C)->d1, \
+		(C)->d0, (C)->d0, \
+		(C)->dp, \
+		(C)->c0, (C)->c0, \
+		(C)->cp);
+
+int
+able_host_exec_shim(able_host_t *host) {
+	for (;;) {
+		able_host_t *h;
+		h = trap_data.u;
+		if (h == host) {
+			int q;
+			q = atomic_exchange(&trap_data.q, 0);
+			if (q == 1) {
+				h->c.p = 0;
+				h->c.d0 = 0;
+				h->c.d1 = 0;
+				memset(h->c.d, 0, sizeof(h->c.d));
+				h->c.dp = 0;
+				h->c.c0 = 0;
+				memset(h->c.c, 0, sizeof(h->c.c));
+				h->c.cp = 0;
+			}
+		}
+		int y;
+		y = able_host_exec(host);
+		switch (y) {
+			case -1: // end of timeslice
+				able_host_wait_shim(host, NULL, NULL);
+				return y;
+			case -2: // bad memory access
+			case -3: // divide by zero
+#ifdef DEBUG
+				P(&host->c, y);
+#endif
+				host->c.p = 0;
+				break;
+			case -4: // illegal instruction
+				switch (host->c.i) {
+					case 0x85: // debug
+						P(&host->c, y);
+						break;
+					default:
+#ifdef DEBUG
+						P(&host->c, y);
+#endif
+						host->c.p = 0;
+						break;
+				}
+				break;
+			case -5: // start of timeslice
+				return y;
+		}
+	}
+
+	// should not happen
+	return 1;
+}

libable_shim.h

@@ -0,0 +1,2 @@
+int
+able_host_exec_shim(able_host_t *host);