(t *testing.T)
| 169 | } |
| 170 | |
| 171 | func TestRemoveRemote(t *testing.T) { |
| 172 | nodes, err := connectedTestNodes(2, 1) |
| 173 | defer tearDownNodes(nodes) |
| 174 | if err != nil { |
| 175 | t.Fatalf("connectedTestNodes(2, 1) failed: %v", err) |
| 176 | } |
| 177 | |
| 178 | n1 := nodes[0] |
| 179 | n2 := nodes[1] |
| 180 | |
| 181 | // Store a value on the second node |
| 182 | k := "foo" |
| 183 | if err := n2.data.Set(k, []byte("bar"), 0, 0); err != nil { |
| 184 | t.Fatalf("Set(%v) failed: %v", k, err) |
| 185 | } |
| 186 | |
| 187 | var resp struct{} |
| 188 | args := StorageArgs{Key: k, ExplicitPeer: n2.name} |
| 189 | if err := n1.server.Remove(args, &resp); err != nil { |
| 190 | t.Errorf("Remove(%+v) returned an error %v", args, err) |
| 191 | } |
| 192 | |
| 193 | // Check the key is actually deleted. |
| 194 | if n2.data.Contains(k) { |
| 195 | t.Errorf("Contains(%v) returned true; want false", k) |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | func TestRemoveRemoteInvalid(t *testing.T) { |
| 200 | nodes, err := connectedTestNodes(2, 1) |
nothing calls this directly
no test coverage detected