Source code: org/rakiura/mbot/TcpConnectionsServer.java
1
2 package org.rakiura.mbot;
3
4 /**/
5 import java.net.*;
6 import java.io.*;
7
8 /**
9 * TcpConnectionsServer.java
10 * Created: Thu Jul 15 12:38:56 1999
11 *
12 *@author Mariusz Nowostawski
13 *@version 0.3 $Revision: 1.1.1.1 $
14 */
15 public class TcpConnectionsServer extends Thread {
16
17 private int port;
18 private boolean listening;
19 private Engine engine;
20
21 /**/
22 public TcpConnectionsServer(int port, Engine engine) {
23 this.port = port;
24 this.engine = engine;
25 listening = true;
26 }
27
28 /**/
29 public void run() {
30 ServerSocket serverSocket = null;
31 try {
32 serverSocket = new ServerSocket(port);
33 } catch (IOException e) {
34 System.err.println("Could not listen on port: "+port);
35 }
36
37 System.out.println("TCP listening on port: "+port);
38
39 try{
40 while (listening)
41 new ConnectionThread(serverSocket.accept(), engine).start();
42 serverSocket.close();
43 } catch (IOException e) {
44 System.err.println("Problem with port: "+port+" Tcp connection thread stoped");
45 }
46 }
47
48 public void setListening(boolean b){ listening = b; }
49
50 } // TcpConnectionsServer
51 //////////////////// end of file ////////////////////