1
2
3
4
5
6
7
8
9
10
11
12
13
14 package org.eclipse.jetty.server.nio;
15
16 import java.io.IOException;
17 import java.nio.channels.SelectionKey;
18 import java.nio.channels.SocketChannel;
19 import java.util.ConcurrentModificationException;
20 import java.util.List;
21 import java.util.concurrent.CopyOnWriteArrayList;
22
23 import org.eclipse.jetty.io.NetworkTrafficListener;
24 import org.eclipse.jetty.io.nio.NetworkTrafficSelectChannelEndPoint;
25 import org.eclipse.jetty.io.nio.SelectChannelEndPoint;
26 import org.eclipse.jetty.io.nio.SelectorManager;
27
28
29
30
31
32
33 public class NetworkTrafficSelectChannelConnector extends SelectChannelConnector
34 {
35 private final List<NetworkTrafficListener> listeners = new CopyOnWriteArrayList<NetworkTrafficListener>();
36
37
38
39
40 public void addNetworkTrafficListener(NetworkTrafficListener listener)
41 {
42 listeners.add(listener);
43 }
44
45
46
47
48 public void removeNetworkTrafficListener(NetworkTrafficListener listener)
49 {
50 listeners.remove(listener);
51 }
52
53 @Override
54 protected SelectChannelEndPoint newEndPoint(SocketChannel channel, SelectorManager.SelectSet selectSet, SelectionKey key) throws IOException
55 {
56 NetworkTrafficSelectChannelEndPoint endPoint = new NetworkTrafficSelectChannelEndPoint(channel, selectSet, key, _maxIdleTime, listeners);
57 endPoint.notifyOpened();
58 return endPoint;
59 }
60
61 @Override
62 protected void endPointClosed(SelectChannelEndPoint endpoint)
63 {
64 super.endPointClosed(endpoint);
65 ((NetworkTrafficSelectChannelEndPoint)endpoint).notifyClosed();
66 }
67 }