Mercurial > hg > RemoteEditor > REPSessionManager
annotate rep/SessionManagerList.java @ 367:1bde894edd83
*** empty log message ***
| author | kono |
|---|---|
| date | Tue, 21 Oct 2008 18:46:04 +0900 |
| parents | c432755c3555 |
| children | 4b87f89b3afd |
| rev | line source |
|---|---|
| 7 | 1 package rep; |
| 2 | |
| 3 import java.util.LinkedList; | |
| 356 | 4 |
| 5 public class SessionManagerList extends LinkedList<Forwarder>{ | |
| 56 | 6 |
| 356 | 7 /** |
| 8 * | |
| 9 */ | |
| 10 private static final long serialVersionUID = 1L; | |
| 11 private int mySMID=0; | |
| 12 private int smid_root=0; | |
| 360 | 13 private Forwarder parent=new NullForwarder(null); |
| 355 | 14 private LinkedList<Forwarder> waiting= new LinkedList<Forwarder>(); |
| 7 | 15 |
| 16 | |
| 349 | 17 public void setMaster(Forwarder f) { |
| 18 this.parent = f; | |
| 19 } | |
| 20 | |
| 21 public void sendToMaster(REPCommand repCmd) { | |
| 22 parent.send(repCmd); | |
| 23 } | |
| 24 | |
| 25 public void sendToSlaves(REPCommand repCmd) { | |
| 356 | 26 for(Forwarder channel : this){ |
| 349 | 27 channel.send(repCmd); |
| 7 | 28 } |
| 29 } | |
| 30 | |
| 349 | 31 public boolean isMaster() { |
| 360 | 32 return !parent.isForwarder(); |
| 25 | 33 } |
| 21 | 34 |
| 355 | 35 public int addNewSessionManager(Forwarder fw,REPCommand receivedCommand) { |
| 356 | 36 add(fw); |
| 37 int sid = ++smid_root; | |
| 355 | 38 fw.setSID(sid); |
| 39 fw.setName(receivedCommand.string); | |
| 40 return sid; | |
| 31 | 41 } |
| 42 | |
| 56 | 43 |
| 355 | 44 public void setSessionManagerID(int sid) { |
| 45 mySMID = sid; | |
| 46 } | |
| 47 | |
| 48 public int sessionManagerID() { | |
| 49 return mySMID; | |
| 50 } | |
| 51 | |
| 52 public void addWaitingSessionManager(Forwarder fw, REPCommand command) { | |
| 53 // SID assign 待ちのSessionManager Channelを登録する | |
| 54 waiting.add(fw); | |
| 55 | |
| 56 } | |
| 57 | |
| 58 public void assignSessionManagerIDtoWaitingSM(int sid) { | |
| 59 // 待っていたSession Manager ChannelにSession IDを登録し，Session Manager List | |
| 60 // に登録する。この次のsm_join_ackでSIDが確定する。 | |
| 61 Forwarder waiter; | |
| 62 if ((waiter=waiting.poll())!=null) { | |
| 63 waiter.setSID(sid); | |
| 356 | 64 add(waiter); |
| 355 | 65 return; |
| 66 } | |
| 67 assert false; | |
| 68 } | |
| 69 | |
|
365
c432755c3555
distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents:
360
diff
changeset
|
70 public void setParent(Forwarder fw) { |
|
c432755c3555
distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents:
360
diff
changeset
|
71 parent = fw; |
|
c432755c3555
distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents:
360
diff
changeset
|
72 } |
| 367 | 73 |
| 74 public Forwarder parent() { | |
| 75 return parent; | |
| 76 } | |
|
365
c432755c3555
distributed session debug continue... SELECT/SELECT_ACK loop
kono
parents:
360
diff
changeset
|
77 |
| 56 | 78 |
| 349 | 79 |
| 78 | 80 |
| 7 | 81 } |