Author: rgodfrey
Date: Wed Jun 27 15:26:13 2012
New Revision: 1354577
URL: http://svn.apache.org/viewvc?rev=1354577&view=rev
Log:
NO-JIRA : [Proton-j] implement unsettled count
Modified:
qpid/proton/trunk/proton-j/jproton.py
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/Link.java
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/DeliveryImpl.java
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
Modified: qpid/proton/trunk/proton-j/jproton.py
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/jproton.py?rev=1354577&r1=1354576&r2=1354577&view=diff
==============================================================================
--- qpid/proton/trunk/proton-j/jproton.py (original)
+++ qpid/proton/trunk/proton-j/jproton.py Wed Jun 27 15:26:13 2012
@@ -379,3 +379,6 @@ def pn_credit(l):
def pn_queued(l):
return l.getQueued()
+
+def pn_unsettled(l):
+ return l.getUnsettled()
Modified: qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/Link.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/Link.java?rev=1354577&r1=1354576&r2=1354577&view=diff
==============================================================================
--- qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/Link.java
(original)
+++ qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/Link.java Wed
Jun 27 15:26:13 2012
@@ -65,5 +65,6 @@ public interface Link extends Endpoint
public int getCredit();
public int getQueued();
+ public int getUnsettled();
}
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/DeliveryImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/DeliveryImpl.java?rev=1354577&r1=1354576&r2=1354577&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/DeliveryImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/DeliveryImpl.java
Wed Jun 27 15:26:13 2012
@@ -60,6 +60,7 @@ public class DeliveryImpl implements Del
{
_tag = tag;
_link = link;
+ _link.incrementUnsettled();
_linkPrevious = previous;
if(previous != null)
{
@@ -106,6 +107,7 @@ public class DeliveryImpl implements Del
public void settle()
{
_settled = true;
+ _link.decrementUnsettled();
setTransportFlag(DELIVERY_STATE_CHANGED);
}
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java?rev=1354577&r1=1354576&r2=1354577&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/LinkImpl.java
Wed Jun 27 15:26:13 2012
@@ -39,6 +39,7 @@ public abstract class LinkImpl extends E
private String _remoteTargetAddress;
private int _queued;
private int _credit;
+ private int _unsettled;
private LinkNode<LinkImpl> _node;
@@ -256,4 +257,19 @@ public abstract class LinkImpl extends E
{
_queued--;
}
+
+ public int getUnsettled()
+ {
+ return _unsettled;
+ }
+
+ void incrementUnsettled()
+ {
+ _unsettled++;
+ }
+
+ void decrementUnsettled()
+ {
+ _unsettled--;
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
