Mercurial > hg > RemoteEditor > REPSessionManager

comparison rep/handler/Forwarder.java @ 450:21cb16b7f3df

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
block message in Editor.write()
author one
date Thu, 23 Sep 2010 18:15:37 +0900
parents 1bb59652d89c
children c83af820eb62
comparison
equal deleted inserted replaced
449:89a326696c54 450:21cb16b7f3df
40 @Override 40 @Override
41 public void send(REPCommand command) { 41 public void send(REPCommand command) {
42 assert(command!=null); 42 assert(command!=null);
43 assert(channel!=null); 43 assert(channel!=null);
44 REPCommand c = new REPCommand(command); 44 REPCommand c = new REPCommand(command);
45 manager.addWriteQueue(new PacketSet(channel,null, c)); 45 manager.addWriteQueue(new PacketSet(this, c));
46 } 46 }
47 47
48 public void sendWithSeq(REPCommand command) { 48 public void sendWithSeq(REPCommand command) {
49 assert(command!=null); 49 assert(command!=null);
50 assert(channel!=null); 50 assert(channel!=null);
51 REPCommand c = new REPCommand(command); 51 REPCommand c = new REPCommand(command);
52 c.setSEQID(seq()); 52 c.setSEQID(seq());
53 manager.addWriteQueue(new PacketSet(channel,null, c)); 53 manager.addWriteQueue(new PacketSet(this, c));
54 } 54 }
55 55
56 public REPSocketChannel<REPCommand> getChannel() { 56 public REPSocketChannel<REPCommand> getChannel() {
57 return channel; 57 return channel;
58 } 58 }
149 @Override 149 @Override
150 public List<REPCommand> getSentList() { 150 public List<REPCommand> getSentList() {
151 return null; 151 return null;
152 } 152 }
153 153
154 @Override
155 public void write(REPCommand command) {
156 channel.write(command);
157 }
158
154 159
155 160
156 161
157 162
158 } 163 }