9 files changed, 129 insertions, 0 deletions
diff --git a/05_callback/build.sh b/05_callback/build.sh
new file mode 100755
index 0000000..998ebd1
--- /dev/null
+++ b/05_callback/build.sh
@@ -0,0 +1,8 @@
+#!/bin/sh
+mkdir -p build
+emcc -sEXPORTED_FUNCTIONS=_primes_in_range -sMODULARIZE -sEXPORT_NAME=Primes \
+        -sEXPORTED_RUNTIME_METHODS=addFunction,UTF8ToString \
+        -sALLOW_TABLE_GROWTH \
+        -pthread -sPTHREAD_POOL_SIZE=16 \
+        -o build/primes.mjs primes.c
diff --git a/05_callback/index.html b/05_callback/index.html
new file mode 100644
index 0000000..7a1fba7
--- /dev/null
+++ b/05_callback/index.html
@@ -0,0 +1,19 @@
+<!doctype html>
+<html lang="en-US">
+<head>
+        <meta charset="utf-8" />
+        <meta name="viewport" content="width=device-width" />
+        <title>Primes in a range</title>
+        <script src="./script.mjs" type="module" defer></script>
+</head>
+<body>
+        <label for="aInput">Lower bound (included)</label><br />
+        <input id="aInput" name="aInput" /> x <br />
+        <label for="bInput">Upper bound (excluded)</label><br />
+        <input id="bInput" name="bInput" /> <br />
+        <button id="goButton">Compute</button> <br />
+        <p id="resultText"></p>
+</body>
+</html>
diff --git a/05_callback/mime.txt b/05_callback/mime.txt
new file mode 100644
index 0000000..6a9a425
--- /dev/null
+++ b/05_callback/mime.txt
@@ -0,0 +1 @@
+text/javascript         mjs
diff --git a/05_callback/primes.c b/05_callback/primes.c
new file mode 100644
index 0000000..f581161
--- /dev/null
+++ b/05_callback/primes.c
@@ -0,0 +1,55 @@
+#include <stdbool.h>
+#include <pthread.h>
+#define NTHREADS 16
+bool isprime(int);
+void *pthread_routine(void *);
+struct interval { int low; int high; int count; };
+int primes_in_range(int low, int high, void (*log)(const char *)) {
+        pthread_t threads[NTHREADS];
+        struct interval args[NTHREADS];
+        if (low < 0 || high < low)
+                return 0;
+        int interval_size = (high-low)/NTHREADS + 1;
+        for (int i = 0; i < NTHREADS; i++) {
+                args[i].low = low + i*interval_size;
+                args[i].high = args[i].low + interval_size;
+                pthread_create(&threads[i], NULL, pthread_routine, &args[i]);
+        }
+        log("All threads have started, computing..."); 
+        int result = 0;
+        for (int i = 0; i < NTHREADS; i++) {
+                pthread_join(threads[i], NULL);
+                result += args[i].count;
+        }
+        return result;
+}
+bool isprime(int n) {
+        if (n < 2)
+                return false;
+        for (int i = 2; i*i <= n; i++)
+                if (n % i == 0)
+                        return false;
+        return true;
+}
+void *pthread_routine(void *arg) {
+        struct interval *interval = arg;
+        interval->count = 0;
+        for (int i = interval->low; i < interval->high; i++)
+                if (isprime(i))
+                        interval->count++;
+        return NULL;
+}
diff --git a/05_callback/program.mjs b/05_callback/program.mjs
new file mode 100644
index 0000000..fd85a58
--- /dev/null
+++ b/05_callback/program.mjs
@@ -0,0 +1,11 @@
+import Primes from "./build/primes.mjs"
+var primes = await Primes();
+const logPtr = primes.addFunction((cstr) => {
+        console.log(primes.UTF8ToString(cstr));
+}, 'vp');
+const a = 1;
+const b = 10000000;
+const count = primes._primes_in_range(a, b, logPtr);
+console.log("There are " + count + " primes between " + a + " and " + b);
diff --git a/05_callback/run-node.sh b/05_callback/run-node.sh
new file mode 100755
index 0000000..a6c9aa8
--- /dev/null
+++ b/05_callback/run-node.sh
@@ -0,0 +1,3 @@
+#!/bin/sh
+node program.mjs
diff --git a/05_callback/run-server.sh b/05_callback/run-server.sh
new file mode 100755
index 0000000..6e75760
--- /dev/null
+++ b/05_callback/run-server.sh
@@ -0,0 +1,7 @@
+#!/bin/sh
+darkhttpd . \
+--port 8082 \
+        --mimetypes mime.txt \
+        --header 'Cross-Origin-Opener-Policy: same-origin' \
+        --header 'Cross-Origin-Embedder-Policy: require-corp'
diff --git a/05_callback/script.mjs b/05_callback/script.mjs
new file mode 100644
index 0000000..9fce6fe
--- /dev/null
+++ b/05_callback/script.mjs
@@ -0,0 +1,13 @@
+var aInput = document.getElementById("aInput");
+var bInput = document.getElementById("bInput");
+var button = document.getElementById("goButton");
+var resultText = document.getElementById("resultText");
+var worker = new Worker("./worker.mjs", { type: "module" });
+button.addEventListener("click", () => worker.postMessage({
+        a: Number(aInput.value),
+        b: Number(bInput.value)
+}));
+worker.onmessage = (e) => resultText.innerText = e.data.message;
diff --git a/05_callback/worker.mjs b/05_callback/worker.mjs
new file mode 100644
index 0000000..736e9f8
--- /dev/null
+++ b/05_callback/worker.mjs
@@ -0,0 +1,12 @@
+import Primes from "./build/primes.mjs";
+var primes = await Primes();
+const logPtr = primes.addFunction((cstr) => {
+        postMessage({ message: primes.UTF8ToString(cstr) });
+}, "vp");
+onmessage = (e) => {
+        const count = primes._primes_in_range(e.data.a, e.data.b, logPtr);
+        postMessage({ message: "There are " + count + " primes between " +
+                e.data.a + " and " + e.data.b });
+};

