Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8929dc868f | |||
| 2480446ef5 | |||
| 53171df913 | |||
| 67b67c2505 | |||
| c1a3e86222 | |||
| e8138414c0 | |||
| 289443192f |
@@ -1,85 +1,50 @@
|
|||||||
# Wipforth
|
# Wipforth
|
||||||
|
|
||||||
Wipforth is a Forth implementation that runs in the WebAssembly
|
Wipforth is a simple Forth implementation that runs in the WebAssembly
|
||||||
virtual machine. The system is bootstrapped from source on page load:
|
virtual machine. It does I/O via memory-mapped peripherals, which are
|
||||||
the only non-text file is the favicon :)
|
emulated in JavaScript.
|
||||||
|
|
||||||
I/O is done via memory-mapped peripherals, which are emulated in
|
- For the Forth kernel, see [wipforth.wat](./wipforth.wat)
|
||||||
JavaScript.
|
- For the JavaScript emulator, see [emu.js](./emu.js)
|
||||||
|
- For the Forth prelude, which is loaded at start-up, see
|
||||||
- For the Forth kernel, see [wipforth.ws](./wipforth.ws)
|
[prelude.f](./prelude.f)
|
||||||
- For the emulator, see [emu.js](./emu.js)
|
|
||||||
- For the assembler, see [asm.js](./asm.js)
|
|
||||||
- For the prelude (Forth code loaded right after the kernel boots),
|
|
||||||
see [prelude.f](./prelude.f)
|
|
||||||
- For a description of the peripherals, see the
|
- For a description of the peripherals, see the
|
||||||
[Peripherals](#peripherals) section below.
|
[Peripherals](#peripherals) section below.
|
||||||
|
|
||||||
## Building and Running Locally
|
## Building and Running
|
||||||
|
|
||||||
There's a [Guile](https://www.gnu.org/software/guile/) script in the
|
To run, first compile the WebAssembly module:
|
||||||
repo you can use for this:
|
|
||||||
|
|
||||||
```
|
```
|
||||||
guile server.scm
|
wat2wasm --enable-threads wipforth.wat
|
||||||
|
```
|
||||||
|
|
||||||
|
Then run the server:
|
||||||
|
|
||||||
|
```
|
||||||
|
python3 server.py
|
||||||
```
|
```
|
||||||
|
|
||||||
You should then be able to open <http://localhost:8080> in a browser
|
You should then be able to open <http://localhost:8080> in a browser
|
||||||
and use the system from there.
|
and use the system from there.
|
||||||
|
|
||||||
However, since everything is bootstrapped on the client, basically any
|
**NOTE**: The server is just a very simple instantiation of Python's
|
||||||
HTTP server will do as long as it sets the appropriate response
|
built-in `http.server.HTTPServer`, configured to set the cross-origin
|
||||||
headers for `SharedMemoryBuffer` use:
|
headers required for `SharedMemoryBuffer` use. You could use any HTTP
|
||||||
|
server that sets these headers.
|
||||||
- `Cross-Origin-Opener-Policy: same-origin`
|
|
||||||
- `Cross-Origin-Embedder-Policy: require-corp`
|
|
||||||
|
|
||||||
So, if you don't have Guile on your system you can use something else
|
|
||||||
like Python's `http.server`.
|
|
||||||
|
|
||||||
**NOTE**: You should **definitely not** use `server.scm` to serve the
|
|
||||||
application on the open internet or anything like that; I just hacked
|
|
||||||
it together for testing on localhost during development and it's
|
|
||||||
probably hilariously insecure.
|
|
||||||
|
|
||||||
## End-to-End Tests
|
|
||||||
|
|
||||||
There's a (fairly minimal at the moment) end-to-end test suite defined
|
|
||||||
in [tests.scm](./tests.scm). To run it you'll need:
|
|
||||||
|
|
||||||
- [Guile](https://www.gnu.org/software/guile/) again (no substitute
|
|
||||||
this time, sorry)
|
|
||||||
- [guile-json](https://github.com/aconchillo/guile-json)
|
|
||||||
- Firefox
|
|
||||||
|
|
||||||
I'm also pretty sure it won't work on a non-POSIX system, though I
|
|
||||||
haven't tried it.
|
|
||||||
|
|
||||||
Given that's all sorted, you should be able to run:
|
|
||||||
|
|
||||||
```
|
|
||||||
guile tests.scm
|
|
||||||
```
|
|
||||||
|
|
||||||
It will print a JUnit XML report to standard out. You can
|
|
||||||
pretty-print it with `xmllint` if you have it installed:
|
|
||||||
|
|
||||||
```
|
|
||||||
guile tests.scm | xmllint --format -
|
|
||||||
```
|
|
||||||
|
|
||||||
## Peripherals
|
## Peripherals
|
||||||
|
|
||||||
### Terminal
|
# Terminal
|
||||||
|
|
||||||
| Name | Address | Size / B | Access |
|
| Name | Offset | Size / B | Access |
|
||||||
|--------|---------|----------|--------------|
|
|--------|--------|----------|--------------|
|
||||||
| TXBUF | 00h | 32 | write |
|
| TXBUF | 0 | 32 | write |
|
||||||
| RXBUF | 20h | 32 | read |
|
| RXBUF | 32 | 32 | read |
|
||||||
| TXHEAD | 40h | 4 | atomic read |
|
| TXHEAD | 64 | 1 | atomic read |
|
||||||
| TXTAIL | 44h | 4 | atomic write |
|
| TXTAIL | 65 | 1 | atomic write |
|
||||||
| RXHEAD | 48h | 4 | atomic write |
|
| RXHEAD | 66 | 1 | atomic write |
|
||||||
| RXTAIL | 4Ch | 4 | atomic read |
|
| RXTAIL | 67 | 1 | atomic read |
|
||||||
|
|
||||||
For both sending (`TX`) and receiving (`RX`), there are three
|
For both sending (`TX`) and receiving (`RX`), there are three
|
||||||
registers: `xBUF`, `xHEAD` and `xTAIL`:
|
registers: `xBUF`, `xHEAD` and `xTAIL`:
|
||||||
@@ -93,11 +58,11 @@ In order to be distinguishable from the empty state, the ring buffers
|
|||||||
must never be completely full -- there must always be *at least one*
|
must never be completely full -- there must always be *at least one*
|
||||||
unoccupied byte between the tail and the head.
|
unoccupied byte between the tail and the head.
|
||||||
|
|
||||||
### System status
|
# System status
|
||||||
|
|
||||||
| Name | Address | Size / B | Access |
|
| Name | Offset | Size / B | Access |
|
||||||
|----------|---------|----------|--------------|
|
|----------|--------|----------|--------------|
|
||||||
| SYSREADY | 50h | 1 | atomic write |
|
| SYSREADY | 68 | 1 | atomic write |
|
||||||
|
|
||||||
The `SYSREADY` register is used to indicate when the system has booted
|
The `SYSREADY` register is used to indicate when the system has booted
|
||||||
up and is ready for user input.
|
up and is ready for user input.
|
||||||
|
|||||||
@@ -1,26 +1,7 @@
|
|||||||
import { Assembler } from './asm.js';
|
|
||||||
|
|
||||||
const assemble = (async () => {
|
|
||||||
const asm = new Assembler();
|
|
||||||
const resp = await fetch('wipforth.ws');
|
|
||||||
for await (const chunk of resp.body) {
|
|
||||||
asm.push(chunk);
|
|
||||||
}
|
|
||||||
return asm.wasm();
|
|
||||||
})();
|
|
||||||
|
|
||||||
self.onmessage = async (e) => {
|
self.onmessage = async (e) => {
|
||||||
switch (e.data.type) {
|
const exports = { emu: { mem: e.data } };
|
||||||
case "load":
|
const mod = await WebAssembly.instantiateStreaming(
|
||||||
const exports = { emu: { mem: e.data.mem } };
|
fetch('wipforth.wasm'), exports)
|
||||||
const wasm = await assemble;
|
mod.instance.exports.reset();
|
||||||
self.mod = await WebAssembly.instantiate(wasm, exports);
|
console.log('System halt');
|
||||||
await self.postMessage('ready');
|
|
||||||
break;
|
|
||||||
|
|
||||||
case "boot":
|
|
||||||
self.mod.instance.exports.reset();
|
|
||||||
console.log('System halt');
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -1,6 +0,0 @@
|
|||||||
boot.js
|
|
||||||
emu.js
|
|
||||||
index.html
|
|
||||||
prelude.f
|
|
||||||
styles.css
|
|
||||||
wipforth.ws
|
|
||||||
@@ -1,139 +0,0 @@
|
|||||||
(define-module (e2e marionette)
|
|
||||||
#:export (with-marionette
|
|
||||||
start-firefox
|
|
||||||
close-firefox
|
|
||||||
client-setup
|
|
||||||
client-teardown
|
|
||||||
navigate
|
|
||||||
input-line
|
|
||||||
get-display))
|
|
||||||
|
|
||||||
(use-modules
|
|
||||||
(json)
|
|
||||||
(scheme base)
|
|
||||||
(srfi srfi-9))
|
|
||||||
|
|
||||||
(define-syntax-rule (with-marionette client body ...)
|
|
||||||
(let ((client #f) (pid #f))
|
|
||||||
(dynamic-wind
|
|
||||||
(lambda ()
|
|
||||||
(set! pid (start-firefox))
|
|
||||||
(set! client (client-setup)))
|
|
||||||
(lambda () body ...)
|
|
||||||
(lambda ()
|
|
||||||
(when client (client-teardown client))
|
|
||||||
(when pid (close-firefox pid))))))
|
|
||||||
|
|
||||||
(define (start-firefox)
|
|
||||||
(let* ((profile-dir (mkdtemp "/tmp/marionette-XXXXXX"))
|
|
||||||
(i/o (pipe))
|
|
||||||
(pid (spawn "firefox"
|
|
||||||
`("firefox" "--marionette" "--headless"
|
|
||||||
"--profile" ,profile-dir "about:blank")
|
|
||||||
#:output (cdr i/o)
|
|
||||||
#:error (cdr i/o))))
|
|
||||||
(let loop ((line (read-line (car i/o))))
|
|
||||||
(cond
|
|
||||||
((string-contains line "Listening on port") #nil)
|
|
||||||
((eof-object? line) (format #t "EOF when starting firefox~%"))
|
|
||||||
(#t (loop (read-line (car i/o))))))
|
|
||||||
(close-port (car i/o))
|
|
||||||
(close-port (cdr i/o))
|
|
||||||
pid))
|
|
||||||
|
|
||||||
(define (close-firefox pid)
|
|
||||||
(kill pid SIGINT)
|
|
||||||
(waitpid pid)
|
|
||||||
*unspecified*)
|
|
||||||
|
|
||||||
(define-record-type client
|
|
||||||
(make-client socket msg-num)
|
|
||||||
client?
|
|
||||||
(socket client-socket)
|
|
||||||
(msg-num client-msg-num client-msg-num-set!))
|
|
||||||
|
|
||||||
(define (client-msg-num-1+! client)
|
|
||||||
(client-msg-num-set! client (1+ (client-msg-num client))))
|
|
||||||
|
|
||||||
(define (open-socket host port)
|
|
||||||
(let ((sock (socket PF_INET SOCK_STREAM 0))
|
|
||||||
(addr (inet-pton AF_INET host)))
|
|
||||||
(connect sock AF_INET addr port)
|
|
||||||
sock))
|
|
||||||
|
|
||||||
(define (handle-start-msg client)
|
|
||||||
(let* ((msg (read-msg (client-socket client)))
|
|
||||||
(protocol (assoc-ref msg "marionetteProtocol")))
|
|
||||||
(unless (= 3 protocol)
|
|
||||||
(format #t "Unsupported protocol: ~a~%" protocol))))
|
|
||||||
|
|
||||||
(define* (client-setup #:key (host "127.0.0.1") (port 2828))
|
|
||||||
(let ((client (make-client (open-socket host port) 0)))
|
|
||||||
(handle-start-msg client)
|
|
||||||
(create-session client)
|
|
||||||
client))
|
|
||||||
|
|
||||||
(define (client-teardown client)
|
|
||||||
(close (client-socket client)))
|
|
||||||
|
|
||||||
(define (add-digit val digit)
|
|
||||||
(+ (* val 10) (- digit 48)))
|
|
||||||
|
|
||||||
(define (read-msg-len sock)
|
|
||||||
(let loop ((len 0) (byte (read-u8 sock)))
|
|
||||||
(if (eq? byte 58)
|
|
||||||
len
|
|
||||||
(loop (add-digit len byte)
|
|
||||||
(read-u8 sock)))))
|
|
||||||
|
|
||||||
(define (read-msg sock)
|
|
||||||
(let ((len (read-msg-len sock)))
|
|
||||||
(json-string->scm (utf8->string (read-bytevector len sock)))))
|
|
||||||
|
|
||||||
(define (send-msg sock msg)
|
|
||||||
(let* ((payload (string->utf8 (scm->json-string msg)))
|
|
||||||
(len (bytevector-length payload)))
|
|
||||||
(write-bytevector (string->utf8 (number->string len)) sock)
|
|
||||||
(write-u8 58 sock)
|
|
||||||
(write-bytevector payload sock)))
|
|
||||||
|
|
||||||
(define (send-command client command params)
|
|
||||||
(send-msg (client-socket client)
|
|
||||||
(vector 0 (client-msg-num client) command params))
|
|
||||||
(client-msg-num-1+! client)
|
|
||||||
(let* ((response (read-msg (client-socket client)))
|
|
||||||
(error (vector-ref response 2))
|
|
||||||
(result (vector-ref response 3)))
|
|
||||||
(unless (eq? 'null error)
|
|
||||||
(format #t "Error: ~a~%" (assoc-ref error "message")))
|
|
||||||
(assoc-ref result "value")))
|
|
||||||
|
|
||||||
(define (create-session client)
|
|
||||||
(send-command client "WebDriver:NewSession" '())
|
|
||||||
*unspecified*)
|
|
||||||
|
|
||||||
(define (navigate client url)
|
|
||||||
(send-command client "WebDriver:Navigate" `(("url" . ,url)))
|
|
||||||
*unspecified*)
|
|
||||||
|
|
||||||
(define (find-element client selector)
|
|
||||||
(assoc-ref
|
|
||||||
(send-command client "WebDriver:FindElement"
|
|
||||||
`(("using" . "css selector")
|
|
||||||
("value" . ,selector)))
|
|
||||||
"element-6066-11e4-a52e-4f735466cecf"))
|
|
||||||
|
|
||||||
(define (send-keys client text)
|
|
||||||
(let ((id (find-element client "body")))
|
|
||||||
(send-command client "WebDriver:ElementSendKeys"
|
|
||||||
`(("id" . ,id) ("text" . ,text)))))
|
|
||||||
|
|
||||||
(define (get-element-text client selector)
|
|
||||||
(let ((id (find-element client selector)))
|
|
||||||
(send-command client "WebDriver:GetElementText" `(("id" . ,id)))))
|
|
||||||
|
|
||||||
(define (input-line client text)
|
|
||||||
(send-keys client (string-append text "\ue007")))
|
|
||||||
|
|
||||||
(define (get-display client)
|
|
||||||
(get-element-text client "#output"))
|
|
||||||
@@ -1,71 +0,0 @@
|
|||||||
(define-module (e2e testing)
|
|
||||||
#:export (assert define-test run-tests run-tests-with-cleanup))
|
|
||||||
|
|
||||||
(use-modules
|
|
||||||
(sxml simple)
|
|
||||||
(srfi srfi-1))
|
|
||||||
|
|
||||||
(define *tests* (make-fluid '()))
|
|
||||||
|
|
||||||
(define (assert condition . args)
|
|
||||||
(unless condition
|
|
||||||
(let ((msg (if (null? args) "Assertion failed" (car args))))
|
|
||||||
(raise-exception `(assertion-failed . ,msg)))))
|
|
||||||
|
|
||||||
(define-syntax-rule (define-test name body ...)
|
|
||||||
(fluid-set!
|
|
||||||
*tests*
|
|
||||||
(append (fluid-ref *tests*)
|
|
||||||
(list (cons 'name (lambda () body ...))))))
|
|
||||||
|
|
||||||
(define (fail-handler ex)
|
|
||||||
(if (and (pair? ex) (eq? 'assertion-failed (car ex)))
|
|
||||||
(cons 'fail (cdr ex))
|
|
||||||
(cons 'error (format #f "~a" ex))))
|
|
||||||
|
|
||||||
(define (run-test test)
|
|
||||||
(cons (car test)
|
|
||||||
(with-exception-handler fail-handler
|
|
||||||
(lambda ()
|
|
||||||
((cdr test))
|
|
||||||
'pass)
|
|
||||||
#:unwind? #t)))
|
|
||||||
|
|
||||||
(define (fail? result)
|
|
||||||
(and (pair? (cdr result))
|
|
||||||
(eq? 'fail (cadr result))))
|
|
||||||
|
|
||||||
(define (error? result)
|
|
||||||
(and (pair? (cdr result))
|
|
||||||
(eq? 'error (cadr result))))
|
|
||||||
|
|
||||||
(define (test-junit-report result)
|
|
||||||
`(testcase
|
|
||||||
(@ (name ,(symbol->string (car result))))
|
|
||||||
,@(cond
|
|
||||||
((fail? result) `((failure (@ (message ,(cddr result))))))
|
|
||||||
((error? result) `((error (@ (message ,(cddr result))))))
|
|
||||||
(#t '()))))
|
|
||||||
|
|
||||||
(define (junit-report results fails errors)
|
|
||||||
(let ((count (length results)))
|
|
||||||
`(testsuites
|
|
||||||
(testsuite
|
|
||||||
(@ (name "wipforth e2e")
|
|
||||||
(tests ,count)
|
|
||||||
(failures ,fails)
|
|
||||||
(errors ,errors))
|
|
||||||
,@(map test-junit-report results)))))
|
|
||||||
|
|
||||||
(define (run-tests)
|
|
||||||
(let* ((results (map run-test (fluid-ref *tests*)))
|
|
||||||
(fails (length (filter fail? results)))
|
|
||||||
(errors (length (filter error? results))))
|
|
||||||
(sxml->xml (junit-report results fails errors))
|
|
||||||
(exit (if (= (+ fails errors) 0) 0 1))))
|
|
||||||
|
|
||||||
(define-syntax-rule (run-tests-with-cleanup body ...)
|
|
||||||
(dynamic-wind
|
|
||||||
(lambda () #f)
|
|
||||||
run-tests
|
|
||||||
(lambda () body ...)))
|
|
||||||
@@ -1,17 +1,16 @@
|
|||||||
const TXBUF = 0x00;
|
const TXBUF = 0;
|
||||||
const RXBUF = 0x20;
|
const RXBUF = 32;
|
||||||
const TXHEAD = 0x40;
|
const TXHEAD = 64;
|
||||||
const TXTAIL = 0x44;
|
const TXTAIL = 65;
|
||||||
const RXHEAD = 0x48;
|
const RXHEAD = 66;
|
||||||
const RXTAIL = 0x4c;
|
const RXTAIL = 67;
|
||||||
const SYSREADY = 0x50;
|
const SYSREADY = 68;
|
||||||
|
|
||||||
const TXBUF_SIZE = 32;
|
const TXBUF_SIZE = 32;
|
||||||
const RXBUF_SIZE = 32;
|
const RXBUF_SIZE = 32;
|
||||||
const PERIPHS_SIZE = 81;
|
const PERIPHS_SIZE = 69; // Nice
|
||||||
|
|
||||||
const POLL_INTERVAL_MS = 20;
|
const POLL_INTERVAL_MS = 20;
|
||||||
const DOT_INTERVAL_MS = 120;
|
|
||||||
|
|
||||||
const COLS = 80;
|
const COLS = 80;
|
||||||
const TAB_WIDTH = 8;
|
const TAB_WIDTH = 8;
|
||||||
@@ -28,7 +27,6 @@ class Emulator {
|
|||||||
this.mem_u8 = new Uint8Array(this.mem.buffer);
|
this.mem_u8 = new Uint8Array(this.mem.buffer);
|
||||||
for (let i = 0; i < PERIPHS_SIZE; ++i)
|
for (let i = 0; i < PERIPHS_SIZE; ++i)
|
||||||
this.mem_u8[i] = 0;
|
this.mem_u8[i] = 0;
|
||||||
this.mem_i32 = new Int32Array(this.mem.buffer);
|
|
||||||
|
|
||||||
this.decoder = new TextDecoder('utf-8');
|
this.decoder = new TextDecoder('utf-8');
|
||||||
this.encoder = new TextEncoder('utf-8');
|
this.encoder = new TextEncoder('utf-8');
|
||||||
@@ -51,29 +49,8 @@ class Emulator {
|
|||||||
document.addEventListener('keydown', (e) => this.handle_keydown(e));
|
document.addEventListener('keydown', (e) => this.handle_keydown(e));
|
||||||
window.addEventListener('resize', () => this.handle_resize());
|
window.addEventListener('resize', () => this.handle_resize());
|
||||||
|
|
||||||
this.prof = new Worker("prof.js");
|
this.worker = new Worker('boot.js');
|
||||||
this.prof.onmessage = (e) => {
|
this.worker.postMessage(this.mem);
|
||||||
const blob = new Blob(
|
|
||||||
[JSON.stringify(e.data)],
|
|
||||||
{ type: "application/json" });
|
|
||||||
const url = URL.createObjectURL(blob);
|
|
||||||
const a = document.createElement("a");
|
|
||||||
a.href = url;
|
|
||||||
a.download = "wipforth-profile.json";
|
|
||||||
a.click();
|
|
||||||
URL.revokeObjectURL(url);
|
|
||||||
};
|
|
||||||
|
|
||||||
this.print("Assembling kernel ");
|
|
||||||
const dots = setInterval(() => this.print("."), DOT_INTERVAL_MS);
|
|
||||||
this.worker = new Worker('boot.js', { type: 'module' });
|
|
||||||
this.worker.postMessage({ type: "load", mem: this.mem });
|
|
||||||
this.worker.onmessage = (e) => {
|
|
||||||
clearInterval(dots);
|
|
||||||
this.print(" done\n");
|
|
||||||
this.worker.postMessage({ type: "boot" });
|
|
||||||
this.prof.postMessage({ type: "start", mem: this.mem });
|
|
||||||
};
|
|
||||||
|
|
||||||
fetch('prelude.f')
|
fetch('prelude.f')
|
||||||
.then(res => res.text())
|
.then(res => res.text())
|
||||||
@@ -99,7 +76,6 @@ class Emulator {
|
|||||||
if (!this.input_enable) {
|
if (!this.input_enable) {
|
||||||
const sysready = Atomics.load(this.mem_u8, SYSREADY);
|
const sysready = Atomics.load(this.mem_u8, SYSREADY);
|
||||||
if (sysready != 0) {
|
if (sysready != 0) {
|
||||||
this.prof.postMessage({ type: "stop" });
|
|
||||||
this.input_enable = true;
|
this.input_enable = true;
|
||||||
this.flush_output();
|
this.flush_output();
|
||||||
document.getElementById('cursor').classList.add('blinking');
|
document.getElementById('cursor').classList.add('blinking');
|
||||||
@@ -127,7 +103,6 @@ class Emulator {
|
|||||||
tail = this.fifo_next(tail);
|
tail = this.fifo_next(tail);
|
||||||
} while (this.fifo_next(tail) != head && this.rx_queue.length != 0);
|
} while (this.fifo_next(tail) != head && this.rx_queue.length != 0);
|
||||||
Atomics.store(this.mem_u8, RXTAIL, tail);
|
Atomics.store(this.mem_u8, RXTAIL, tail);
|
||||||
Atomics.notify(this.mem_i32, RXTAIL / 4);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
print(str) {
|
print(str) {
|
||||||
|
|||||||
BIN
Binary file not shown.
|
Before Width: | Height: | Size: 516 B After Width: | Height: | Size: 499 B |
@@ -63,6 +63,18 @@
|
|||||||
|
|
||||||
46 EMIT
|
46 EMIT
|
||||||
|
|
||||||
|
\ Peripheral register addresses
|
||||||
|
|
||||||
|
: TXBUF 0 ;
|
||||||
|
: RXBUF 32 ;
|
||||||
|
: TXHEAD 64 ;
|
||||||
|
: TXTAIL 65 ;
|
||||||
|
: RXHEAD 66 ;
|
||||||
|
: RXTAIL 67 ;
|
||||||
|
: SYSREADY 68 ;
|
||||||
|
|
||||||
|
46 EMIT
|
||||||
|
|
||||||
\ Printing utilities
|
\ Printing utilities
|
||||||
|
|
||||||
: CR 10 EMIT ;
|
: CR 10 EMIT ;
|
||||||
@@ -100,11 +112,7 @@ CHAR . EMIT
|
|||||||
\ Print any trailing zeros
|
\ Print any trailing zeros
|
||||||
BASE @ /
|
BASE @ /
|
||||||
DUP 0<> IF
|
DUP 0<> IF
|
||||||
BEGIN
|
BEGIN CHAR 0 EMIT BASE @ / 0= UNTIL
|
||||||
CHAR 0 EMIT
|
|
||||||
BASE @ /
|
|
||||||
DUP 0=
|
|
||||||
UNTIL
|
|
||||||
THEN
|
THEN
|
||||||
|
|
||||||
2DROP
|
2DROP
|
||||||
@@ -157,10 +165,6 @@ CHAR . EMIT
|
|||||||
|
|
||||||
: NIP SWAP DROP ;
|
: NIP SWAP DROP ;
|
||||||
|
|
||||||
: HEX 16 BASE ! ;
|
|
||||||
|
|
||||||
: DECIMAL 10 BASE ! ;
|
|
||||||
|
|
||||||
: '
|
: '
|
||||||
WORD FIND DUP 0<> IF
|
WORD FIND DUP 0<> IF
|
||||||
>CFA
|
>CFA
|
||||||
@@ -206,22 +210,6 @@ CHAR . EMIT
|
|||||||
|
|
||||||
CHAR . EMIT
|
CHAR . EMIT
|
||||||
|
|
||||||
\ Peripheral register addresses
|
|
||||||
|
|
||||||
HEX
|
|
||||||
|
|
||||||
00 CONSTANT TXBUF
|
|
||||||
20 CONSTANT RXBUF
|
|
||||||
40 CONSTANT TXHEAD
|
|
||||||
44 CONSTANT TXTAIL
|
|
||||||
48 CONSTANT RXHEAD
|
|
||||||
4C CONSTANT RXTAIL
|
|
||||||
50 CONSTANT SYSREADY
|
|
||||||
|
|
||||||
DECIMAL
|
|
||||||
|
|
||||||
46 EMIT
|
|
||||||
|
|
||||||
\ A better word-not-found handler
|
\ A better word-not-found handler
|
||||||
|
|
||||||
: ANY-RX? RXHEAD AC@ RXTAIL AC@ <> ;
|
: ANY-RX? RXHEAD AC@ RXTAIL AC@ <> ;
|
||||||
@@ -248,14 +236,14 @@ CHAR . EMIT
|
|||||||
|
|
||||||
\ Version number
|
\ Version number
|
||||||
|
|
||||||
0 CONSTANT VERSION-MAJOR
|
: VERSION-MAJOR 0 ;
|
||||||
2 CONSTANT VERSION-MINOR
|
: VERSION-MINOR 1 ;
|
||||||
1 CONSTANT VERSION-PATCH
|
: VERSION-PATCH 0 ;
|
||||||
|
|
||||||
: PRINT-VERSION
|
: VERSION-PRINT
|
||||||
CHAR v EMIT VERSION-MAJOR .
|
." v" VERSION-MAJOR .
|
||||||
CHAR . EMIT VERSION-MINOR .
|
." ." VERSION-MINOR .
|
||||||
CHAR . EMIT VERSION-PATCH .
|
." ." VERSION-PATCH .
|
||||||
;
|
;
|
||||||
|
|
||||||
CHAR . EMIT
|
CHAR . EMIT
|
||||||
@@ -269,11 +257,11 @@ CHAR . EMIT
|
|||||||
." |__,__/_/ .__(_)___/_//_/" CR
|
." |__,__/_/ .__(_)___/_//_/" CR
|
||||||
." /_/ " CR
|
." /_/ " CR
|
||||||
CR
|
CR
|
||||||
." Wipforth " PRINT-VERSION CR
|
." Wipforth " VERSION-PRINT CR
|
||||||
." Copyright (c) Camden Dixie O'Brien" CR
|
." Copyright (c) Camden Dixie O'Brien" CR
|
||||||
CR
|
CR
|
||||||
." Wipforth is freely available to use, modify and distribute for personal use" CR
|
." Wipforth is available to use, modify and distribute for personal use under" CR
|
||||||
." under the Komorebi license, version 2.0.0." CR
|
." the Komorebi license, version 2.0.0." CR
|
||||||
CR
|
CR
|
||||||
;
|
;
|
||||||
|
|
||||||
|
|||||||
@@ -1,48 +0,0 @@
|
|||||||
const INTERVAL_MS = 1;
|
|
||||||
const RS_TOP_ADDR = 0x10000;
|
|
||||||
const PROF_DATA_ADDR = 0x58;
|
|
||||||
const PROF_DATA_IDX = PROF_DATA_ADDR / 8;
|
|
||||||
|
|
||||||
let mem_8;
|
|
||||||
let mem_64;
|
|
||||||
let sampler;
|
|
||||||
|
|
||||||
const samples = [];
|
|
||||||
|
|
||||||
function sample() {
|
|
||||||
const data = Atomics.load(mem_64, PROF_DATA_IDX);
|
|
||||||
const ip = Number(data & 0xffffffffn);
|
|
||||||
const rsp = Number(data >> 32n);
|
|
||||||
samples.push({ ip, rs_bytes: mem_8.slice(rsp, RS_TOP_ADDR) });
|
|
||||||
}
|
|
||||||
|
|
||||||
function i32(bytes) {
|
|
||||||
return bytes[0]
|
|
||||||
| (bytes[1] << 8)
|
|
||||||
| (bytes[2] << 16)
|
|
||||||
| (bytes[3] << 24);
|
|
||||||
}
|
|
||||||
function postproc({ ip, rs_bytes }) {
|
|
||||||
const rs = [];
|
|
||||||
for (let i = 0; i < rs_bytes.length; i += 4)
|
|
||||||
rs.push(i32(rs_bytes.slice(i, i + 4)));
|
|
||||||
rs.reverse();
|
|
||||||
return { ip, rs };
|
|
||||||
}
|
|
||||||
|
|
||||||
self.onmessage = (e) => {
|
|
||||||
switch (e.data.type) {
|
|
||||||
case "start":
|
|
||||||
console.log("Starting profiler");
|
|
||||||
mem_8 = new Uint8Array(e.data.mem.buffer);
|
|
||||||
mem_64 = new BigUint64Array(e.data.mem.buffer);
|
|
||||||
ip = e.data.ip;
|
|
||||||
rsp = e.data.rsp;
|
|
||||||
sampler = setInterval(sample, INTERVAL_MS);
|
|
||||||
break;
|
|
||||||
case "stop":
|
|
||||||
clearInterval(sample);
|
|
||||||
console.log("Stopped profiler");
|
|
||||||
self.postMessage(samples.map(postproc));
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@@ -0,0 +1,16 @@
|
|||||||
|
from http.server import HTTPServer, SimpleHTTPRequestHandler
|
||||||
|
import sys
|
||||||
|
|
||||||
|
class CORSRequestHandler(SimpleHTTPRequestHandler):
|
||||||
|
def end_headers(self):
|
||||||
|
self.send_header(
|
||||||
|
'Cross-Origin-Opener-Policy', 'same-origin')
|
||||||
|
self.send_header(
|
||||||
|
'Cross-Origin-Embedder-Policy', 'require-corp')
|
||||||
|
self.send_header(
|
||||||
|
'Cache-Control', 'no-store, no-cache, must-revalidate')
|
||||||
|
super().end_headers()
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
server = HTTPServer(('localhost', 8080), CORSRequestHandler)
|
||||||
|
server.serve_forever()
|
||||||
-81
@@ -1,81 +0,0 @@
|
|||||||
(define-module (server)
|
|
||||||
#:export (run start stop main))
|
|
||||||
|
|
||||||
(use-modules
|
|
||||||
(ice-9 atomic)
|
|
||||||
(ice-9 binary-ports)
|
|
||||||
(ice-9 threads)
|
|
||||||
(srfi srfi-9)
|
|
||||||
(web client)
|
|
||||||
(web server)
|
|
||||||
(web request)
|
|
||||||
(web response)
|
|
||||||
(web uri))
|
|
||||||
|
|
||||||
(define mime-types
|
|
||||||
'(("html" . (text/html))
|
|
||||||
("css" . (text/css))
|
|
||||||
("js" . (application/javascript))
|
|
||||||
("f" . (text/plain))
|
|
||||||
("ws" . (text/plain))
|
|
||||||
("png" . (image/png))))
|
|
||||||
|
|
||||||
(define (mime-type path)
|
|
||||||
(let* ((dot (string-rindex path #\.))
|
|
||||||
(ext (when dot (substring path (1+ dot)))))
|
|
||||||
(or (assoc-ref mime-types ext) "application/octet-stream")))
|
|
||||||
|
|
||||||
(define headers
|
|
||||||
'((cross-origin-opener-policy . "same-origin")
|
|
||||||
(cross-origin-embedder-policy . "require-corp")
|
|
||||||
(cache-control . (no-store no-cache must-revalidate))))
|
|
||||||
|
|
||||||
(define (is-dir? path)
|
|
||||||
(eq? 'directory (stat:type (stat path))))
|
|
||||||
|
|
||||||
(define (request-path request)
|
|
||||||
(let ((path (string-append "." (uri-path (request-uri request)))))
|
|
||||||
(cond ((not (file-exists? path)) #nil)
|
|
||||||
((is-dir? path) (string-append path "index.html"))
|
|
||||||
(#t path))))
|
|
||||||
|
|
||||||
(define (file-handler request body)
|
|
||||||
(let ((path (request-path request)))
|
|
||||||
(if path
|
|
||||||
(values (cons `(content-type . ,(mime-type path)) headers)
|
|
||||||
(get-bytevector-all (open-input-file path)))
|
|
||||||
(values (build-response #:code 404) #f))))
|
|
||||||
|
|
||||||
(define* (run #:key (port 8080))
|
|
||||||
(run-server file-handler 'http `(#:port ,port)))
|
|
||||||
|
|
||||||
(define-record-type <handle>
|
|
||||||
(make-handle close-flag thread port)
|
|
||||||
handle?
|
|
||||||
(close-flag handle-close-flag)
|
|
||||||
(thread handle-thread)
|
|
||||||
(port handle-port))
|
|
||||||
|
|
||||||
(define (serve impl server should-close)
|
|
||||||
(let loop ()
|
|
||||||
(unless (atomic-box-ref should-close)
|
|
||||||
(serve-one-client file-handler impl server '())
|
|
||||||
(loop)))
|
|
||||||
(close-server impl server))
|
|
||||||
|
|
||||||
(define* (start #:key (port 8080))
|
|
||||||
(let* ((impl (lookup-server-impl 'http))
|
|
||||||
(server (open-server impl `(#:port ,port)))
|
|
||||||
(should-close (make-atomic-box #f))
|
|
||||||
(thread
|
|
||||||
(call-with-new-thread
|
|
||||||
(lambda () (serve impl server should-close)))))
|
|
||||||
(make-handle should-close thread port)))
|
|
||||||
|
|
||||||
(define (stop handle)
|
|
||||||
(atomic-box-set! (handle-close-flag handle) #t)
|
|
||||||
(http-request (format #f "http://localhost:~a/" (handle-port handle)))
|
|
||||||
(join-thread (handle-thread handle)))
|
|
||||||
|
|
||||||
(when (string=? (basename (current-filename)) (car (command-line)))
|
|
||||||
(run))
|
|
||||||
@@ -1,52 +0,0 @@
|
|||||||
(add-to-load-path (dirname (current-filename)))
|
|
||||||
|
|
||||||
(use-modules
|
|
||||||
(e2e marionette)
|
|
||||||
(e2e testing)
|
|
||||||
(ice-9 regex)
|
|
||||||
((server) #:prefix server-)
|
|
||||||
(srfi srfi-1))
|
|
||||||
|
|
||||||
(define (lines s)
|
|
||||||
(string-split s #\newline))
|
|
||||||
|
|
||||||
(define (get-result-line client)
|
|
||||||
(let ((display (get-display client)))
|
|
||||||
(last (lines (string-trim-right display)))))
|
|
||||||
|
|
||||||
(define server (server-start))
|
|
||||||
(define firefox (start-firefox))
|
|
||||||
(define client (client-setup))
|
|
||||||
|
|
||||||
(navigate client "http://localhost:8080")
|
|
||||||
(sleep 5)
|
|
||||||
|
|
||||||
(define-test kernel-assembles-successfully
|
|
||||||
(let* ((display (get-display client))
|
|
||||||
(line (first (lines display))))
|
|
||||||
(assert (string-match "Assembling kernel \\.+ done" line)
|
|
||||||
(format #f "Kernel assemble line: ~s" line))))
|
|
||||||
|
|
||||||
(define-test prelude-loads-successfully
|
|
||||||
(let* ((display (get-display client))
|
|
||||||
(line (second (lines display))))
|
|
||||||
(assert (string-match "Loading prelude \\.+ done" line)
|
|
||||||
(format #f "Prelude load line: ~s" line))))
|
|
||||||
|
|
||||||
(define-test six-seven-times-dot-cr-yields-42
|
|
||||||
(input-line client "6 7 * . CR")
|
|
||||||
(let* ((result-line (get-result-line client)))
|
|
||||||
(assert (string=? "42" result-line)
|
|
||||||
(format #f "Result line: ~s" result-line))))
|
|
||||||
|
|
||||||
(define-test define-hello-then-run-hello-prints-message
|
|
||||||
(input-line client ": HELLO .\" Hello, world!\" CR ;")
|
|
||||||
(input-line client "HELLO")
|
|
||||||
(let* ((result-line (get-result-line client)))
|
|
||||||
(assert (string=? "Hello, world!" result-line)
|
|
||||||
(format #f "Result line: ~s" result-line))))
|
|
||||||
|
|
||||||
(run-tests-with-cleanup
|
|
||||||
(client-teardown client)
|
|
||||||
(close-firefox firefox)
|
|
||||||
(server-stop server))
|
|
||||||
+2009
File diff suppressed because it is too large
Load Diff
-2098
File diff suppressed because it is too large
Load Diff
@@ -1,16 +0,0 @@
|
|||||||
import { Assembler } from "./asm.js";
|
|
||||||
|
|
||||||
const asm = new Assembler();
|
|
||||||
for await (const chunk of Deno.stdin.readable) {
|
|
||||||
asm.push(chunk);
|
|
||||||
}
|
|
||||||
asm.wasm();
|
|
||||||
|
|
||||||
const defs = Object.entries(asm.defs);
|
|
||||||
while (defs[0][0] != '_DUP')
|
|
||||||
defs.shift();
|
|
||||||
while (defs.at(-1)[0] != 'WNF_HANDLER')
|
|
||||||
defs.pop();
|
|
||||||
const words = Object.fromEntries(defs.filter(([k,v]) => !k.startsWith("_")));
|
|
||||||
|
|
||||||
console.log(JSON.stringify(words));
|
|
||||||
Reference in New Issue
Block a user