diff options
Diffstat (limited to 'src/java/net/sf/antcontrib/antserver/server/Server.java')
-rw-r--r-- | src/java/net/sf/antcontrib/antserver/server/Server.java | 126 |
1 files changed, 0 insertions, 126 deletions
diff --git a/src/java/net/sf/antcontrib/antserver/server/Server.java b/src/java/net/sf/antcontrib/antserver/server/Server.java deleted file mode 100644 index b0e8c56..0000000 --- a/src/java/net/sf/antcontrib/antserver/server/Server.java +++ /dev/null @@ -1,126 +0,0 @@ -/* - * Copyright (c) 2001-2004 Ant-Contrib project. All rights reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - package net.sf.antcontrib.antserver.server; - -import java.io.IOException; -import java.io.InterruptedIOException; -import java.net.ServerSocket; -import java.net.Socket; - -import org.apache.tools.ant.BuildException; -import org.apache.tools.ant.Project; - -/**************************************************************************** - * Place class description here. - * - * @author <a href='mailto:[email protected]'>Matthew Inger</a> - * @author <additional author> - * - * @since - * - ****************************************************************************/ - - -public class Server - implements Runnable -{ - private ServerTask task; - private int port = 17000; - private boolean running = false; - private Thread thread = null; - - public Server(ServerTask task, int port) - { - super(); - this.task = task; - this.port = port; - } - - public void start() - throws InterruptedException - { - thread = new Thread(this); - thread.start(); - thread.join(); - } - - public void stop() - { - running = false; - } - - public void run() - { - ServerSocket server = null; - running = true; - try - { - task.getProject().log("Starting server on port: " + port, - Project.MSG_DEBUG); - try - { - server = new ServerSocket(port); - server.setSoTimeout(500); - } - catch (IOException e) - { - throw new BuildException(e); - } - - - while (running) - { - try - { - Socket clientSocket = server.accept(); - task.getProject().log("Got a client connection. Starting Handler.", - Project.MSG_DEBUG); - ConnectionHandler handler = new ConnectionHandler(task, - clientSocket); - handler.start(); - } - catch (InterruptedIOException e) - { - ; // gulp, no socket connection - } - catch (IOException e) - { - task.getProject().log(e.getMessage(), - Project.MSG_ERR); - } - } - } - finally - { - if (server != null) - { - try - { - server.close(); - server = null; - } - catch (IOException e) - { - ; // gulp - } - } - } - running = false; - - - } - -} |