diff options
author | Eric Wong <normalperson@yhbt.net> | 2013-12-27 08:08:50 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2013-12-27 08:08:50 +0000 |
commit | 156bce1e6349fd6ae921bad59ad0b93081946b0c (patch) | |
tree | 93bb0c6e9a03599b2fc4248e761f19f4908643af /lib/dtas/player.rb | |
parent | df634904b60f0aa17a99afd225c58a7605c9ee37 (diff) | |
download | dtas-156bce1e6349fd6ae921bad59ad0b93081946b0c.tar.gz |
This keeps us from doing an extra IO.select when we know the sink buffer is readable (as we just registered a sink as writable).
Diffstat (limited to 'lib/dtas/player.rb')
-rw-r--r-- | lib/dtas/player.rb | 2 |
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) |