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

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
108 108
109 public abstract void cancel(REPSocketChannel<REPCommand> channel1) ; 109 public abstract void cancel(REPSocketChannel<REPCommand> channel1) ;
110 110
111 public abstract String getLocalHostName(); 111 public abstract String getLocalHostName();
112 112
113 113 /**
114 * Send to the next REPNode (with possible blocking)
115 * @param command
116 */
114 public abstract void send(REPCommand command) ; 117 public abstract void send(REPCommand command) ;
118
119 /**
120 * write command to the socket channel
121 * @param command
122 */
123 public abstract void write(REPCommand command) ;
115 124
116 public abstract void sendWithSeq(REPCommand command) ; 125 public abstract void sendWithSeq(REPCommand command) ;
117 126
118 public abstract void setQuit2(REPCommand receivedCommand) ; 127 public abstract void setQuit2(REPCommand receivedCommand) ;
119 128
120 public abstract int seq() ; 129 public abstract int seq() ;
121
122 public abstract boolean isMerging() ;
123
124 130
125 public abstract boolean manage(REPCommand command) ; 131 public abstract boolean manage(REPCommand command) ;
126 132
127 133
128 public abstract void selectSession(REPCommand sendCommand,Session session) ; 134 public abstract void selectSession(REPCommand sendCommand,Session session) ;
161 167
162 public abstract void checkWaitingCommandInMerge(); 168 public abstract void checkWaitingCommandInMerge();
163 169
164 public abstract List<REPCommand> getSentList() ; 170 public abstract List<REPCommand> getSentList() ;
165 171
172 public void sendToEditor(REPCommand m) {
173 send(m);
174 }
175
166 176
167 177
168 178
169 } 179 }