Mercurial > hg > RemoteEditor > REPSessionManager
view rep/Forwarder.java @ 324:e235998427a6 before-merge-fix
try to fix merger
author | kono |
---|---|
date | Sat, 11 Oct 2008 16:31:03 +0900 |
parents | dfed28488274 |
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; } }