summaryrefslogtreecommitdiff
path: root/workers.go
diff options
context:
space:
mode:
Diffstat (limited to 'workers.go')
-rw-r--r--workers.go12
1 files changed, 11 insertions, 1 deletions
diff --git a/workers.go b/workers.go
index 03c9072..91f9eaf 100644
--- a/workers.go
+++ b/workers.go
@@ -9,7 +9,6 @@ func worker(queue chan *Utterance, done chan bool, worknumber int, geshaft chan
return
}
select {
-
case ut := <-queue:
if err := cutoutClipAndTranscode(ut); err == nil {
geshaft <- ut
@@ -21,3 +20,14 @@ func worker(queue chan *Utterance, done chan bool, worknumber int, geshaft chan
}
}
}
+
+func cutterQueue(fQueue chan string, workerID int) {
+ for {
+ if len(fQueue) == 0 {
+ fmt.Println("empty queue, number", workerID)
+ return
+ }
+ fpath := <-fQueue
+ cutOnEqualParts(fpath, segmentSize)
+ }
+}