You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by bl...@apache.org on 2004/12/15 18:10:42 UTC
svn commit: r112000 - /incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java /incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java
Author: bloritsch
Date: Wed Dec 15 09:10:40 2004
New Revision: 112000
URL: http://svn.apache.org/viewcvs?view=rev&rev=112000
Log:
Almost remove the blocking for the pipes
Modified:
incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java
incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java
Modified: incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java
Url: http://svn.apache.org/viewcvs/incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java?view=diff&rev=112000&p1=incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java&r1=111999&p2=incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java&r2=112000
==============================================================================
--- incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java (original)
+++ incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/SEDAServer.java Wed Dec 15 09:10:40 2004
@@ -26,12 +26,13 @@
import org.apache.protocol.ProtocolProvider;
import org.d_haven.event.command.ThreadManager;
import org.d_haven.event.command.DefaultThreadManager;
+import org.d_haven.event.command.ThreadPolicy;
+import org.d_haven.event.command.ProcessorBoundThreadPolicy;
import org.d_haven.event.impl.DefaultPipe;
import java.nio.channels.SocketChannel;
import java.nio.channels.ServerSocketChannel;
import java.io.IOException;
-import java.net.ServerSocket;
import java.net.InetSocketAddress;
import java.util.Map;
import java.util.HashMap;
@@ -58,7 +59,9 @@
m_firewall = new Firewall();
m_reader = new ReaderSource();
m_writer = new Writer();
- m_manager = new DefaultThreadManager();
+ // 5 threads per processor, and check every 100ms for new events
+ final ThreadPolicy policy = new ProcessorBoundThreadPolicy(5, 100L);
+ m_manager = new DefaultThreadManager(policy);
m_connect = new ConnectSource();
m_firewall.addSource( m_connect );
Modified: incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java
Url: http://svn.apache.org/viewcvs/incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java?view=diff&rev=112000&p1=incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java&r1=111999&p2=incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java&r2=112000
==============================================================================
--- incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java (original)
+++ incubator/directory/network/trunk/sedang/src/java/org/apache/directory/seda/Stage.java Wed Dec 15 09:10:40 2004
@@ -43,6 +43,7 @@
{
m_sources = new LinkedList();
m_sink = new DefaultPipe();
+ m_sink.setTimeout( 1L ); // essentially don't timeout
m_namedSinks = new HashMap();
}
@@ -77,6 +78,8 @@
{
throw new IllegalArgumentException("'pipe' cannot be null");
}
+
+ pipe.setTimeout( 1L ); // essentially don't timeout
m_namedSinks.put( name, pipe );
}