You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/11/14 12:03:16 UTC
[07/50] [abbrv] qpid-proton git commit: Renamed PN_{CONNECTION,
SESSION, LINK}_{OPEN, CLOSE} to PN_{CONNECTION, SESSION, LINK}_LOCAL_{OPEN,
CLOSE}
Renamed PN_{CONNECTION,SESSION,LINK}_{OPEN,CLOSE} to PN_{CONNECTION,SESSION,LINK}_LOCAL_{OPEN,CLOSE}
git-svn-id: https://svn.apache.org/repos/asf/qpid/proton/trunk@1631542 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/4e7e432a
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/4e7e432a
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/4e7e432a
Branch: refs/heads/examples
Commit: 4e7e432a05e46a56ac7fc1f3e198a2f1d992cde2
Parents: a4ad521
Author: Rafael H. Schloming <rh...@apache.org>
Authored: Mon Oct 13 20:50:51 2014 +0000
Committer: Rafael H. Schloming <rh...@apache.org>
Committed: Mon Oct 13 20:50:51 2014 +0000
----------------------------------------------------------------------
proton-c/bindings/python/proton.py | 14 ++++-----
proton-c/include/proton/event.h | 20 +++++++------
proton-c/src/engine/engine.c | 8 +++---
proton-c/src/events/event.c | 28 +++++++++---------
proton-c/src/messenger/messenger.c | 14 ++++-----
.../org/apache/qpid/proton/engine/Event.java | 16 +++++------
.../qpid/proton/engine/impl/ConnectionImpl.java | 4 +--
.../qpid/proton/engine/impl/LinkImpl.java | 6 ++--
.../qpid/proton/engine/impl/SessionImpl.java | 4 +--
proton-j/src/main/resources/cengine.py | 14 ++++-----
tests/python/proton_tests/engine.py | 30 ++++++++++----------
11 files changed, 80 insertions(+), 78 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-c/bindings/python/proton.py
----------------------------------------------------------------------
diff --git a/proton-c/bindings/python/proton.py b/proton-c/bindings/python/proton.py
index b5df542..4d2f3e4 100644
--- a/proton-c/bindings/python/proton.py
+++ b/proton-c/bindings/python/proton.py
@@ -3380,23 +3380,23 @@ class Event:
CONNECTION_INIT = PN_CONNECTION_INIT
CONNECTION_BOUND = PN_CONNECTION_BOUND
CONNECTION_UNBOUND = PN_CONNECTION_UNBOUND
- CONNECTION_OPEN = PN_CONNECTION_OPEN
- CONNECTION_CLOSE = PN_CONNECTION_CLOSE
+ CONNECTION_LOCAL_OPEN = PN_CONNECTION_LOCAL_OPEN
+ CONNECTION_LOCAL_CLOSE = PN_CONNECTION_LOCAL_CLOSE
CONNECTION_REMOTE_OPEN = PN_CONNECTION_REMOTE_OPEN
CONNECTION_REMOTE_CLOSE = PN_CONNECTION_REMOTE_CLOSE
CONNECTION_FINAL = PN_CONNECTION_FINAL
SESSION_INIT = PN_SESSION_INIT
- SESSION_OPEN = PN_SESSION_OPEN
- SESSION_CLOSE = PN_SESSION_CLOSE
+ SESSION_LOCAL_OPEN = PN_SESSION_LOCAL_OPEN
+ SESSION_LOCAL_CLOSE = PN_SESSION_LOCAL_CLOSE
SESSION_REMOTE_OPEN = PN_SESSION_REMOTE_OPEN
SESSION_REMOTE_CLOSE = PN_SESSION_REMOTE_CLOSE
SESSION_FINAL = PN_SESSION_FINAL
LINK_INIT = PN_LINK_INIT
- LINK_OPEN = PN_LINK_OPEN
- LINK_CLOSE = PN_LINK_CLOSE
- LINK_DETACH = PN_LINK_DETACH
+ LINK_LOCAL_OPEN = PN_LINK_LOCAL_OPEN
+ LINK_LOCAL_CLOSE = PN_LINK_LOCAL_CLOSE
+ LINK_LOCAL_DETACH = PN_LINK_LOCAL_DETACH
LINK_REMOTE_OPEN = PN_LINK_REMOTE_OPEN
LINK_REMOTE_CLOSE = PN_LINK_REMOTE_CLOSE
LINK_REMOTE_DETACH = PN_LINK_REMOTE_DETACH
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-c/include/proton/event.h
----------------------------------------------------------------------
diff --git a/proton-c/include/proton/event.h b/proton-c/include/proton/event.h
index 97095c6..c843fee 100644
--- a/proton-c/include/proton/event.h
+++ b/proton-c/include/proton/event.h
@@ -94,12 +94,14 @@ typedef enum {
PN_CONNECTION_INIT,
/**
- * The connection has been bound to a transport.
+ * The connection has been bound to a transport. This event is
+ * issued when the ::pn_transport_bind() operation is invoked.
*/
PN_CONNECTION_BOUND,
/**
- * The connection has been unbound from its transport.
+ * The connection has been unbound from its transport. This event is
+ * issued when the ::pn_transport_unbind() operation is invoked.
*/
PN_CONNECTION_UNBOUND,
@@ -107,7 +109,7 @@ typedef enum {
* The local connection endpoint has been closed. Events of this
* type point to the relevant connection.
*/
- PN_CONNECTION_OPEN,
+ PN_CONNECTION_LOCAL_OPEN,
/**
* The remote endpoint has opened the connection. Events of this
@@ -119,7 +121,7 @@ typedef enum {
* The local connection endpoint has been closed. Events of this
* type point to the relevant connection.
*/
- PN_CONNECTION_CLOSE,
+ PN_CONNECTION_LOCAL_CLOSE,
/**
* The remote endpoint has closed the connection. Events of this
@@ -144,7 +146,7 @@ typedef enum {
* The local session endpoint has been opened. Events of this type
* point ot the relevant session.
*/
- PN_SESSION_OPEN,
+ PN_SESSION_LOCAL_OPEN,
/**
* The remote endpoint has opened the session. Events of this type
@@ -156,7 +158,7 @@ typedef enum {
* The local session endpoint has been closed. Events of this type
* point ot the relevant session.
*/
- PN_SESSION_CLOSE,
+ PN_SESSION_LOCAL_CLOSE,
/**
* The remote endpoint has closed the session. Events of this type
@@ -181,7 +183,7 @@ typedef enum {
* The local link endpoint has been opened. Events of this type
* point ot the relevant link.
*/
- PN_LINK_OPEN,
+ PN_LINK_LOCAL_OPEN,
/**
* The remote endpoint has opened the link. Events of this type
@@ -193,7 +195,7 @@ typedef enum {
* The local link endpoint has been closed. Events of this type
* point ot the relevant link.
*/
- PN_LINK_CLOSE,
+ PN_LINK_LOCAL_CLOSE,
/**
* The remote endpoint has closed the link. Events of this type
@@ -205,7 +207,7 @@ typedef enum {
* The local link endpoint has been detached. Events of this type
* point to the relevant link.
*/
- PN_LINK_DETACH,
+ PN_LINK_LOCAL_DETACH,
/**
* The remote endpoint has detached the link. Events of this type
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-c/src/engine/engine.c
----------------------------------------------------------------------
diff --git a/proton-c/src/engine/engine.c b/proton-c/src/engine/engine.c
index 46bf462..494c2d9 100644
--- a/proton-c/src/engine/engine.c
+++ b/proton-c/src/engine/engine.c
@@ -52,12 +52,12 @@ pn_connection_t *pn_ep_get_connection(pn_endpoint_t *endpoint)
static pn_event_type_t endpoint_event(pn_endpoint_type_t type, bool open) {
switch (type) {
case CONNECTION:
- return open ? PN_CONNECTION_OPEN : PN_CONNECTION_CLOSE;
+ return open ? PN_CONNECTION_LOCAL_OPEN : PN_CONNECTION_LOCAL_CLOSE;
case SESSION:
- return open ? PN_SESSION_OPEN : PN_SESSION_CLOSE;
+ return open ? PN_SESSION_LOCAL_OPEN : PN_SESSION_LOCAL_CLOSE;
case SENDER:
case RECEIVER:
- return open ? PN_LINK_OPEN : PN_LINK_CLOSE;
+ return open ? PN_LINK_LOCAL_OPEN : PN_LINK_LOCAL_CLOSE;
default:
assert(false);
return PN_EVENT_NONE;
@@ -267,7 +267,7 @@ void pn_link_detach(pn_link_t *link)
{
assert(link);
link->detached = true;
- pn_collector_put(link->session->connection->collector, PN_OBJECT, link, PN_LINK_DETACH);
+ pn_collector_put(link->session->connection->collector, PN_OBJECT, link, PN_LINK_LOCAL_DETACH);
pn_modified(link->session->connection, &link->endpoint, true);
}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-c/src/events/event.c
----------------------------------------------------------------------
diff --git a/proton-c/src/events/event.c b/proton-c/src/events/event.c
index 95aeb03..94c8edf 100644
--- a/proton-c/src/events/event.c
+++ b/proton-c/src/events/event.c
@@ -242,40 +242,40 @@ const char *pn_event_type_name(pn_event_type_t type)
return "PN_CONNECTION_UNBOUND";
case PN_CONNECTION_REMOTE_OPEN:
return "PN_CONNECTION_REMOTE_OPEN";
- case PN_CONNECTION_OPEN:
- return "PN_CONNECTION_OPEN";
+ case PN_CONNECTION_LOCAL_OPEN:
+ return "PN_CONNECTION_LOCAL_OPEN";
case PN_CONNECTION_REMOTE_CLOSE:
return "PN_CONNECTION_REMOTE_CLOSE";
- case PN_CONNECTION_CLOSE:
- return "PN_CONNECTION_CLOSE";
+ case PN_CONNECTION_LOCAL_CLOSE:
+ return "PN_CONNECTION_LOCAL_CLOSE";
case PN_CONNECTION_FINAL:
return "PN_CONNECTION_FINAL";
case PN_SESSION_INIT:
return "PN_SESSION_INIT";
case PN_SESSION_REMOTE_OPEN:
return "PN_SESSION_REMOTE_OPEN";
- case PN_SESSION_OPEN:
- return "PN_SESSION_OPEN";
+ case PN_SESSION_LOCAL_OPEN:
+ return "PN_SESSION_LOCAL_OPEN";
case PN_SESSION_REMOTE_CLOSE:
return "PN_SESSION_REMOTE_CLOSE";
- case PN_SESSION_CLOSE:
- return "PN_SESSION_CLOSE";
+ case PN_SESSION_LOCAL_CLOSE:
+ return "PN_SESSION_LOCAL_CLOSE";
case PN_SESSION_FINAL:
return "PN_SESSION_FINAL";
case PN_LINK_INIT:
return "PN_LINK_INIT";
case PN_LINK_REMOTE_OPEN:
return "PN_LINK_REMOTE_OPEN";
- case PN_LINK_OPEN:
- return "PN_LINK_OPEN";
+ case PN_LINK_LOCAL_OPEN:
+ return "PN_LINK_LOCAL_OPEN";
case PN_LINK_REMOTE_CLOSE:
return "PN_LINK_REMOTE_CLOSE";
- case PN_LINK_DETACH:
- return "PN_LINK_DETACH";
+ case PN_LINK_LOCAL_DETACH:
+ return "PN_LINK_LOCAL_DETACH";
case PN_LINK_REMOTE_DETACH:
return "PN_LINK_REMOTE_DETACH";
- case PN_LINK_CLOSE:
- return "PN_LINK_CLOSE";
+ case PN_LINK_LOCAL_CLOSE:
+ return "PN_LINK_LOCAL_CLOSE";
case PN_LINK_FLOW:
return "PN_LINK_FLOW";
case PN_LINK_FINAL:
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-c/src/messenger/messenger.c
----------------------------------------------------------------------
diff --git a/proton-c/src/messenger/messenger.c b/proton-c/src/messenger/messenger.c
index 7c098a3..f0df36a 100644
--- a/proton-c/src/messenger/messenger.c
+++ b/proton-c/src/messenger/messenger.c
@@ -1266,22 +1266,22 @@ int pn_messenger_process_events(pn_messenger_t *messenger)
break;
case PN_CONNECTION_REMOTE_OPEN:
case PN_CONNECTION_REMOTE_CLOSE:
- case PN_CONNECTION_OPEN:
- case PN_CONNECTION_CLOSE:
+ case PN_CONNECTION_LOCAL_OPEN:
+ case PN_CONNECTION_LOCAL_CLOSE:
pn_messenger_process_connection(messenger, event);
break;
case PN_SESSION_REMOTE_OPEN:
case PN_SESSION_REMOTE_CLOSE:
- case PN_SESSION_OPEN:
- case PN_SESSION_CLOSE:
+ case PN_SESSION_LOCAL_OPEN:
+ case PN_SESSION_LOCAL_CLOSE:
pn_messenger_process_session(messenger, event);
break;
case PN_LINK_REMOTE_OPEN:
case PN_LINK_REMOTE_CLOSE:
case PN_LINK_REMOTE_DETACH:
- case PN_LINK_OPEN:
- case PN_LINK_CLOSE:
- case PN_LINK_DETACH:
+ case PN_LINK_LOCAL_OPEN:
+ case PN_LINK_LOCAL_CLOSE:
+ case PN_LINK_LOCAL_DETACH:
pn_messenger_process_link(messenger, event);
break;
case PN_LINK_FLOW:
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
index a0a2e95..3ffd414 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/Event.java
@@ -33,26 +33,26 @@ public interface Event
CONNECTION_INIT,
CONNECTION_BOUND,
CONNECTION_UNBOUND,
- CONNECTION_OPEN,
+ CONNECTION_LOCAL_OPEN,
CONNECTION_REMOTE_OPEN,
- CONNECTION_CLOSE,
+ CONNECTION_LOCAL_CLOSE,
CONNECTION_REMOTE_CLOSE,
CONNECTION_FINAL,
SESSION_INIT,
- SESSION_OPEN,
+ SESSION_LOCAL_OPEN,
SESSION_REMOTE_OPEN,
- SESSION_CLOSE,
+ SESSION_LOCAL_CLOSE,
SESSION_REMOTE_CLOSE,
SESSION_FINAL,
LINK_INIT,
- LINK_OPEN,
+ LINK_LOCAL_OPEN,
LINK_REMOTE_OPEN,
- LINK_CLOSE,
- LINK_REMOTE_CLOSE,
- LINK_DETACH,
+ LINK_LOCAL_DETACH,
LINK_REMOTE_DETACH,
+ LINK_LOCAL_CLOSE,
+ LINK_REMOTE_CLOSE,
LINK_FLOW,
LINK_FINAL,
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
index 736d93c..9a27c1a 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
@@ -617,12 +617,12 @@ public class ConnectionImpl extends EndpointImpl implements ProtonJConnection
@Override
void localOpen()
{
- put(Event.Type.CONNECTION_OPEN, this);
+ put(Event.Type.CONNECTION_LOCAL_OPEN, this);
}
@Override
void localClose()
{
- put(Event.Type.CONNECTION_CLOSE, this);
+ put(Event.Type.CONNECTION_LOCAL_CLOSE, this);
}
}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
index 0da2a60..2190ced 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/LinkImpl.java
@@ -391,19 +391,19 @@ public abstract class LinkImpl extends EndpointImpl implements Link
@Override
void localOpen()
{
- getConnectionImpl().put(Event.Type.LINK_OPEN, this);
+ getConnectionImpl().put(Event.Type.LINK_LOCAL_OPEN, this);
}
@Override
void localClose()
{
- getConnectionImpl().put(Event.Type.LINK_CLOSE, this);
+ getConnectionImpl().put(Event.Type.LINK_LOCAL_CLOSE, this);
}
public void detach()
{
_detached = true;
- getConnectionImpl().put(Event.Type.LINK_DETACH, this);
+ getConnectionImpl().put(Event.Type.LINK_LOCAL_DETACH, this);
modified();
}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
----------------------------------------------------------------------
diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
index 26ad9ca..5eb55f5 100644
--- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
+++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/SessionImpl.java
@@ -204,12 +204,12 @@ public class SessionImpl extends EndpointImpl implements ProtonJSession
@Override
void localOpen()
{
- getConnectionImpl().put(Event.Type.SESSION_OPEN, this);
+ getConnectionImpl().put(Event.Type.SESSION_LOCAL_OPEN, this);
}
@Override
void localClose()
{
- getConnectionImpl().put(Event.Type.SESSION_CLOSE, this);
+ getConnectionImpl().put(Event.Type.SESSION_LOCAL_CLOSE, this);
}
}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/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 102ee77..63603bc 100644
--- a/proton-j/src/main/resources/cengine.py
+++ b/proton-j/src/main/resources/cengine.py
@@ -954,23 +954,23 @@ from org.apache.qpid.proton.engine import Event
PN_CONNECTION_INIT = Event.Type.CONNECTION_INIT
PN_CONNECTION_BOUND = Event.Type.CONNECTION_BOUND
PN_CONNECTION_UNBOUND = Event.Type.CONNECTION_UNBOUND
-PN_CONNECTION_OPEN = Event.Type.CONNECTION_OPEN
+PN_CONNECTION_LOCAL_OPEN = Event.Type.CONNECTION_LOCAL_OPEN
PN_CONNECTION_REMOTE_OPEN = Event.Type.CONNECTION_REMOTE_OPEN
-PN_CONNECTION_CLOSE = Event.Type.CONNECTION_CLOSE
+PN_CONNECTION_LOCAL_CLOSE = Event.Type.CONNECTION_LOCAL_CLOSE
PN_CONNECTION_REMOTE_CLOSE = Event.Type.CONNECTION_REMOTE_CLOSE
PN_CONNECTION_FINAL = Event.Type.CONNECTION_FINAL
PN_SESSION_INIT = Event.Type.SESSION_INIT
-PN_SESSION_OPEN = Event.Type.SESSION_OPEN
+PN_SESSION_LOCAL_OPEN = Event.Type.SESSION_LOCAL_OPEN
PN_SESSION_REMOTE_OPEN = Event.Type.SESSION_REMOTE_OPEN
-PN_SESSION_CLOSE = Event.Type.SESSION_CLOSE
+PN_SESSION_LOCAL_CLOSE = Event.Type.SESSION_LOCAL_CLOSE
PN_SESSION_REMOTE_CLOSE = Event.Type.SESSION_REMOTE_CLOSE
PN_SESSION_FINAL = Event.Type.SESSION_FINAL
PN_LINK_INIT = Event.Type.LINK_INIT
-PN_LINK_OPEN = Event.Type.LINK_OPEN
+PN_LINK_LOCAL_OPEN = Event.Type.LINK_LOCAL_OPEN
PN_LINK_REMOTE_OPEN = Event.Type.LINK_REMOTE_OPEN
-PN_LINK_CLOSE = Event.Type.LINK_CLOSE
+PN_LINK_LOCAL_CLOSE = Event.Type.LINK_LOCAL_CLOSE
PN_LINK_REMOTE_CLOSE = Event.Type.LINK_REMOTE_CLOSE
-PN_LINK_DETACH = Event.Type.LINK_DETACH
+PN_LINK_LOCAL_DETACH = Event.Type.LINK_LOCAL_DETACH
PN_LINK_REMOTE_DETACH = Event.Type.LINK_REMOTE_DETACH
PN_LINK_FLOW = Event.Type.LINK_FLOW
PN_LINK_FINAL = Event.Type.LINK_FINAL
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4e7e432a/tests/python/proton_tests/engine.py
----------------------------------------------------------------------
diff --git a/tests/python/proton_tests/engine.py b/tests/python/proton_tests/engine.py
index c821107..d35f518 100644
--- a/tests/python/proton_tests/engine.py
+++ b/tests/python/proton_tests/engine.py
@@ -2139,13 +2139,13 @@ class EventTest(CollectorTest):
rcv = ssn2.receiver("receiver")
rcv.open()
self.pump()
- self.expect(Event.CONNECTION_OPEN, Event.TRANSPORT,
- Event.SESSION_INIT, Event.SESSION_OPEN,
- Event.TRANSPORT, Event.LINK_INIT, Event.LINK_OPEN,
+ self.expect(Event.CONNECTION_LOCAL_OPEN, Event.TRANSPORT,
+ Event.SESSION_INIT, Event.SESSION_LOCAL_OPEN,
+ Event.TRANSPORT, Event.LINK_INIT, Event.LINK_LOCAL_OPEN,
Event.TRANSPORT)
rcv.close()
- self.expect(Event.LINK_CLOSE, Event.TRANSPORT)
+ self.expect(Event.LINK_LOCAL_CLOSE, Event.TRANSPORT)
self.pump()
rcv.free()
del rcv
@@ -2209,7 +2209,7 @@ class EventTest(CollectorTest):
rcv.flow(10)
self.pump()
self.expect(Event.CONNECTION_INIT, Event.SESSION_INIT,
- Event.LINK_INIT, Event.LINK_OPEN, Event.TRANSPORT)
+ Event.LINK_INIT, Event.LINK_LOCAL_OPEN, Event.TRANSPORT)
snd.delivery("delivery")
snd.send("Hello World!")
snd.advance()
@@ -2229,7 +2229,7 @@ class EventTest(CollectorTest):
dlv = snd.delivery("delivery")
snd.send("Hello World!")
assert snd.advance()
- self.expect(Event.LINK_OPEN, Event.TRANSPORT)
+ self.expect(Event.LINK_LOCAL_OPEN, Event.TRANSPORT)
self.pump()
self.expect(Event.LINK_FLOW)
rdlv = rcv.current
@@ -2276,7 +2276,7 @@ class EventTest(CollectorTest):
t.bind(c)
c.open()
- self.expect(Event.CONNECTION_BOUND, Event.CONNECTION_OPEN, Event.TRANSPORT)
+ self.expect(Event.CONNECTION_BOUND, Event.CONNECTION_LOCAL_OPEN, Event.TRANSPORT)
c2 = Connection()
t2 = Transport()
@@ -2293,7 +2293,7 @@ class EventTest(CollectorTest):
pump(t, t2)
- self.expect(Event.CONNECTION_CLOSE, Event.TRANSPORT,
+ self.expect(Event.CONNECTION_LOCAL_CLOSE, Event.TRANSPORT,
Event.TRANSPORT_HEAD_CLOSED, Event.TRANSPORT_CLOSED)
def testLinkDetach(self):
@@ -2307,7 +2307,7 @@ class EventTest(CollectorTest):
l1 = s1.sender("asdf")
l1.open()
l1.detach()
- self.expect_until(Event.LINK_DETACH, Event.TRANSPORT)
+ self.expect_until(Event.LINK_LOCAL_DETACH, Event.TRANSPORT)
c2 = Connection()
c2.collect(self.collector)
@@ -2339,15 +2339,15 @@ class TeardownLeakTest(PeerTest):
def doLeak(self, local, remote):
self.connection.open()
self.expect(Event.CONNECTION_INIT, Event.CONNECTION_BOUND,
- Event.CONNECTION_OPEN, Event.TRANSPORT)
+ Event.CONNECTION_LOCAL_OPEN, Event.TRANSPORT)
ssn = self.connection.session()
ssn.open()
- self.expect(Event.SESSION_INIT, Event.SESSION_OPEN, Event.TRANSPORT)
+ self.expect(Event.SESSION_INIT, Event.SESSION_LOCAL_OPEN, Event.TRANSPORT)
snd = ssn.sender("sender")
snd.open()
- self.expect(Event.LINK_INIT, Event.LINK_OPEN, Event.TRANSPORT)
+ self.expect(Event.LINK_INIT, Event.LINK_LOCAL_OPEN, Event.TRANSPORT)
self.pump()
@@ -2364,11 +2364,11 @@ class TeardownLeakTest(PeerTest):
if local:
snd.close() # ha!!
- self.expect(Event.LINK_CLOSE, Event.TRANSPORT)
+ self.expect(Event.LINK_LOCAL_CLOSE, Event.TRANSPORT)
ssn.close()
- self.expect(Event.SESSION_CLOSE, Event.TRANSPORT)
+ self.expect(Event.SESSION_LOCAL_CLOSE, Event.TRANSPORT)
self.connection.close()
- self.expect(Event.CONNECTION_CLOSE, Event.TRANSPORT)
+ self.expect(Event.CONNECTION_LOCAL_CLOSE, Event.TRANSPORT)
if remote:
self.peer.link_head(0).close() # ha!!
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org