Add channel and no-escape integration tests, LSP protocol tests, and worker_pool example. Run channel/spawn tests under TSan in CI and add a large-codegen compile check.

Author: Cod-e-Codes

.github/workflows/ci.yml

@@ -67,6 +67,44 @@ jobs:
           test_array_to_slice_coercion 10
           EOF
 
+      - name: Generated C thread sanitizer (Linux)
+        shell: bash
+        env:
+          COMPILER: ${{ github.workspace }}/target/release/ion-compiler
+          CC: gcc
+          CFLAGS: -fsanitize=thread -fno-omit-frame-pointer
+          LDFLAGS: -fsanitize=thread
+        run: |
+          cd tests
+          "$CC" $CFLAGS -c ../runtime/ion_runtime.c -I. -I.. -I../runtime -o .ion_test_runtime_tsan.o
+          while IFS=$'\t' read -r test kind expected _rest; do
+            [ "$kind" = "run" ] || continue
+            case "$test" in
+              test_channel_*|test_spawn_*) ;;
+              *) continue ;;
+            esac
+            [ -f "${test}.ion" ] || continue
+            "$COMPILER" "${test}.ion" >/dev/null
+            "$CC" $CFLAGS "${test}.c" .ion_test_runtime_tsan.o -I. -I.. -I../runtime -lpthread $LDFLAGS -o "$test"
+            set +e
+            "./$test" >/dev/null
+            status=$?
+            set -e
+            if [ "$status" -ne "$expected" ]; then
+              echo "$test: expected exit $expected, got $status"
+              exit 1
+            fi
+            rm -f "${test}.c" "$test"
+          done < <(awk -F '\t' 'NR > 1 && $2 == "run" && ($1 ~ /^test_channel_/ || $1 ~ /^test_spawn_/) { print $1, $2, $3 }' test_expectations.tsv)
+
+      - name: Large codegen smoke (Linux)
+        shell: bash
+        env:
+          COMPILER: ${{ github.workspace }}/target/release/ion-compiler
+          CC: gcc
+          CFLAGS: -Wall -Wextra -Werror
+        run: bash tests/large_codegen_smoke.sh
+
       - name: Generated C warning-clean (Linux)
         shell: bash
         env:

Cargo.lock

@@ -22,3 +22,7 @@ tokio = { version = "1.48.0", features = ["full"] }
 toml = "1.1.2"
 tower-lsp = "0.20.0"
 
+[dev-dependencies]
+tempfile = "3.27.0"
+url = "2.5.8"
+

Cargo.toml

@@ -180,6 +180,7 @@ On Linux or macOS, use `./target/release/ion-build` and drop `.exe`. Windows cha
 | [minimal/](examples/minimal/) | Smallest valid program |
 | [spawn_channel/](examples/spawn_channel/) | `spawn` with cross-thread channels |
 | [channel_worker/](examples/channel_worker/) | Channel worker |
+| [worker_pool/](examples/worker_pool/) | Three workers with per-worker job/result channels |
 | [showcase/](examples/showcase/) | Mixed language features |
 | [access_log/](examples/access_log/) | Log parsing, spawn, channels, fmt/io |
 | [http_server/](examples/http_server/) | Sockets FFI, spawn per client, stdin `quit` to stop; see [http_server/README.md](examples/http_server/README.md) |

README.md

@@ -0,0 +1,5 @@
+name = "worker_pool"
+main = "worker_pool.ion"
+output = "worker_pool"
+mode = "single"
+out_dir = "target"

examples/worker_pool/ion.toml

@@ -0,0 +1,46 @@
+// Three workers; per-worker job and result channels.
+fn worker_count() -> int {
+    return 3;
+}
+
+fn jobs_per_worker() -> int {
+    return 4;
+}
+
+fn main() -> int {
+    let mut grand_total: int = 0;
+    let mut w: int = 0;
+    while w < worker_count() {
+        let (job_tx, job_rx): (Sender<int>, Receiver<int>) = channel<int>();
+        let (result_tx, result_rx): (Sender<int>, Receiver<int>) = channel<int>();
+
+        spawn {
+            let mut rx: Receiver<int> = job_rx;
+            let mut sum: int = 0;
+            let mut j: int = 0;
+            while j < jobs_per_worker() {
+                let job: int = recv(&mut rx);
+                sum = sum + job;
+                j = j + 1;
+            }
+            send(&result_tx, sum);
+        };
+
+        let mut job_id: int = 1;
+        while job_id <= jobs_per_worker() {
+            let payload: int = (w + 1) * 100 + job_id;
+            send(&job_tx, payload);
+            job_id = job_id + 1;
+        }
+
+        let mut result_rx_mut: Receiver<int> = result_rx;
+        let partial: int = recv(&mut result_rx_mut);
+        grand_total = grand_total + partial;
+        w = w + 1;
+    }
+
+    if grand_total != 2430 {
+        return 1;
+    }
+    return 0;
+}

examples/worker_pool/worker_pool.ion

@@ -1,2 +1,5 @@
 pub mod server;
 pub mod util;
+
+#[cfg(test)]
+mod tests;