Commite4879ab

authored and

committed

conn_test: Add TestConcurrentClosePing

Updates#298

1 parent8abed3a commite4879abCopy full SHA for e4879ab

File tree

+23

-0

lines changed

+23

-0

lines changed

Lines changed: 23 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -553,3 +553,26 @@ func assertClose(tb testing.TB, c *websocket.Conn) {`
`553`	`553`	`err:=c.Close(websocket.StatusNormalClosure,"")`
`554`	`554`	`assert.Success(tb,err)`
`555`	`555`	`}`
	`556`	`+`
	`557`	`+funcTestConcurrentClosePing(t*testing.T) {`
	`558`	`+t.Parallel()`
	`559`	`+fori:=0;i<64;i++ {`
	`560`	`+func() {`
	`561`	`+c1,c2:=wstest.Pipe(nil,nil)`
	`562`	`+deferc1.CloseNow()`
	`563`	`+deferc2.CloseNow()`
	`564`	`+c1.CloseRead(context.Background())`
	`565`	`+c2.CloseRead(context.Background())`
	`566`	`+gofunc() {`
	`567`	`+forrangetime.Tick(time.Millisecond) {`
	`568`	`+iferr:=c1.Ping(context.Background());err!=nil {`
	`569`	`+return`
	`570`	`+}`
	`571`	`+}`
	`572`	`+}()`
	`573`	`+`
	`574`	`+time.Sleep(10*time.Millisecond)`
	`575`	`+assert.Success(t,c1.Close(websocket.StatusNormalClosure,""))`
	`576`	`+}()`
	`577`	`+}`
	`578`	`+}`

Comments

(0)