[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH] dtas-tl: speed up prune by pipelining requests
From: |
Eric Wong |
Subject: |
[PATCH] dtas-tl: speed up prune by pipelining requests |
Date: |
Mon, 3 Jul 2023 01:11:18 +0000 |
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
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [PATCH] dtas-tl: speed up prune by pipelining requests,
Eric Wong <=