+
+using GLib;
// compile valac
/// # valac --pkg gio-2.0 --pkg posix Spawn.vala -o /tmp/Spawn
static int main (string[] args) {
// A reference to our file
- var cfg = new SpawnConfig(null, { "ls" } , "");
+ var cfg = new SpawnConfig("", { "ls" } , { "" });
var spawn = new Spawn(cfg);
*
*
*/
-delegate void SpawnOutput(string line);
-delegate void SpawnErr(string line);
-delegate string SpawnInput();
+public delegate void SpawnOutput(string line);
+public delegate void SpawnErr(string line);
+public delegate string SpawnInput();
}
+errordomain SpawnError {
+ NO_ARGS
+}
+
/**
* @class Spawn
* @param cfg {SpawnConfig} settings - see properties.
public class Spawn : Object
{
-
+ SpawnConfig cfg;
public Spawn(SpawnConfig cfg) throws Error
{
this.cfg = cfg;
- this.cwd = this.cfg.cwd.length || GLib.get_home_dir();
- if (!this.cfg.args.length) {
- throw new Error("No arguments");
+ this.cfg.cwd = this.cfg.cwd.length < 1 ? GLib.Environment.get_home_dir() : this.cfg.cwd;
+ if (this.cfg.args.length < 0) {
+ throw new SpawnError.NO_ARGS("No arguments");
}
this.run();
int standard_error;
- var ret = {};
if (this.cfg.debug) {
- print("cd " + this.cfg.cwd +";" + string.joinv(" ", this.cfg.args));
+ stdout.printf("cd %s; %s" , this.cfg.cwd , string.joinv(" ", this.cfg.args));
}
Process.spawn_async_with_pipes (
//print(JSON.stringify(gret));
if (this.cfg.debug) {
- print("PID: " + this.pid);
+ stdout.print("PID: %d" ,this.pid);
}
ChildWatch.add (this.pid, (w_pid, result) => {
- this.in_ch = new GLib.IOChannel.unix_new(ret.standard_input);
- this.out_ch = new GLib.IOChannel.unix_new(ret.standard_output);
- this.err_ch = new GLib.IOChannel.unix_new(ret.standard_error);
+ this.in_ch = new GLib.IOChannel.unix_new(standard_input);
+ this.out_ch = new GLib.IOChannel.unix_new(standard_output);
+ this.err_ch = new GLib.IOChannel.unix_new(standard_error);
// make everything non-blocking!
+
+ // using NONBLOCKING only works if io_add_watch
+ //returns true/false in right conditions
+ this.in_ch.set_flags (GLib.IOFlags.NONBLOCK);
+ this.out_ch.set_flags (GLib.IOFlags.NONBLOCK);
+ this.err_ch.set_flags (GLib.IOFlags.NONBLOCK);
+
- // using NONBLOCKING only works if io_add_watch
- //returns true/false in right conditions
- this.in_ch.set_flags (GLib.IOFlags.NONBLOCK);
- this.out_ch.set_flags (GLib.IOFlags.NONBLOCK);
- this.err_ch.set_flags (GLib.IOFlags.NONBLOCK);
-
-
-
- // add handlers for output and stderr.
-
- this.out_src = this.out_ch.add_watch (
- IOCondition.OUT | IOCondition.IN | IOCondition.PRI | IOCondition.HUP | IOCondition.ERR ,
- (channel, condition) => {
- return this.read(_this.out_ch);
- }
- );
+
+ // add handlers for output and stderr.
+
+ this.out_src = this.out_ch.add_watch (
+ IOCondition.OUT | IOCondition.IN | IOCondition.PRI | IOCondition.HUP | IOCondition.ERR ,
+ (channel, condition) => {
+ return this.read(_this.out_ch);
+ }
+ );
this.err_src = this.err_ch.add_watch (
IOCondition.OUT | IOCondition.IN | IOCondition.PRI | IOCondition.HUP | IOCondition.ERR ,
- (channel, condition) => {
- return this.read(_this.err_ch);
- }
- );
-
+ (channel, condition) => {
+ return this.read(_this.err_ch);
+ }
+ );
+
// call input..
if (this.pid > -1) {