blob: 7516c8c0b1174b1c374278ffa5c1372923bade09 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
/*******************************************************************************
* Copyright (c) 2002-2005 IBM Corporation and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* IBM - Initial API and implementation
*******************************************************************************/
package org.eclipse.wst.wsi.internal.core.monitor;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Iterator;
import java.util.Vector;
import org.eclipse.wst.wsi.internal.core.monitor.config.Redirect;
/**
* A server socket listener.
*
* @author Peter Brittenham (peterbr@us.ibm.com)
* @version 1.0.1
*/
public class ServerSocketListener
extends Thread
implements ConnectionListener // SS
{
protected Monitor monitor = null;
protected Redirect redirect = null;
protected ServerSocket serverSocket = null;
protected boolean stopServerSocket = false;
protected Vector connectionList = new Vector();
/**
* Create server socket listener.
* @param monitor a Monitor object.
* @param redirect a Redirect object.
*/
public ServerSocketListener(Monitor monitor, Redirect redirect)
{
this.monitor = monitor;
this.redirect = redirect;
// Start listening
start();
}
/**
* Run the thread and listen for a connection on the socket.
*/
public void run()
{
try
{
// Create server socket
serverSocket =
new ServerSocket(
redirect.getListenPort(),
redirect.getMaxConnections());
// SS
// Set timeout so that server socket will continue to accept connections
serverSocket.setSoTimeout(0);
// Listen for connections until interrupted
while (!stopServerSocket)
{
// Accept connections
Socket socket = serverSocket.accept();
// If the server socket was NOT stopped, process connection
if (!stopServerSocket)
{
// Create new connection
SocketConnection socketConnection =
new SocketConnection(this.monitor, this.redirect, socket);
//register as a listener
socketConnection.addConnectionListener(this); // SS
// Add to connection list
connectionList.add(socketConnection);
}
}
}
catch (Exception e)
{
// If the exception was NOT caused by closing the socket, then stop monitor
if (!e.getMessage().equals("socket closed"))
{
monitor.exitMonitor(e);
}
}
}
/**
* Stop listening for a connection on the socket.
*/
public void shutdown()
{
try
{
// Shutdown all active connections
Iterator iterator = connectionList.iterator();
while (iterator.hasNext())
{
((SocketConnection) iterator.next()).shutdown();
}
// Tell the server socket listening thread to stop
this.stopServerSocket = true;
// Set the server socket timeout to 1 ms
serverSocket.setSoTimeout(1);
// Close the server socket
if (serverSocket != null)
serverSocket.close();
}
catch (Exception e)
{
}
}
// ==== SS start ====
/* (non-Javadoc)
* @see org.wsi.test.monitor.ConnectionListener#connectionClosed()
*/
public void connectionClosed(SocketConnection connection)
{
connectionList.remove(connection);
}
// ==== SS end ====
}
|
