Changeset 442

Timestamp:

07/19/07 10:04:12 (1 year ago)

Author:

blackhedd

Message:

stop tcp server

Files:

• version_0/java/src/com/rubyeventmachine/EM.java (modified) (3 diffs)
• version_0/lib/jeventmachine.rb (modified) (1 diff)

version_0/java/src/com/rubyeventmachine/EM.java

@@ -50 +50 @@
-        private TreeMap<Long, String> Timers;
-        private TreeMap<String, EventableChannel> Connections;
+        private TreeMap<String, ServerSocketChannel> Acceptors;
+
-        private boolean bRunReactor;
-        private long BindingIndex;
@@ -60 +62 @@
-                Timers = new TreeMap<Long, String>();
-                Connections = new TreeMap<String, EventableChannel>();
+                Acceptors = new TreeMap<String, ServerSocketChannel>();
+                
-                BindingIndex = 100000;
-                EmptyByteBuffer = ByteBuffer.allocate(0);
@@ -223 +227 @@
-                server.socket().bind(new java.net.InetSocketAddress(address, port));
-                String s = createBinding();
+                Acceptors.put(s, server);
-                server.register(mySelector, SelectionKey.OP_ACCEPT, s);
-                return s;
-        }
-
+        public void stopTcpServer (String signature) throws IOException {
+                ServerSocketChannel server = Acceptors.remove(signature);
+                if (server != null)
+                        server.close();
+                else
+                        throw new RuntimeException ("failed to close unknown acceptor");
+        }
+        
-        public void sendData (String sig, String data, int length) throws IOException {
-                (Connections.get(sig)).scheduleOutboundData( ByteBuffer.wrap(data.getBytes()));

version_0/lib/jeventmachine.rb

@@ -66 +66 @@
-                @em.startTcpServer server, port
-        end
+        def self.stop_tcp_server sig
+                @em.stopTcpServer sig
+        end
-        def self.send_data sig, data, length
-                @em.sendData sig, data, length