Author: rhs
Date: Wed Oct 15 12:45:47 2014
New Revision: 1632004
URL: http://svn.apache.org/r1632004
Log:
PROTON-714: don't overflow the input buffer
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java?rev=1632004&r1=1632003&r2=1632004&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
Wed Oct 15 12:45:47 2014
@@ -125,7 +125,13 @@ public class SimpleSslTransportWrapper i
} else {
ByteBuffer tail = _underlyingInput.tail();
_decodedInputBuffer.flip();
+ int limit = _decodedInputBuffer.limit();
+ int overflow = _decodedInputBuffer.remaining() - capacity;
+ if (overflow > 0) {
+ _decodedInputBuffer.limit(limit - overflow);
+ }
tail.put(_decodedInputBuffer);
+ _decodedInputBuffer.limit(limit);
_decodedInputBuffer.compact();
_underlyingInput.process();
capacity = _underlyingInput.capacity();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