diff --git a/05_callback/build.sh b/05_callback/build.sh new file mode 100755 index 0000000..998ebd1 --- /dev/null +++ b/05_callback/build.sh
@@ -0,0 +1,8 @@
	1	#!/bin/sh
	2
	3	mkdir -p build
	4	emcc -sEXPORTED_FUNCTIONS=_primes_in_range -sMODULARIZE -sEXPORT_NAME=Primes \
	5	-sEXPORTED_RUNTIME_METHODS=addFunction,UTF8ToString \
	6	-sALLOW_TABLE_GROWTH \
	7	-pthread -sPTHREAD_POOL_SIZE=16 \
	8	-o build/primes.mjs primes.c


diff --git a/05_callback/index.html b/05_callback/index.html new file mode 100644 index 0000000..7a1fba7 --- /dev/null +++ b/05_callback/index.html
@@ -0,0 +1,19 @@
	1	<!doctype html>
	2	<html lang="en-US">
	3	<head>
	4	<meta charset="utf-8" />
	5	<meta name="viewport" content="width=device-width" />
	6	<title>Primes in a range</title>
	7	<script src="./script.mjs" type="module" defer></script>
	8	</head>
	9
	10	<body>
	11	<label for="aInput">Lower bound (included)</label><br />
	12	<input id="aInput" name="aInput" /> x <br />
	13	<label for="bInput">Upper bound (excluded)</label><br />
	14	<input id="bInput" name="bInput" /> <br />
	15	<button id="goButton">Compute</button> <br />
	16	<p id="resultText"></p>
	17	</body>
	18
	19	</html>


diff --git a/05_callback/mime.txt b/05_callback/mime.txt new file mode 100644 index 0000000..6a9a425 --- /dev/null +++ b/05_callback/mime.txt
@@ -0,0 +1 @@
		text/javascript mjs


