Changeset 604 in code for trunk/server_test.go
- Timestamp:
- Oct 5, 2021, 12:26:10 PM (4 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/server_test.go
r603 r604 48 48 } 49 49 50 type testUpstream struct { 51 net.Listener 52 Accept chan ircConn 53 } 54 55 func createTestUpstream(t *testing.T, db Database, user *User) (*Network, *testUpstream) { 50 func createTestUpstream(t *testing.T, db Database, user *User) (*Network, net.Listener) { 56 51 ln, err := net.Listen("tcp", "localhost:0") 57 52 if err != nil { 58 53 t.Fatalf("failed to create TCP listener: %v", err) 59 54 } 60 61 tu := &testUpstream{62 Listener: ln,63 Accept: make(chan ircConn),64 }65 66 go func() {67 defer close(tu.Accept)68 69 for {70 c, err := ln.Accept()71 if isErrClosed(err) {72 break73 } else if err != nil {74 t.Fatalf("failed accepting connection: %v", err)75 }76 tu.Accept <- newNetIRCConn(c)77 }78 }()79 55 80 56 network := &Network{ … … 88 64 } 89 65 90 return network, tu 66 return network, ln 67 } 68 69 func mustAccept(t *testing.T, ln net.Listener) ircConn { 70 c, err := ln.Accept() 71 if err != nil { 72 t.Fatalf("failed accepting connection: %v", err) 73 } 74 return newNetIRCConn(c) 91 75 } 92 76 … … 170 154 defer srv.Shutdown() 171 155 172 uc := <-upstream.Accept156 uc := mustAccept(t, upstream) 173 157 defer uc.Close() 174 158 registerUpstreamConn(t, uc)
Note:
See TracChangeset
for help on using the changeset viewer.