(t *testing.T)
| 214 | } |
| 215 | |
| 216 | func TestGetRemote(t *testing.T) { |
| 217 | nodes, err := connectedTestNodes(2, 1) |
| 218 | defer tearDownNodes(nodes) |
| 219 | if err != nil { |
| 220 | t.Fatalf("connectedTestNodes(2, 1) failed: %v", err) |
| 221 | } |
| 222 | |
| 223 | n1 := nodes[0] |
| 224 | n2 := nodes[1] |
| 225 | |
| 226 | // Store a value on the second node |
| 227 | k := "foo" |
| 228 | expV := []byte("bar") |
| 229 | if err := n2.data.Set(k, expV, 0, 0); err != nil { |
| 230 | t.Fatalf("Set(%v) failed: %v", k, err) |
| 231 | } |
| 232 | |
| 233 | var resp ttlstore.KeyData |
| 234 | args := StorageArgs{Key: k, ExplicitPeer: n2.name} |
| 235 | if n1.server.Get(args, &resp); err != nil { |
| 236 | t.Errorf("Get(%+v) returned an error %v", args, err) |
| 237 | t.FailNow() |
| 238 | } |
| 239 | |
| 240 | // Check the value returned is correct. |
| 241 | if !reflect.DeepEqual(resp.Data, expV) { |
| 242 | t.Errorf("Get(%v) returned %v; want %v", args, resp.Data, expV) |
| 243 | } |
| 244 | } |
| 245 | |
| 246 | func TestGetRemoteInvalid(t *testing.T) { |
| 247 | nodes, err := connectedTestNodes(2, 1) |
nothing calls this directly
no test coverage detected