Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code | Sign in
(652)

Delta Between Two Patch Sets: ssh/handshake_test.go

Issue 14494058: code review 14494058: go.crypto/ssh: support rekeying in both directions. (Closed)
Left Patch Set: diff -r 5ff5636e18c9 https://code.google.com/p/go.crypto Created 10 years, 5 months ago
Right Patch Set: diff -r cd1eea1eb828 https://code.google.com/p/go.crypto Created 10 years, 5 months ago
Left:
Right:
Use n/p to move between diff chunks; N/P to move between comments. Please Sign in to add in-line comments.
Jump to:
Left: Side by side diff | Download
Right: Side by side diff | Download
« ssh/common.go ('K') | « ssh/handshake.go ('k') | ssh/server.go » ('j') | no next file with change/comment »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
LEFTRIGHT
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
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
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 }
LEFTRIGHT

Powered by Google App Engine
RSS Feeds Recent Issues | This issue
This is Rietveld f62528b