- public GitMonitor () {
-
-
+ public GitMonitor ()
+ {
this.queue = new Array<GitMonitorQueue>();
GitMonitor.gitmonitor = this;
-
-
-
-
Timeout.add_full(Priority.LOW, 500, () => {
-
+
//GLib.debug("TIMEOUT queue length = %d, is_runing = %s\n", (int)this.queue.length , this.queueRunning ? "Y" : "N");
//stdout.printf("QL %u: QR: %d\n", this.queue.length, this.queueRunning ? 1 : 0);
return true; //
});
-
}
public new void pauseError(string failure)
this.paused = true;
+ var leave_queued = new Gee.ArrayList<GitMonitorQueue>();
GLib.debug("GitMonitor.runQueue - creating repos");
for(var i = 0; i < cmds.length; i++) {
var cmd = cmds.index(i);
var gitpath = cmd.gitpath;
+
+ var repo = GitRepo.get( gitpath );
+ if ( !repo.isWipBranch()) {
+ leave_queued.add(cmd);
+ continue;
+ }
+
GLib.debug("GitMonitor.runQueue - finding %s", cmd.gitpath);
var ix = GitRepo.indexOf(repo_list, cmd.gitpath);
if (ix < 0) {
- repo_list.append_val(new GitRepo( gitpath ));
+ repo_list.append_val( GitRepo.get( gitpath ));
ix = GitRepo.indexOf(repo_list, cmd.gitpath);
}
GLib.debug("GitMonitor.runQueue - adding to repolist %d", ix);