Mercurial > hg > RemoteEditor > REPSessionManager

annotate rep/Session.java @ 361:65c6d12a5835

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*** empty log message ***
author kono
date Sun, 19 Oct 2008 22:50:20 +0900
parents b25f832f875d
children f0bd158dace6
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
e41994ce73c7 *** empty log message ***
pin
parents:
diff changeset
1 package rep;
e41994ce73c7 *** empty log message ***
pin
parents:
diff changeset
2
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
3 import java.util.Collection;
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
4 import java.util.HashMap;
1
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
5 import java.util.LinkedList;
131
617a47cb0150 *** empty log message ***
pin
parents: 96
diff changeset
6 import rep.channel.REPSocketChannel;
617a47cb0150 *** empty log message ***
pin
parents: 96
diff changeset
7
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
8 public class Session extends HashMap<Integer,EditorPlus> {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
9 /**
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
10 *
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
11 */
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
12 private static final long serialVersionUID = 1L;
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
13 private Forwarder masterEditor;
1
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
14 private int sessionID;
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
15 private String sessionName;
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
16 // isOnwer means this session has active channels(forwarders).
67
13e4c3f2c6f9 *** empty log message ***
pin
parents: 66
diff changeset
17 private boolean isOwner = false;
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
18 private Forwarder firstForwarder;
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
19 private Forwarder last;
9
2d4c2c19d2d0 *** empty log message ***
pin
parents: 3
diff changeset
20
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
21 public Session(int sid, String name, Forwarder editor) {
227
cbd67817e9cd *** empty log message ***
pin
parents: 224
diff changeset
22 this(sid, editor);
cbd67817e9cd *** empty log message ***
pin
parents: 224
diff changeset
23 sessionName = name;
1
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
24 }
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
25
39
c873ee0318f8 *** empty log message ***
pin
parents: 38
diff changeset
26
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
27 public Session(int sid, Forwarder editor) {
144
0bf7f8d0f5f7 *** empty log message ***
pin
parents: 131
diff changeset
28 sessionID = sid;
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
29 if (editor!=null) {
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
30 // we have a master
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
31 masterEditor = last = editor;
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
32 editor.setSID(sid);
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
33 put(editor.eid,editor);
323
1e605880d49e *** empty log message ***
kono
parents: 322
diff changeset
34 if(editor.channel!=null) {
1e605880d49e *** empty log message ***
kono
parents: 322
diff changeset
35 firstForwarder = editor;
1e605880d49e *** empty log message ***
kono
parents: 322
diff changeset
36 masterEditor.setNext(masterEditor);
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
37 isOwner = true;
323
1e605880d49e *** empty log message ***
kono
parents: 322
diff changeset
38 }
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
39 }
1
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
40 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
41
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
42 public void addForwarder(Forwarder forwarder) {
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
43 // add a forwarder and connect this to the session
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
44 forwarder.setNext(last.getNextForwarder());
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
45 last.setNext(forwarder);
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
46 last = forwarder;
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
47 put(forwarder.eid,forwarder);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
48 isOwner = true;
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
49 if(firstForwarder==null) firstForwarder = forwarder;
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
50 }
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
51
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
52 public void addEditor(Editor editor) {
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
53 // add a not-connected editor in a sassion
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
54 // the editor is outside of this manager
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
55 put(editor.eid,editor);
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
56 }
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
57
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
58 public Collection<EditorPlus> getEditorList() {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
59 return values();
1
3f5bf0255f5e *** empty log message ***
pin
parents: 0
diff changeset
60 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
61
56
6ead43b2475e *** empty log message ***
pin
parents: 39
diff changeset
62 public int getSID() {
6ead43b2475e *** empty log message ***
pin
parents: 39
diff changeset
63 return sessionID;
38
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
64 }
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
65 public Forwarder getOwner() {
38
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
66 return masterEditor;
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
67 }
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
68 public String getName() {
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
69 return sessionName;
de8638eb0edd *** empty log message ***
pin
parents: 9
diff changeset
70 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
71
274
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
72
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
73 public boolean deleteEditor(REPSocketChannel<REPCommand> channel) {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
74 LinkedList<EditorPlus> toBeRemoved = new LinkedList<EditorPlus>();
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
75 for (EditorPlus e:values() ) {
275
3be92eb54b1c *** empty log message ***
kono
parents: 274
diff changeset
76 if (e.getChannel()==channel) {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
77 unconnect((Forwarder)e);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
78 toBeRemoved.add(e);
274
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
79 }
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
80 }
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
81 for(EditorPlus e:toBeRemoved) {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
82 remove(e);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
83 }
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
84 return !toBeRemoved.isEmpty();
274
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
85 }
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
86
358
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
87 public boolean deleteForwarder(Forwarder editor) {
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
88 unconnect(editor);
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
89 return remove(editor)!=null;
358
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
90 }
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
91
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
92 private void unconnect(Forwarder e) {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
93 boolean hasOwner = false;
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
94 for(EditorPlus e1:values()) {
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
95 Forwarder f = (Forwarder)e1;
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
96 if(f.next==e) {
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
97 f.next=e.next;
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
98 } else {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
99 if (f.channel!=null) hasOwner=true;
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
100 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
101 }
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
102 if(firstForwarder==e) firstForwarder=null;
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
103 if(masterEditor==e) masterEditor=null;
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
104 isOwner = hasOwner;
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
105 }
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
106
227
cbd67817e9cd *** empty log message ***
pin
parents: 224
diff changeset
107 public void setSID(int sid) {
cbd67817e9cd *** empty log message ***
pin
parents: 224
diff changeset
108 sessionID = sid;
56
6ead43b2475e *** empty log message ***
pin
parents: 39
diff changeset
109 }
274
ad487e63e3c8 *** empty log message ***
kono
parents: 260
diff changeset
110
158
5cc8cd48bded *** empty log message ***
pin
parents: 144
diff changeset
111 public boolean hasOwner() {
67
13e4c3f2c6f9 *** empty log message ***
pin
parents: 66
diff changeset
112 return isOwner;
13e4c3f2c6f9 *** empty log message ***
pin
parents: 66
diff changeset
113 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
114
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
115
144
0bf7f8d0f5f7 *** empty log message ***
pin
parents: 131
diff changeset
116 public Editor getEditor(REPSocketChannel<REPCommand> channel) {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
117 for(EditorPlus editor : values()){
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
118 if(editor.getChannel() == channel) {
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
119 return (Editor)editor;
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
120 }
144
0bf7f8d0f5f7 *** empty log message ***
pin
parents: 131
diff changeset
121 }
0bf7f8d0f5f7 *** empty log message ***
pin
parents: 131
diff changeset
122 return null;
0bf7f8d0f5f7 *** empty log message ***
pin
parents: 131
diff changeset
123 }
315
20fb70068089 *** empty log message ***
kono
parents: 300
diff changeset
124
20fb70068089 *** empty log message ***
kono
parents: 300
diff changeset
125
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
126 Forwarder getNextEditor(Forwarder editor) {
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
127 return editor.getNextForwarder();
167
3dc194f5e28f *** empty log message ***
pin
parents: 158
diff changeset
128 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
129
259
9e36fd27e2b6 *** empty log message ***
pin
parents: 227
diff changeset
130 public void closeSession() {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
131 Forwarder first = firstForwarder;
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
132 REPCommand command = new REPCommand(REP.REPCMD_CLOSE, sessionID, REP.SM_EID.id, 0, 0, "");
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
133 if (first!=null)
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
134 first.send(command);
300
8f6b7a1890b2 *** empty log message ***
kono
parents: 281
diff changeset
135 }
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
136
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
137
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
138
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
139 public Forwarder getFirstForwarder() {
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
140 return firstForwarder;
316
77f443f6dc9f add session manager channel handler
kono
parents: 315
diff changeset
141 }
358
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
142
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
143
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
144 public void remove(SessionManager manager) {
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
145 for(EditorPlus editor : values()){
358
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
146 if(editor.getChannel() !=null)
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
147 unconnect((Forwarder)editor);
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
148 manager.editorList.remove(editor);
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
149 }
034acadc0cdc *** empty log message ***
kono
parents: 356
diff changeset
150 }
359
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
151
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
152
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
153 public void merge(Session s) {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
154 for(EditorPlus editor : s.values()){
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
155 EditorPlus mine = get(editor.eid);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
156 if (mine==null) {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
157 put(editor.eid,editor);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
158 } else {
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
159 mine.merge(editor);
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
160 }
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
161 }
fa041bae35f1 all code written for distributed session except gather.
kono
parents: 358
diff changeset
162 }
319
dfed28488274 *** empty log message ***
kono
parents: 318
diff changeset
163
360
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
164 @Override
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
165 public String toString() {
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
166 String s = super.toString();
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
167 return s+" sid="+sessionID+" "+sessionName+" master="+
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
168 ((masterEditor==null)?"null":masterEditor.toString());
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
169 }
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
170
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
171
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
172 public void setName(String string) {
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
173 sessionName = string;
b25f832f875d *** empty log message ***
kono
parents: 359
diff changeset
174 }
320
83790b8b8174 *** empty log message ***
kono
parents: 319
diff changeset
175
361
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
176
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
177 public void setFirstForwarder(Forwarder f) {
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
178 put(f.eid,f);
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
179 firstForwarder = last = f;
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
180 }
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
181
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
182
65c6d12a5835 *** empty log message ***
kono
parents: 360
diff changeset
183
0
e41994ce73c7 *** empty log message ***
pin
parents:
diff changeset
184 }