]> Cypherpunks repositories - gostls13.git/commitdiff
net/rpc: fix a test bug
authorChaiShushan <chaishushan@gmail.com>
Thu, 11 Jul 2013 19:55:08 +0000 (15:55 -0400)
committerRuss Cox <rsc@golang.org>
Thu, 11 Jul 2013 19:55:08 +0000 (15:55 -0400)
R=golang-dev, rsc
CC=golang-dev
https://golang.org/cl/10855043

src/pkg/net/rpc/server_test.go

index b64228111b9eb5668a91ddf847f9ac45feb4c2ca..0631acdf94cdb673b22df87bd49e6c963060d6b4 100644 (file)
@@ -99,11 +99,12 @@ func startNewServer() {
        newServer = NewServer()
        newServer.Register(new(Arith))
        newServer.RegisterName("net.rpc.Arith", new(Arith))
+       newServer.RegisterName("newServer.Arith", new(Arith))
 
        var l net.Listener
        l, newServerAddr = listenTCP()
        log.Println("NewServer test RPC server listening on", newServerAddr)
-       go Accept(l)
+       go newServer.Accept(l)
 
        newServer.HandleHTTP(newHttpPath, "/bar")
        httpOnce.Do(startHttpServer)
@@ -120,6 +121,7 @@ func TestRPC(t *testing.T) {
        testRPC(t, serverAddr)
        newOnce.Do(startNewServer)
        testRPC(t, newServerAddr)
+       testNewServerRPC(t, newServerAddr)
 }
 
 func testRPC(t *testing.T, addr string) {
@@ -249,6 +251,25 @@ func testRPC(t *testing.T, addr string) {
        }
 }
 
+func testNewServerRPC(t *testing.T, addr string) {
+       client, err := Dial("tcp", addr)
+       if err != nil {
+               t.Fatal("dialing", err)
+       }
+       defer client.Close()
+
+       // Synchronous calls
+       args := &Args{7, 8}
+       reply := new(Reply)
+       err = client.Call("newServer.Arith.Add", args, reply)
+       if err != nil {
+               t.Errorf("Add: expected no error but got string %q", err.Error())
+       }
+       if reply.C != args.A+args.B {
+               t.Errorf("Add: expected %d got %d", reply.C, args.A+args.B)
+       }
+}
+
 func TestHTTP(t *testing.T) {
        once.Do(startServer)
        testHTTPRPC(t, "")