this.out_src = (int) this.out_ch.add_watch (
IOCondition.OUT | IOCondition.IN | IOCondition.PRI | IOCondition.HUP | IOCondition.ERR ,
(channel, condition) => {
- return this.read(this.out_ch);
+ return this.read(channel);
+ //return this.out_ch != null ? this.read(this.out_ch) : true;
}
);
this.err_src = (int) this.err_ch.add_watch (
IOCondition.OUT | IOCondition.IN | IOCondition.PRI | IOCondition.HUP | IOCondition.ERR ,
(channel, condition) => {
- return this.read(this.err_ch);
+ return this.read(channel);
+ //return this.err_ch != null ? this.read(this.err_ch) : true;
}
);
private void tidyup()
{
- this.unref();
+ print("Tidyup\n");
if (this.pid > -1) {
Process.close_pid(this.pid); // hopefully kills it..
this.pid = -1;
//if (this.out_src > -1 ) GLib.source_remove(this.out_src);
this.err_src = -1;
this.out_src = -1;
-
+ this.unref();
}
{
string prop = (ch == this.out_ch) ? "output" : "stderr";
// print("prop: " + prop);
- if (this.pid < 0) {
- return false; // spawn complete + closed... can't read any more.
- }
+
//print(JSON.stringify(ch, null,4));
while (true) {