Mercurial > hg > RemoteEditor > REPSessionManager
view rep/Forwarder.java @ 319:dfed28488274
*** empty log message ***
author | kono |
---|---|
date | Thu, 09 Oct 2008 17:26:55 +0900 |
parents | dc57e24ea3df |
children | 7b6dede07f4a |
line wrap: on
line source
package rep; import rep.channel.REPLogger; import rep.channel.REPSocketChannel; import rep.handler.PacketSet; public class Forwarder extends EditorPlus { int seq = 0; Forwarder next; // REPCommands we sent to the next editor final int limit=100; REPLogger ns = REPLogger.singleton(); SessionManager manager; public Forwarder(SessionManager manager) { this.manager = manager; } public int seq() { return seq++; } public void send(REPCommand command) { assert(command!=null); manager.addWriteQueue(new PacketSet(channel, null, command)); } public REPSocketChannel<REPCommand> getChannel() { return channel; } public void setChannel(REPSocketChannel<REPCommand> channel) { this.channel = channel; } public void setQuit2(REPCommand cmd) { send(cmd); } public void setNext(Forwarder next) { this.next = next; } public Forwarder getNextForwarder() { return next; } public boolean manage(REPCommand command) { send(command); return true; } }