about summary refs log tree commit homepage
path: root/lib/dtas/player.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/dtas/player.rb')
-rw-r--r--lib/dtas/player.rb2
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/dtas/player.rb b/lib/dtas/player.rb
index 04c03b0..f935d4c 100644
--- a/lib/dtas/player.rb
+++ b/lib/dtas/player.rb
@@ -312,7 +312,7 @@ class DTAS::Player # :nodoc:
     case rv = buf.broadcast(targets)
     when Array # array of blocked sinks
       # have sinks wake up the this buffer when they're writable
-      trade_ctl = proc { @srv.wait_ctl(buf, :wait_readable) }
+      trade_ctl = proc { @srv.wait_ctl(buf, :hot_read) }
       rv.each do |dst|
         dst.on_writable = trade_ctl
         @srv.wait_ctl(dst, :wait_writable)