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: [email protected]
For additional commands, e-mail: [email protected]
