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: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org