diff options
author | Kazuki Yamaguchi <k@rhe.jp> | 2015-08-11 21:45:33 +0900 |
---|---|---|
committer | Kazuki Yamaguchi <k@rhe.jp> | 2015-08-11 21:45:33 +0900 |
commit | 30b571999a425468d85e354f4958e8d970764f41 (patch) | |
tree | b12957d6315ebe266f4fea07230db1def602a77c | |
parent | 86f634da361f61628ff145f061609eb7ffdbff14 (diff) | |
download | plum-30b571999a425468d85e354f4958e8d970764f41.tar.gz |
remove odd 'local_error' methods
-rw-r--r-- | lib/plum/connection.rb | 4 | ||||
-rw-r--r-- | lib/plum/flow_control.rb | 2 | ||||
-rw-r--r-- | lib/plum/stream.rb | 4 |
3 files changed, 2 insertions, 8 deletions
diff --git a/lib/plum/connection.rb b/lib/plum/connection.rb index ca6280d..188b172 100644 --- a/lib/plum/connection.rb +++ b/lib/plum/connection.rb @@ -196,9 +196,5 @@ module Plum send_immediately Frame.ping(:ack, opaque_data) end end - - def local_error - ConnectionError - end end end diff --git a/lib/plum/flow_control.rb b/lib/plum/flow_control.rb index 539ae8b..27f39bf 100644 --- a/lib/plum/flow_control.rb +++ b/lib/plum/flow_control.rb @@ -61,6 +61,7 @@ module Plum when :data @recv_remaining_window -= frame.length if @recv_remaining_window < 0 + local_error = (Connection === self) ? ConnectionError : StreamError raise local_error.new(:flow_control_error) end end @@ -85,6 +86,7 @@ module Plum wsi = r_wsi & ~(1 << 31) if wsi == 0 + local_error = (Connection === self) ? ConnectionError : StreamError raise local_error.new(:protocol_error) end diff --git a/lib/plum/stream.rb b/lib/plum/stream.rb index ee37f38..46fad40 100644 --- a/lib/plum/stream.rb +++ b/lib/plum/stream.rb @@ -213,9 +213,5 @@ module Plum @state = :closed # MUST NOT send RST_STREAM end - - def local_error - StreamError - end end end |