You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2015/07/06 01:45:33 UTC
[32/38] qpid-proton git commit: added more shim for selectabes;
cat and echo still don't work because you can't select on files in
java
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/master
Commit: 5ed6de4321037fda7e8fd4730aab5b10a70c84bc
Parents: a3d9d43
Author: Rafael Schloming <rh...@alum.mit.edu>
Authored: Thu Jun 18 06:53:23 2015 -0400
Committer: Rafael Schloming <rh...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org