[PATCH] dtas-tl: speed up prune by pipelining requests

[PATCH] dtas-tl: speed up prune by pipelining requests

[Eric Wong]

We are safely be able to pipeline 10 requests via SOCK_SEQPACKET
on any OS without hitting buffering limits.
---
 bin/dtas-tl | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/bin/dtas-tl b/bin/dtas-tl
index 45a18b5..66e0612 100755
--- a/bin/dtas-tl
+++ b/bin/dtas-tl
@@ -138,6 +138,8 @@ def add_after(c, argv, last_id)
 when 'cat'
   each_track(c) { |line| print "#{line}\n" }
 when 'prune'
+  c2 = nil
+  pending = 0
   each_track(c) do |line|
     line.sub!(/\A(\d+)=/n, '') or abort "unexpected line=#{line.inspect}\n"
     track_id = $1.to_i
@@ -149,7 +151,19 @@ def add_after(c, argv, last_id)
       warn "# #{line}: #{e.class}"
       # raise other exceptions
     end
-    c.req("tl remove #{track_id}") unless ok
+    unless ok
+      c2 ||= DTAS::UNIXClient.new
+      if pending > 5
+        c2.res_wait
+        pending -= 1
+      end
+      pending += 1
+      c2.req_start("tl remove #{track_id}")
+    end
+  end
+  while pending > 0
+    c2.res_wait
+    pending -= 1
   end
 when 'aac' # add-after-current
   ARGV.shift