tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fha...@apache.org
Subject svn commit: r385682 - in /tomcat/container/tc5.5.x/modules/groupcom: etc/cluster-server.xml src/share/org/apache/catalina/tribes/tcp/bio/PooledMultiSender.java
Date Mon, 13 Mar 2006 22:27:30 GMT
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: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message