Lines Matching refs:requests

386   ScopedVector<TestSocketRequest>* requests() { return test_base_.requests(); }
529 EXPECT_EQ(OK, (*requests())[0]->WaitForResult());
557 // One initial asynchronous request and then 10 pending requests.
560 // First part of requests, all with the same priority, finishes in FIFO order.
568 // Make sure that rest of the requests complete in the order of priority.
580 // Make sure we test order of all requests made.
587 EXPECT_EQ(OK, (*requests())[0]->WaitForResult());
608 // The pending requests should finish successfully.
609 EXPECT_EQ(OK, (*requests())[6]->WaitForResult());
610 EXPECT_EQ(OK, (*requests())[7]->WaitForResult());
611 EXPECT_EQ(OK, (*requests())[8]->WaitForResult());
612 EXPECT_EQ(OK, (*requests())[9]->WaitForResult());
613 EXPECT_EQ(OK, (*requests())[10]->WaitForResult());
615 EXPECT_EQ(static_cast<int>(requests()->size()),
618 // First asynchronous request, and then last 5 pending requests.
683 EXPECT_EQ(OK, (*requests())[0]->WaitForResult());
694 // Reached per-group limit, queue up requests.
708 EXPECT_FALSE((*requests())[index_to_cancel]->handle()->is_initialized());
709 (*requests())[index_to_cancel]->handle()->Reset();
715 EXPECT_EQ(requests()->size() - kMaxSocketsPerGroup, completion_count());
735 // Make sure we test order of all requests made.
798 // Make sure that pending requests get serviced after active requests get
804 // Queue up all the requests
815 // Now, kMaxSocketsPerGroup requests should be active. Let's cancel them.
816 ASSERT_LE(kMaxSocketsPerGroup, static_cast<int>(requests()->size()));
818 (*requests())[i]->handle()->Reset();
821 for (size_t i = kMaxSocketsPerGroup; i < requests()->size(); ++i) {
822 EXPECT_EQ(OK, (*requests())[i]->WaitForResult());
823 (*requests())[i]->handle()->Reset();
826 EXPECT_EQ(requests()->size() - kMaxSocketsPerGroup, completion_count());
829 // Make sure that pending requests get serviced after active requests fail.
837 // Queue up all the requests
842 EXPECT_EQ(ERR_CONNECTION_FAILED, (*requests())[i]->WaitForResult());