Commitab2f07b

committed

fix: require client pipe to be closed in provisionerd test

1 parent2157bff commitab2f07bCopy full SHA for ab2f07b

File tree

-1

lines changed

-1

lines changed

Lines changed: 7 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1090,10 +1090,16 @@ func createProvisionerDaemonClient(t *testing.T, server provisionerDaemonTestSer`
`1090`	`1090`	`require.NoError(t,err)`
`1091`	`1091`	`srv:=drpcserver.New(mux)`
`1092`	`1092`	`ctx,cancelFunc:=context.WithCancel(context.Background())`
`1093`		`-t.Cleanup(cancelFunc)`
	`1093`	`+closed:=make(chanstruct{})`
`1094`	`1094`	`gofunc() {`
	`1095`	`+deferclose(closed)`
`1095`	`1096`	`_=srv.Serve(ctx,serverPipe)`
`1096`	`1097`	`}()`
	`1098`	`+t.Cleanup(func() {`
	`1099`	`+cancelFunc()`
	`1100`	`+_=serverPipe.Close()`
	`1101`	`+<-closed`
	`1102`	`+})`
`1097`	`1103`	`returnproto.NewDRPCProvisionerDaemonClient(clientPipe)`
`1098`	`1104`	`}`
`1099`	`1105`

Comments

(0)