PROTON-898: Update Ruby bindings to use pn_selectable_get_fd Also removed references to pending and capacity.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/caaabb7b Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/caaabb7b Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/caaabb7b Branch: refs/heads/master Commit: caaabb7bd225aae8d3699ce138ef43c1083782a6 Parents: b49e518 Author: Darryl L. Pierce <mcpie...@gmail.com> Authored: Mon Jun 1 13:48:09 2015 -0400 Committer: Darryl L. Pierce <mcpie...@gmail.com> Committed: Thu Jun 4 09:11:58 2015 -0400 ---------------------------------------------------------------------- examples/ruby/messenger/nonblocking_recv.rb | 7 ++----- proton-c/bindings/ruby/lib/messenger/selectable.rb | 2 +- 2 files changed, 3 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/caaabb7b/examples/ruby/messenger/nonblocking_recv.rb ---------------------------------------------------------------------- diff --git a/examples/ruby/messenger/nonblocking_recv.rb b/examples/ruby/messenger/nonblocking_recv.rb index 2868b52..09dc3f9 100644 --- a/examples/ruby/messenger/nonblocking_recv.rb +++ b/examples/ruby/messenger/nonblocking_recv.rb @@ -76,8 +76,6 @@ loop do write_array.delete(sel) sel.free else - sel.capacity - sel.pending if !sel.registered? read_array << sel write_array << sel @@ -102,8 +100,8 @@ loop do result.flatten.each do |io| sel = selectables[io.fileno] - sel.writable if sel.pending > 0 - sel.readable if sel.capacity > 0 + sel.writable + sel.readable end end @@ -145,4 +143,3 @@ loop do end messenger.stop - http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/caaabb7b/proton-c/bindings/ruby/lib/messenger/selectable.rb ---------------------------------------------------------------------- diff --git a/proton-c/bindings/ruby/lib/messenger/selectable.rb b/proton-c/bindings/ruby/lib/messenger/selectable.rb index 9a61317..ec5174f 100644 --- a/proton-c/bindings/ruby/lib/messenger/selectable.rb +++ b/proton-c/bindings/ruby/lib/messenger/selectable.rb @@ -44,7 +44,7 @@ module Qpid::Proton::Messenger # This can be used in conjunction with the IO class. # def fileno - Cproton.pn_selectable_fd(@impl) + Cproton.pn_selectable_get_fd(@impl) end def to_io --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
