added more shim for selectabes; cat and echo still don't work because you can't select on files in java
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/5ed6de43 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/5ed6de43 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/5ed6de43 Branch: refs/heads/proton-j-reactor Commit: 5ed6de4321037fda7e8fd4730aab5b10a70c84bc Parents: a3d9d43 Author: Rafael Schloming <r...@alum.mit.edu> Authored: Thu Jun 18 06:53:23 2015 -0400 Committer: Rafael Schloming <r...@alum.mit.edu> Committed: Thu Jun 18 06:53:23 2015 -0400 ---------------------------------------------------------------------- proton-j/src/main/resources/cengine.py | 6 ++++-- proton-j/src/main/resources/cobject.py | 3 +++ proton-j/src/main/resources/creactor.py | 3 +++ 3 files changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/5ed6de43/proton-j/src/main/resources/cengine.py ---------------------------------------------------------------------- diff --git a/proton-j/src/main/resources/cengine.py b/proton-j/src/main/resources/cengine.py index b5cd703..5ecaaad 100644 --- a/proton-j/src/main/resources/cengine.py +++ b/proton-j/src/main/resources/cengine.py @@ -1052,7 +1052,7 @@ def pn_event_transport(event): from org.apache.qpid.proton.engine.impl import ConnectionImpl, SessionImpl, \ SenderImpl, ReceiverImpl, DeliveryImpl, TransportImpl -from org.apache.qpid.proton.reactor.impl import TaskImpl +from org.apache.qpid.proton.reactor.impl import TaskImpl, SelectableImpl J2C = { ConnectionImpl: "pn_connection", @@ -1061,7 +1061,8 @@ J2C = { ReceiverImpl: "pn_link", DeliveryImpl: "pn_delivery", TransportImpl: "pn_transport", - TaskImpl: "pn_task" + TaskImpl: "pn_task", + SelectableImpl: "pn_selectable" } wrappers = { @@ -1071,6 +1072,7 @@ wrappers = { "pn_delivery": lambda x: wrap(x, pn_delivery_wrapper), "pn_transport": lambda x: wrap(x, pn_transport_wrapper), "pn_task": lambda x: x, + "pn_selectable": lambda x: x, "pn_void": lambda x: x } http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/5ed6de43/proton-j/src/main/resources/cobject.py ---------------------------------------------------------------------- diff --git a/proton-j/src/main/resources/cobject.py b/proton-j/src/main/resources/cobject.py index 140e62a..33ab438 100644 --- a/proton-j/src/main/resources/cobject.py +++ b/proton-j/src/main/resources/cobject.py @@ -47,6 +47,9 @@ def pn_cast_pn_reactor(obj): def pn_cast_pn_task(obj): return obj +def pn_cast_pn_selectable(obj): + return obj + PN_PYREF = None def pn_record_def(record, key, clazz): http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/5ed6de43/proton-j/src/main/resources/creactor.py ---------------------------------------------------------------------- diff --git a/proton-j/src/main/resources/creactor.py b/proton-j/src/main/resources/creactor.py index d21e830..e179b23 100644 --- a/proton-j/src/main/resources/creactor.py +++ b/proton-j/src/main/resources/creactor.py @@ -72,6 +72,9 @@ def pn_task_attachments(t): def pn_selectable_attachments(s): return s.attachments() +def pn_selectable_set_fd(s, fd): + s.setChannel(fd.getChannel()) + def pn_acceptor_close(a): a.close() --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org