Skip to content

Add stereo glut engine #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Add stereo glut engine #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
259 changes: 259 additions & 0 deletions Engine_StereoGlut.sc
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,259 @@

Engine_StereoGlut : CroneEngine {
classvar nvoices = 7;

var pg;
var effect;
var <buffers;
var <voices;
var mixBus;
var <phases;
var <levels;

var <seek_tasks;

*new { arg context, doneCallback;
^super.new(context, doneCallback);
}

// disk read
readBuf { arg i, path;
if(buffers[i].notNil, {
if (File.exists(path), {
var temp = Buffer.read(context.server, path, 0, 1, {
// get a temporary buffer to get the number of channels. In its callback, get two channels.
// This is because grainbuf is single channel.
if (temp.numChannels == 1, {
var newbuf = Buffer.readChannel(context.server, path, 0, -1, [0], {
voices[i].set(\buf1, newbuf, \buf2, newbuf);
buffers[i].do(_.free);
buffers[i] = [newbuf];
});
});
if (temp.numChannels == 2, {
var newbuf = [nil, nil];
var c = CondVar();
var remaining = 2;
2.do { |j|
newbuf[j] = Buffer.readChannel(context.server, path, 0, -1, [j], {
remaining = remaining - 1;
c.signalOne;
});
};
fork {
while { remaining > 0 } { c.wait() };
// at this point the buffer should be loaded.
voices[i].set(\buf1, newbuf[0], \buf2, newbuf[1]);
buffers[i].do(_.free);
buffers[i] = newbuf;
};
});
});
});
});
}

alloc {
buffers = Array.fill(nvoices, { arg i;
[Buffer.alloc(
context.server,
context.server.sampleRate * 1,
)];
});

SynthDef(\synth, {
arg out, phase_out, level_out, buf1, buf2,
gate=0, pos=0, speed=1, jitter=0,
size=0.1, density=20, pitch=1, spread=0, gain=1, envscale=1,
freeze=0, t_reset_pos=0;

var grain_trig;
var jitter_sig;
var buf_dur;
var pan_sig;
var buf_pos;
var pos_sig;
var sig;

var env;
var level;

grain_trig = Impulse.kr(density);
buf_dur = BufDur.kr(buf1);

pan_sig = TRand.kr(trig: grain_trig, lo: spread.neg, hi: spread);

jitter_sig = TRand.kr(trig: grain_trig,
lo: buf_dur.reciprocal.neg * jitter,
hi: buf_dur.reciprocal * jitter);

buf_pos = Phasor.kr(trig: t_reset_pos,
rate: buf_dur.reciprocal / ControlRate.ir * speed,
resetPos: pos);

pos_sig = Wrap.kr(Select.kr(freeze, [buf_pos, pos]));

sig = Mix.ar(GrainBuf.ar(2, grain_trig, size, [buf1, buf2], pitch, pos_sig + jitter_sig, 2, ([-1, 1] + pan_sig).clip(-1, 1)))/2;
env = EnvGen.kr(Env.asr(1, 1, 1), gate: gate, timeScale: envscale);

level = env;

Out.ar(out, sig * level * gain);
Out.kr(phase_out, pos_sig);
// ignore gain for level out
Out.kr(level_out, level);
}).add;

SynthDef(\effect, {
arg in, out, mix=0.5, room=0.5, damp=0.5;
var sig = In.ar(in, 2);
sig = FreeVerb.ar(sig, mix, room, damp);
Out.ar(out, sig);
}).add;

context.server.sync;

// mix bus for all synth outputs
mixBus = Bus.audio(context.server, 2);

effect = Synth.new(\effect, [\in, mixBus.index, \out, context.out_b.index], target: context.xg);

phases = Array.fill(nvoices, { arg i; Bus.control(context.server); });
levels = Array.fill(nvoices, { arg i; Bus.control(context.server); });

pg = ParGroup.head(context.xg);

voices = Array.fill(nvoices, { arg i;
Synth.new(\synth, [
\out, mixBus.index,
\phase_out, phases[i].index,
\level_out, levels[i].index,
\buf1, buffers[i][0],
\buf2, buffers[i][0]
], target: pg);
});

context.server.sync;

this.addCommand("reverb_mix", "f", { arg msg; effect.set(\mix, msg[1]); });
this.addCommand("reverb_room", "f", { arg msg; effect.set(\room, msg[1]); });
this.addCommand("reverb_damp", "f", { arg msg; effect.set(\damp, msg[1]); });

this.addCommand("read", "is", { arg msg;
this.readBuf(msg[1] - 1, msg[2]);
});

this.addCommand("seek", "if", { arg msg;
var voice = msg[1] - 1;
var lvl, pos;
var seek_rate = 1 / 750;

seek_tasks[voice].stop;

// TODO: async get
lvl = levels[voice].getSynchronous();

if (false, { // disable seeking until fully implemented
var step;
var target_pos;

// TODO: async get
pos = phases[voice].getSynchronous();
voices[voice].set(\freeze, 1);

target_pos = msg[2];
step = (target_pos - pos) * seek_rate;

seek_tasks[voice] = Routine {
while({ abs(target_pos - pos) > abs(step) }, {
pos = pos + step;
voices[voice].set(\pos, pos);
seek_rate.wait;
});

voices[voice].set(\pos, target_pos);
voices[voice].set(\freeze, 0);
voices[voice].set(\t_reset_pos, 1);
};

seek_tasks[voice].play();
}, {
pos = msg[2];

voices[voice].set(\pos, pos);
voices[voice].set(\t_reset_pos, 1);
voices[voice].set(\freeze, 0);
});
});

this.addCommand("gate", "ii", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\gate, msg[2]);
});

this.addCommand("speed", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\speed, msg[2]);
});

this.addCommand("jitter", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\jitter, msg[2]);
});

this.addCommand("size", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\size, msg[2]);
});

this.addCommand("density", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\density, msg[2]);
});

this.addCommand("pitch", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\pitch, msg[2]);
});

this.addCommand("spread", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\spread, msg[2]);
});

this.addCommand("volume", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\gain, msg[2]);
});

this.addCommand("envscale", "if", { arg msg;
var voice = msg[1] - 1;
voices[voice].set(\envscale, msg[2]);
});

nvoices.do({ arg i;
this.addPoll(("phase_" ++ (i+1)).asSymbol, {
var val = phases[i].getSynchronous;
val
});

this.addPoll(("level_" ++ (i+1)).asSymbol, {
var val = levels[i].getSynchronous;
val
});
});

seek_tasks = Array.fill(nvoices, { arg i;
Routine {}
});
}

free {
voices.do({ arg voice; voice.free; });
phases.do({ arg bus; bus.free; });
levels.do({ arg bus; bus.free; });
buffers.do({ arg b; b.do(_.free); });
effect.free;
mixBus.free;
}
}
3 changes: 1 addition & 2 deletions glut.lua
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
-- patterns using grid row 1
--

engine.name = 'Glut'
engine.name = 'StereoGlut'
local g = grid.connect()

local VOICES = 7
Expand Down Expand Up @@ -291,7 +291,6 @@ function init()
metro_blink:start()

local sep = ": "

params:add_taper("reverb_mix", "*"..sep.."mix", 0, 100, 50, 0, "%")
params:set_action("reverb_mix", function(value) engine.reverb_mix(value / 100) end)

Expand Down