summaryrefslogtreecommitdiffstats
path: root/src/java/net/sf/antcontrib/antserver/server/Server.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/java/net/sf/antcontrib/antserver/server/Server.java')
-rw-r--r--src/java/net/sf/antcontrib/antserver/server/Server.java126
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;
-
-
- }
-
-}