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 2014/07/17 21:52:51 UTC
svn commit: r1611459 -
/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
Author: rhs
Date: Thu Jul 17 19:52:50 2014
New Revision: 1611459
URL: http://svn.apache.org/r1611459
Log:
added size tracking for transport work list
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
Modified: qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java
URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java?rev=1611459&r1=1611458&r2=1611459&view=diff
==============================================================================
--- qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java (original)
+++ qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ConnectionImpl.java Thu Jul 17 19:52:50 2014
@@ -52,6 +52,7 @@ public class ConnectionImpl extends Endp
private TransportImpl _transport;
private DeliveryImpl _transportWorkHead;
private DeliveryImpl _transportWorkTail;
+ private int _transportWorkSize = 0;
private String _localContainerId = "";
private String _localHostname = "";
private String _remoteContainer;
@@ -500,6 +501,10 @@ public class ConnectionImpl extends Endp
return _transportWorkHead;
}
+ int getTransportWorkSize() {
+ return _transportWorkSize;
+ }
+
public void removeTransportWork(DeliveryImpl delivery)
{
if (!delivery._transportWork) return;
@@ -528,6 +533,7 @@ public class ConnectionImpl extends Endp
}
delivery._transportWork = false;
+ _transportWorkSize--;
}
void addTransportWork(DeliveryImpl delivery)
@@ -549,6 +555,7 @@ public class ConnectionImpl extends Endp
}
delivery._transportWork = true;
+ _transportWorkSize++;
}
void workUpdate(DeliveryImpl delivery)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org