Mercurial > 510Connectbot

comparison src/ch/ethz/ssh2/transport/TransportManager.java @ 324:a1a2e33b3565 ganymed

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add ecdsa key support everywhere
author Carl Byington <carl@five-ten-sg.com>
date Thu, 31 Jul 2014 09:31:42 -0700
parents 90537ba71897
children fe127b3c4b88
comparison
equal deleted inserted replaced
323:90537ba71897 324:a1a2e33b3565
278 } 278 }
279 279
280 public void sendKexMessage(byte[] msg) throws IOException { 280 public void sendKexMessage(byte[] msg) throws IOException {
281 synchronized (connectionSemaphore) { 281 synchronized (connectionSemaphore) {
282 if (connectionClosed) { 282 if (connectionClosed) {
283 throw new IOException("Sorry, this connection is closed.").initCause(reasonClosedCause); 283 throw(IOException) new IOException("Sorry, this connection is closed.").initCause(reasonClosedCause);
284 } 284 }
285 285
286 flagKexOngoing = true; 286 flagKexOngoing = true;
287 287
288 try { 288 try {
400 */ 400 */
401 public void sendMessageImmediate(byte[] msg) throws IOException { 401 public void sendMessageImmediate(byte[] msg) throws IOException {
402 synchronized (connectionSemaphore) { 402 synchronized (connectionSemaphore) {
403 while (true) { 403 while (true) {
404 if (connectionClosed) { 404 if (connectionClosed) {
405 throw new IOException("Sorry, this connection is closed.").initCause(reasonClosedCause); 405 throw(IOException) new IOException("Sorry, this connection is closed.").initCause(reasonClosedCause);
406 } 406 }
407 407
408 if (!flagKexOngoing) { 408 if (!flagKexOngoing) {
409 break; 409 break;
410 } 410 }