LEFT | RIGHT |
1 // Copyright 2011 The Go Authors. All rights reserved. | 1 // Copyright 2013 The Go Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style | 2 // Use of this source code is governed by a BSD-style |
3 // license that can be found in the LICENSE file. | 3 // license that can be found in the LICENSE file. |
4 | 4 |
5 package ssh | 5 package ssh |
6 | 6 |
7 import ( | 7 import ( |
8 "bytes" | 8 "bytes" |
9 "crypto/rand" | 9 "crypto/rand" |
10 "fmt" | 10 "fmt" |
11 "net" | 11 "net" |
(...skipping 229 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
241 func TestHandshakeAutoRekeyWrite(t *testing.T) { | 241 func TestHandshakeAutoRekeyWrite(t *testing.T) { |
242 clientConf := &ClientConfig{} | 242 clientConf := &ClientConfig{} |
243 clientConf.Crypto.RekeyThreshold = 500 | 243 clientConf.Crypto.RekeyThreshold = 500 |
244 trC, trS, err := handshakePair(clientConf, "addr") | 244 trC, trS, err := handshakePair(clientConf, "addr") |
245 if err != nil { | 245 if err != nil { |
246 t.Fatalf("handshakePair: %v", err) | 246 t.Fatalf("handshakePair: %v", err) |
247 } | 247 } |
248 defer trC.Close() | 248 defer trC.Close() |
249 defer trS.Close() | 249 defer trS.Close() |
250 | 250 |
251 packet := make([]byte, 251) | |
252 packet[0] = msgRequestSuccess | |
253 for i := 0; i < 5; i++ { | 251 for i := 0; i < 5; i++ { |
| 252 packet := make([]byte, 251) |
| 253 packet[0] = msgRequestSuccess |
254 if err := trC.writePacket(packet); err != nil { | 254 if err := trC.writePacket(packet); err != nil { |
255 t.Errorf("writePacket: %v", err) | 255 t.Errorf("writePacket: %v", err) |
256 } | 256 } |
257 } | 257 } |
258 | 258 |
259 j := 0 | 259 j := 0 |
260 for ; j < 5; j++ { | 260 for ; j < 5; j++ { |
261 _, err := trS.readPacket() | 261 _, err := trS.readPacket() |
262 if err != nil { | 262 if err != nil { |
263 break | 263 break |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
304 if _, err := trS.readPacket(); err != nil { | 304 if _, err := trS.readPacket(); err != nil { |
305 t.Fatalf("readPacket(server): %v", err) | 305 t.Fatalf("readPacket(server): %v", err) |
306 } | 306 } |
307 } | 307 } |
308 | 308 |
309 checker := trC.checker.(*testChecker) | 309 checker := trC.checker.(*testChecker) |
310 if len(checker.calls) != 2 { | 310 if len(checker.calls) != 2 { |
311 t.Errorf("got %d key changes, wanted 2", len(checker.calls)) | 311 t.Errorf("got %d key changes, wanted 2", len(checker.calls)) |
312 } | 312 } |
313 } | 313 } |
LEFT | RIGHT |