From 8460df3e4e3320006ab945dfbbf01474387f1e13 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Mon, 26 Aug 2013 06:16:39 +0000 Subject: player: sink ed pipe_size= disallows nils While we're at it, add a test for this functionality, too. --- lib/dtas/player/client_handler.rb | 2 +- lib/dtas/sink.rb | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) (limited to 'lib') diff --git a/lib/dtas/player/client_handler.rb b/lib/dtas/player/client_handler.rb index d580695..7028c5e 100644 --- a/lib/dtas/player/client_handler.rb +++ b/lib/dtas/player/client_handler.rb @@ -141,7 +141,7 @@ module DTAS::Player::ClientHandler # :nodoc: rv = set_bool(io, kv, v) { |b| sink.__send__("#{k}=", b) } rv == true or return rv when "pipe_size" - rv = set_uint(io, kv, v, true) { |u| sink.__send__("#{k}=", u) } + rv = set_uint(io, kv, v, false) { |u| sink.pipe_size = u } rv == true or return rv when "command" # nothing to validate, this could be "rm -rf /" :> sink.command = v.empty? ? DTAS::Sink::SINK_DEFAULTS["command"] : v diff --git a/lib/dtas/sink.rb b/lib/dtas/sink.rb index 836b0f1..7ecc52b 100644 --- a/lib/dtas/sink.rb +++ b/lib/dtas/sink.rb @@ -15,6 +15,7 @@ class DTAS::Sink # :nodoc: attr_accessor :prio # any Integer attr_accessor :active # boolean attr_accessor :name + attr_accessor :pipe_size attr_accessor :nonblock include DTAS::Command -- cgit v1.2.3-24-ge0c7