It's a proper library now!

Author: eeeeeta

Cargo.lock

@@ -1,11 +1,14 @@
 [package]
-name = "sqa-ng"
+name = "sqa-engine"
 version = "0.0.1"
 authors = ["eeeeeta <eeeeeta@users.noreply.github.com>"]
 
 [dependencies]
-sqa-jack = "0.1"
+sqa-jack = "0.3"
 bounded-spsc-queue = { git = "https://github.com/eeeeeta/bounded-spsc-queue", rev = "542e581" }
 time = "0.1"
 arrayvec = "0.3"
 hound = "3.0"
+error-chain = "0.7"
+parking_lot = "0.3"
+uuid = { version = "0.3", features = ["v4"] }

Cargo.toml

@@ -0,0 +1,81 @@
+#![feature(step_by)]
+
+extern crate hound;
+extern crate sqa_engine;
+use std::thread;
+use std::io::{self, Read};
+use sqa_engine::{EngineContext, jack, Sender};
+fn main() {
+    let mut ec = EngineContext::new(None).unwrap();
+    let mut reader = hound::WavReader::open("test.wav").unwrap();
+    let mut chans = vec![];
+    let mut ctls = vec![];
+    for ch in 0..reader.spec().channels*16 {
+        let st = format!("channel {}", ch);
+        let p = ec.new_channel(&st).unwrap();
+        let mut send = ec.new_sender(reader.spec().sample_rate as u64);
+        send.set_output_patch(p);
+        ctls.push(send.make_plain());
+        chans.push((p, send));
+    }
+    for (i, port) in ec.conn.get_ports(None, None, Some(jack::PORT_IS_INPUT | jack::PORT_IS_PHYSICAL)).unwrap().into_iter().enumerate() {
+        if i % 2 == 0 {
+            for ch in (0..chans.len()).step_by(2) {
+                ec.conn.connect_ports(&ec.chans[chans[ch].0], &port).unwrap();
+            }
+        }
+        else {
+            for ch in (1..chans.len()).step_by(2) {
+                ec.conn.connect_ports(&ec.chans[chans[ch].0], &port).unwrap();
+            }
+        }
+
+    }
+    let _ = thread::spawn(move || {
+        let mut idx = 0;
+        let mut cnt = 0;
+        for samp in reader.samples::<f32>() {
+            let samp = samp.unwrap();
+            for ch in (idx..chans.len()).step_by(2) {
+                chans[ch].1.buf.push(samp * 0.1);
+            }
+            idx += 1;
+            cnt += 1;
+            if cnt == 500_000 {
+                println!("Haha, random buffering fail for 5 seconds!!!");
+                ::std::thread::sleep(::std::time::Duration::new(5, 0));
+                println!("Alright, panic over.");
+            }
+            if idx >= 2 {
+                idx = 0;
+            }
+        }
+    });
+    println!("*** Press Enter to begin playback!");
+    io::stdin().read(&mut [0u8]).unwrap();
+    let time = Sender::<()>::precise_time_ns();
+    for ch in ctls.iter_mut() {
+        ch.set_start_time(time);
+        ch.set_active(true);
+    }
+    let mut secs = 0;
+    loop {
+        thread::sleep(::std::time::Duration::new(1, 0));
+        secs += 1;
+        println!("{}: {} samples - vol {}", ctls[0].position(), ctls[0].position_samples(), ctls[0].volume());
+        if secs == 20 {
+            println!("Haha, some sadist set ch0's active to false for 5 seconds!!!");
+            ctls[0].set_active(false);
+        }
+        if secs == 25 {
+            ctls[0].set_active(true);
+            println!("Alright, panic over.");
+        }
+        if secs > 25 && secs < 36 {
+            ctls[0].set_volume((secs - 25) as f32 * 0.1);
+        }
+        if secs > 60 {
+            break;
+        }
+    }
+}

examples/wav.rs

@@ -0,0 +1,15 @@
+use sqa_jack;
+error_chain! {
+    types {
+        Error, ErrorKind, ChainErr, EngineResult;
+    }
+    links {
+        Jack(sqa_jack::errors::Error, sqa_jack::errors::ErrorKind);
+    }
+    errors {
+        LimitExceeded {
+            description("You have exceeded the channel or sender limit.")
+                display("Engine channel or sender limit exceeded")
+        }
+    }
+}