Author: fhanik
Date: Mon Mar 13 14:27:30 2006
New Revision: 385682
URL: http://svn.apache.org/viewcvs?rev=385682&view=rev
Log:
Added in a multi threaded blocking io sender
Added:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/etc/cluster-server.xml
Modified: tomcat/container/tc5.5.x/modules/groupcom/etc/cluster-server.xml
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/etc/cluster-server.xml?rev=385682&r1=385681&r2=385682&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/etc/cluster-server.xml (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/etc/cluster-server.xml Mon Mar 13
14:27:30 2006
@@ -316,7 +316,7 @@
autoConnect="true"
poolSize="25"/>
<!--
- <transport
className="org.apache.catalina.tribes.tcp.bio.MultipointBioSender"
+ <transport
className="org.apache.catalina.tribes.tcp.bio.PooledMultiSender"
maxRetryAttempts="2"
timeout="15000"
waitForAck="true"
Added:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java?rev=385682&view=auto
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java
(added)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java
Mon Mar 13 14:27:30 2006
@@ -0,0 +1,71 @@
+package org.apache.catalina.tribes.tcp.bio;
+
+import org.apache.catalina.tribes.tcp.DataSender;
+import org.apache.catalina.tribes.tcp.PooledSender;
+
+/**
+ * <p>Title: </p>
+ *
+ * <p>Description: </p>
+ *
+ * <p>Copyright: Copyright (c) 2005</p>
+ *
+ * <p>Company: </p>
+ *
+ * @author not attributable
+ * @version 1.0
+ */
+public class PooledMultiSender extends PooledSender {
+
+ protected long timeout = 15000;
+ protected boolean waitForAck = false;
+ protected int retryAttempts=0;
+ protected int keepAliveCount = Integer.MAX_VALUE;
+ protected boolean directBuf = false;
+ protected int rxBufSize = 43800;
+ protected int txBufSize = 25188;
+ protected boolean suspect = false;
+ private boolean autoConnect;
+
+
+ public PooledMultiSender() {
+ }
+
+ /**
+ * getNewDataSender
+ *
+ * @return DataSender
+ * @todo Implement this org.apache.catalina.tribes.tcp.PooledSender
+ * method
+ */
+ public DataSender getNewDataSender() {
+ MultipointBioSender sender = new MultipointBioSender();
+ sender.setAutoConnect(autoConnect);
+ sender.setTimeout(timeout);
+ sender.setWaitForAck(waitForAck);
+ sender.setMaxRetryAttempts(retryAttempts);
+ sender.setRxBufSize(rxBufSize);
+ sender.setTxBufSize(txBufSize);
+ return sender;
+ }
+
+ public void setAutoConnect(boolean autoConnect) {
+ this.autoConnect = autoConnect;
+ }
+
+ public void setDirectBuf(boolean directBuf) {
+ this.directBuf = directBuf;
+ }
+
+ public void setKeepAliveCount(int keepAliveCount) {
+ this.keepAliveCount = keepAliveCount;
+ }
+
+ public void setRetryAttempts(int retryAttempts) {
+ this.retryAttempts = retryAttempts;
+ }
+
+ public void setSuspect(boolean suspect) {
+ this.suspect = suspect;
+ }
+}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
