Author: rjung
Date: Tue Jun 30 15:24:01 2009
New Revision: 789794
URL: http://svn.apache.org/viewvc?rev=789794&view=rev
Log:
Remove trailing whitespace - no functional change.
Modified:
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java
Modified:
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java
URL:
http://svn.apache.org/viewvc/tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java?rev=789794&r1=789793&r2=789794&view=diff
==============================================================================
---
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java
(original)
+++
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java
Tue Jun 30 15:24:01 2009
@@ -74,7 +74,7 @@
* recover timeout ( default 5 secs)
*/
private long recoverTimeout = 5000;
-
+
/**
* number of recover tries
*/
@@ -113,7 +113,7 @@
super(domain,host, port);
checkThread();
}
-
+
// ------------------------------------------------------------- Properties
/**
@@ -126,14 +126,14 @@
return (info);
}
-
+
/**
* get current add wait timeout
* @return current wait timeout
*/
public long getQueueAddWaitTimeout() {
-
+
return queue.getAddWaitTimeout();
}
@@ -197,7 +197,7 @@
public void setQueueTimeWait(boolean timeWait) {
queue.setTimeWait(timeWait);
}
-
+
/**
* @return Returns the inQueueCounter.
*/
@@ -252,7 +252,7 @@
* @return current push message recover timeout
*/
public long getRecoverTimeout() {
-
+
return recoverTimeout;
}
@@ -269,7 +269,7 @@
* @return current push message recover counter
*/
public int getRecoverCounter() {
-
+
return recoverCounter;
}
@@ -422,7 +422,7 @@
private class FastQueueThread extends Thread {
-
+
/**
* Sender queue
*/
@@ -443,7 +443,7 @@
*/
private long queuedNrOfBytes = 0;
-
+
/**
* Only use inside FastAsyncSocketSender
@@ -455,14 +455,14 @@
this.queue = queue;
this.sender = sender;
}
-
+
/**
* @return Returns the queuedNrOfBytes.
*/
public long getQueuedNrOfBytes() {
return queuedNrOfBytes;
}
-
+
protected void setQueuedNrOfBytes(long queuedNrOfBytes) {
this.queuedNrOfBytes = queuedNrOfBytes;
}
@@ -470,7 +470,7 @@
protected void incQueuedNrOfBytes(long size) {
queuedNrOfBytes += size;
}
-
+
protected void decQueuedNrOfBytes(long size) {
queuedNrOfBytes -= size;
}
@@ -482,8 +482,8 @@
public void stopRunning() {
keepRunning = false;
}
-
-
+
+
/**
* Get the objects from queue and send all mesages to the sender.
* @see java.lang.Runnable#run()
@@ -557,7 +557,7 @@
counter++;
}
} while (keepRunning && !success && counter <=
rCounter);
-
+
if(!success) {
log.warn(sm.getString(
"AsyncSocketSender.send.error", entry
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
