Author: fhanik
Date: Wed Jun 13 10:00:21 2007
New Revision: 546955
URL: http://svn.apache.org/viewvc?view=rev&rev=546955
Log:
fix for BZ 42648
http://issues.apache.org/bugzilla/show_bug.cgi?id=42648
Modified:
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReplicationTask.java
Modified:
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReplicationTask.java
URL:
http://svn.apache.org/viewvc/tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReplicationTask.java?view=diff&rev=546955&r1=546954&r2=546955
==============================================================================
---
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReplicationTask.java
(original)
+++
tomcat/tc6.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReplicationTask.java
Wed Jun 13 10:00:21 2007
@@ -63,12 +63,15 @@
// loop forever waiting for work to do
public synchronized void run() {
- if ( (getOptions() & OPTION_DIRECT_BUFFER) == OPTION_DIRECT_BUFFER ) {
- buffer = ByteBuffer.allocateDirect(getRxBufSize());
- }else {
- buffer = ByteBuffer.allocate (getRxBufSize());
+ if ( buffer == null ) {
+ if ( (getOptions() & OPTION_DIRECT_BUFFER) ==
OPTION_DIRECT_BUFFER) {
+ buffer = ByteBuffer.allocateDirect(getRxBufSize());
+ } else {
+ buffer = ByteBuffer.allocate(getRxBufSize());
+ }
+ } else {
+ buffer.clear();
}
-
if (key == null) {
return; // just in case
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
