Ports a couple of new RPC calls to the updated codec mechanism.

This commit is contained in:
James Phillips 2015-10-15 15:09:13 -07:00
parent 2c36c4f969
commit 8d444f2eed
1 changed files with 2 additions and 2 deletions

View File

@ -281,7 +281,7 @@ func TestKVSEndpoint_List(t *testing.T) {
// Try listing a nonexistent prefix // Try listing a nonexistent prefix
getR.Key = "/nope" getR.Key = "/nope"
if err := client.Call("KVS.List", &getR, &dirent); err != nil { if err := msgpackrpc.CallWithCodec(codec, "KVS.List", &getR, &dirent); err != nil {
t.Fatalf("err: %v", err) t.Fatalf("err: %v", err)
} }
if dirent.Index == 0 { if dirent.Index == 0 {
@ -529,7 +529,7 @@ func TestKVSEndpoint_ListKeys(t *testing.T) {
// Try listing a nonexistent prefix // Try listing a nonexistent prefix
getR.Prefix = "/nope" getR.Prefix = "/nope"
if err := client.Call("KVS.ListKeys", &getR, &dirent); err != nil { if err := msgpackrpc.CallWithCodec(codec, "KVS.ListKeys", &getR, &dirent); err != nil {
t.Fatalf("err: %v", err) t.Fatalf("err: %v", err)
} }
if dirent.Index == 0 { if dirent.Index == 0 {