(t *testing.T)
| 267 | } |
| 268 | |
| 269 | func TestP2pPeerNotFound(t *testing.T) { |
| 270 | l := zerolog.Nop() |
| 271 | m := map[string][]string{} |
| 272 | |
| 273 | req, err := http.NewRequest("GET", "http://127.0.0.1:5000/blobs/"+u, nil) |
| 274 | if err != nil { |
| 275 | t.Fatal(err) |
| 276 | } |
| 277 | |
| 278 | router := mocks.NewMockRouter(m) |
| 279 | c, _ := gin.CreateTestContext(httptest.NewRecorder()) |
| 280 | c.Request = req |
| 281 | |
| 282 | r := NewReader(pcontext.FromContext(c), router, 3, 500*time.Millisecond, mr).(*reader) |
| 283 | |
| 284 | b := make([]byte, 10) |
| 285 | _, err = r.doP2p(l, "key", 0, 10, operationPreadRemote, b) |
| 286 | if err == nil { |
| 287 | t.Fatal("expected error") |
| 288 | } |
| 289 | |
| 290 | if err != errPeerNotFound { |
| 291 | t.Fatalf("expected %v, got %v", errPeerNotFound, err) |
| 292 | } |
| 293 | } |
| 294 | |
| 295 | func TestP2pNoInfiniteLoops(t *testing.T) { |
| 296 | l := zerolog.Nop() |
nothing calls this directly
no test coverage detected