Changeset 604 in code for trunk/server_test.go


Ignore:
Timestamp:
Oct 5, 2021, 12:26:10 PM (4 years ago)
Author:
contact
Message:

test: get rid of testUpstream

No need for this complexity.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/server_test.go

    r603 r604  
    4848}
    4949
    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) {
     50func createTestUpstream(t *testing.T, db Database, user *User) (*Network, net.Listener) {
    5651        ln, err := net.Listen("tcp", "localhost:0")
    5752        if err != nil {
    5853                t.Fatalf("failed to create TCP listener: %v", err)
    5954        }
    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                                 break
    73                         } else if err != nil {
    74                                 t.Fatalf("failed accepting connection: %v", err)
    75                         }
    76                         tu.Accept <- newNetIRCConn(c)
    77                 }
    78         }()
    7955
    8056        network := &Network{
     
    8864        }
    8965
    90         return network, tu
     66        return network, ln
     67}
     68
     69func 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)
    9175}
    9276
     
    170154        defer srv.Shutdown()
    171155
    172         uc := <-upstream.Accept
     156        uc := mustAccept(t, upstream)
    173157        defer uc.Close()
    174158        registerUpstreamConn(t, uc)
Note: See TracChangeset for help on using the changeset viewer.