diff --git a/05_callback/primes.c b/05_callback/primes.c new file mode 100644 index 0000000..f581161 --- /dev/null +++ b/05_callback/primes.c
@@ -0,0 +1,55 @@
	1	#include <stdbool.h>
	2	#include <pthread.h>
	3
	4	#define NTHREADS 16
	5
	6	bool isprime(int);
	7	void pthread_routine(void );
	8
	9	struct interval { int low; int high; int count; };
	10
	11	int primes_in_range(int low, int high, void (log)(const char )) {
	12	pthread_t threads[NTHREADS];
	13	struct interval args[NTHREADS];
	14
	15	if (low < 0 \|\| high < low)
	16	return 0;
	17
	18	int interval_size = (high-low)/NTHREADS + 1;
	19	for (int i = 0; i < NTHREADS; i++) {
	20	args[i].low = low + i*interval_size;
	21	args[i].high = args[i].low + interval_size;
	22	pthread_create(&threads[i], NULL, pthread_routine, &args[i]);
	23	}
	24
	25	log("All threads have started, computing...");
	26
	27	int result = 0;
	28	for (int i = 0; i < NTHREADS; i++) {
	29	pthread_join(threads[i], NULL);
	30	result += args[i].count;
	31	}
	32
	33	return result;
	34	}
	35
	36	bool isprime(int n) {
	37	if (n < 2)
	38	return false;
	39
	40	for (int i = 2; i*i <= n; i++)
	41	if (n % i == 0)
	42	return false;
	43	return true;
	44	}
	45
	46	void pthread_routine(void arg) {
	47	struct interval *interval = arg;
	48
	49	interval->count = 0;
	50	for (int i = interval->low; i < interval->high; i++)
	51	if (isprime(i))
	52	interval->count++;
	53
	54	return NULL;
	55	}


diff --git a/05_callback/program.mjs b/05_callback/program.mjs new file mode 100644 index 0000000..fd85a58 --- /dev/null +++ b/05_callback/program.mjs
@@ -0,0 +1,11 @@
	1	import Primes from "./build/primes.mjs"
	2
	3	var primes = await Primes();
	4	const logPtr = primes.addFunction((cstr) => {
	5	console.log(primes.UTF8ToString(cstr));
	6	}, 'vp');
	7
	8	const a = 1;
	9	const b = 10000000;
	10	const count = primes._primes_in_range(a, b, logPtr);
	11	console.log("There are " + count + " primes between " + a + " and " + b);


diff --git a/05_callback/run-node.sh b/05_callback/run-node.sh new file mode 100755 index 0000000..a6c9aa8 --- /dev/null +++ b/05_callback/run-node.sh
@@ -0,0 +1,3 @@
	1	#!/bin/sh
	2
	3	node program.mjs


diff --git a/05_callback/run-server.sh b/05_callback/run-server.sh new file mode 100755 index 0000000..6e75760 --- /dev/null +++ b/05_callback/run-server.sh
@@ -0,0 +1,7 @@
	1	#!/bin/sh
	2
	3	darkhttpd . \
	4	--port 8082 \
	5	--mimetypes mime.txt \
	6	--header 'Cross-Origin-Opener-Policy: same-origin' \
	7	--header 'Cross-Origin-Embedder-Policy: require-corp'


diff --git a/05_callback/script.mjs b/05_callback/script.mjs new file mode 100644 index 0000000..9fce6fe --- /dev/null +++ b/05_callback/script.mjs
@@ -0,0 +1,13 @@
	1	var aInput = document.getElementById("aInput");
	2	var bInput = document.getElementById("bInput");
	3	var button = document.getElementById("goButton");
	4	var resultText = document.getElementById("resultText");
	5
	6	var worker = new Worker("./worker.mjs", { type: "module" });
	7
	8	button.addEventListener("click", () => worker.postMessage({
	9	a: Number(aInput.value),
	10	b: Number(bInput.value)
	11	}));
	12
	13	worker.onmessage = (e) => resultText.innerText = e.data.message;


diff --git a/05_callback/worker.mjs b/05_callback/worker.mjs new file mode 100644 index 0000000..736e9f8 --- /dev/null +++ b/05_callback/worker.mjs
@@ -0,0 +1,12 @@
	1	import Primes from "./build/primes.mjs";
	2
	3	var primes = await Primes();
	4	const logPtr = primes.addFunction((cstr) => {
	5	postMessage({ message: primes.UTF8ToString(cstr) });
	6	}, "vp");
	7
	8	onmessage = (e) => {
	9	const count = primes._primes_in_range(e.data.a, e.data.b, logPtr);
	10	postMessage({ message: "There are " + count + " primes between " +
	11	e.data.a + " and " + e.data.b });
	12	};