comparison rep/Forwarder.java @ 365:c432755c3555

distributed session debug continue... SELECT/SELECT_ACK loop
author kono
date Mon, 20 Oct 2008 17:00:42 +0900
parents 1a8856580d38
children e16b6326fdac
comparison
equal deleted inserted replaced
364:c965ef2b5fd6 365:c432755c3555
24 return seq++; 24 return seq++;
25 } 25 }
26 26
27 public void send(REPCommand command) { 27 public void send(REPCommand command) {
28 assert(command!=null); 28 assert(command!=null);
29 assert(channel!=null);
29 REPCommand c = new REPCommand(command); 30 REPCommand c = new REPCommand(command);
30 manager.addWriteQueue(new PacketSet(channel,null, c)); 31 manager.addWriteQueue(new PacketSet(channel,null, c));
31 } 32 }
32 33
33 public REPSocketChannel<REPCommand> getChannel() { 34 public REPSocketChannel<REPCommand> getChannel() {