01: package vicazh.hyperpool.stream.net.http;
02:
03: import java.io.*;
04: import vicazh.hyperpool.stream.*;
05:
06: class RouterConnection extends Connection {
07: RouterConnection(Element element) {
08: super (element);
09: }
10:
11: protected Session getSession() {
12: return new RouterSession(this );
13: }
14:
15: int index;
16:
17: synchronized public void close() {
18: super .close();
19: notifyAll();
20: }
21:
22: synchronized public void remove(Session session) {
23: super .remove(session);
24: if (getSessions().size() == 1)
25: notify();
26: }
27:
28: Priority priority;
29:
30: boolean isReverse;
31:
32: public void setServer(OutputStream outputstream) throws IOException {
33: super.setServer(outputstream);
34: isReverse = getServer().isReverse();
35: }
36: }
|