Home
last modified time | relevance | path

Searched refs:epoll_server_ (Results 1 – 25 of 28) sorted by relevance

12

/external/chromium_org/net/tools/quic/
Dquic_epoll_connection_helper_test.cc35 QuicEpollConnectionHelperTest() : helper_(&epoll_server_) {} in QuicEpollConnectionHelperTest()
37 MockEpollServer epoll_server_; member in net::tools::test::__anon66d1dfa70111::QuicEpollConnectionHelperTest
46 epoll_server_.AdvanceBy(delta.ToMicroseconds()); in TEST_F()
65 epoll_server_.AdvanceByAndCallCallbacks(delta.ToMicroseconds()); in TEST_F()
79 epoll_server_.AdvanceByExactlyAndCallCallbacks(delta.ToMicroseconds()); in TEST_F()
96 epoll_server_.AdvanceByExactlyAndCallCallbacks(delta.ToMicroseconds()); in TEST_F()
100 epoll_server_.AdvanceByExactlyAndCallCallbacks( in TEST_F()
118 epoll_server_.AdvanceByExactlyAndCallCallbacks(delta.ToMicroseconds()); in TEST_F()
126 epoll_server_.AdvanceByExactlyAndCallCallbacks( in TEST_F()
Dquic_epoll_connection_helper.cc27 epoll_server_(epoll_server), in QuicEpollAlarm()
33 epoll_server_->RegisterAlarm( in SetImpl()
59 EpollServer* epoll_server_; member in net::tools::__anonb2fe5ac80111::QuicEpollAlarm
66 : epoll_server_(epoll_server), in QuicEpollConnectionHelper()
84 return new QuicEpollAlarm(epoll_server_, delegate); in CreateAlarm()
Dquic_time_wait_list_manager_test.cc93 &epoll_server_, QuicSupportedVersions()), in QuicTimeWaitListManagerTest()
163 NiceMock<MockFakeTimeEpollServer> epoll_server_; member in net::tools::test::__anon53959c150111::QuicTimeWaitListManagerTest
277 epoll_server_.set_now_in_usec(0); in TEST_F()
288 epoll_server_.set_now_in_usec(time_wait_period.ToMicroseconds()); in TEST_F()
297 epoll_server_.set_now_in_usec(time_wait_period.Add(offset).ToMicroseconds()); in TEST_F()
300 int64 next_alarm_time = epoll_server_.ApproximateNowInUsec() + in TEST_F()
302 EXPECT_CALL(epoll_server_, RegisterAlarm(next_alarm_time, _)); in TEST_F()
397 epoll_server_.set_now_in_usec(0); in TEST_F()
422 epoll_server_.set_now_in_usec(time_wait_period.Add(offset).ToMicroseconds()); in TEST_F()
424 int64 next_alarm_time = epoll_server_.ApproximateNowInUsec() + in TEST_F()
[all …]
Dquic_client.cc44 epoll_server_(epoll_server), in QuicClient()
65 epoll_server_(epoll_server), in QuicClient()
81 epoll_server_->UnregisterFD(fd_); in ~QuicClient()
88 epoll_server_->set_timeout_in_us(50 * 1000); in Initialize()
95 epoll_server_->RegisterFD(fd_, this, kEpollFlags); in Initialize()
226 epoll_server_->UnregisterFD(fd_); in Disconnect()
258 epoll_server_->WaitForEventsAndExecuteCallbacks(); in WaitForStreamToClose()
266 epoll_server_->WaitForEventsAndExecuteCallbacks(); in WaitForCryptoHandshakeConfirmed()
273 epoll_server_->WaitForEventsAndExecuteCallbacks(); in WaitForEvents()
326 return new QuicEpollConnectionHelper(epoll_server_); in CreateQuicConnectionHelper()
Dquic_epoll_clock.cc13 : epoll_server_(epoll_server) { in QuicEpollClock()
20 QuicTime::Delta::FromMicroseconds(epoll_server_->ApproximateNowInUsec())); in ApproximateNow()
25 QuicTime::Delta::FromMicroseconds(epoll_server_->NowInUsec())); in Now()
Dquic_server.cc73 epoll_server_.set_timeout_in_us(50 * 1000); in Initialize()
77 QuicEpollClock clock(&epoll_server_); in Initialize()
157 epoll_server_.RegisterFD(fd_, this, kEpollFlags); in Listen()
170 &epoll_server_); in CreateQuicDispatcher()
174 epoll_server_.WaitForEventsAndExecuteCallbacks(); in WaitForEvents()
Dquic_epoll_connection_helper.h43 EpollServer* epoll_server() { return epoll_server_; } in epoll_server()
48 EpollServer* epoll_server_; // Not owned. variable
Dquic_server.h93 EpollServer* epoll_server() { return &epoll_server_; } in epoll_server()
104 EpollServer epoll_server_; variable
Dquic_time_wait_list_manager.cc92 : epoll_server_(epoll_server), in QuicTimeWaitListManager()
95 clock_(epoll_server_), in QuicTimeWaitListManager()
270 epoll_server_->RegisterAlarmApproximateDelta( in SetConnectionIdCleanUpAlarm()
Dquic_client.h185 EpollServer* epoll_server() { return epoll_server_; } in epoll_server()
236 EpollServer* epoll_server_; variable
Dquic_epoll_clock.h34 EpollServer* epoll_server_;
Dquic_dispatcher.h153 EpollServer* epoll_server() { return epoll_server_; } in epoll_server()
230 EpollServer* epoll_server_; // Owned by the server. variable
Dquic_dispatcher.cc190 epoll_server_(epoll_server), in QuicDispatcher()
191 helper_(new QuicEpollConnectionHelper(epoll_server_)), in QuicDispatcher()
350 epoll_server_->RegisterAlarmApproximateDelta( in OnConnectionClosed()
Dquic_time_wait_list_manager.h157 EpollServer* epoll_server_; variable
/external/chromium_org/net/tools/flip_server/
Doutput_ordering.cc26 epoll_server_ = connection->epoll_server(); in OutputOrdering()
36 epoll_server_->UnregisterAlarm(pmp.alarm_token); in Reset()
53 : output_ordering_(oo), pmp_(pmp), mci_(mci), epoll_server_(NULL) {} in BeginOutputtingAlarm()
56 if (epoll_server_ && pmp_->alarm_enabled) in ~BeginOutputtingAlarm()
57 epoll_server_->UnregisterAlarm(pmp_->alarm_token); in ~BeginOutputtingAlarm()
71 epoll_server_ = eps; in OnRegistration()
119 epoll_server_->RegisterAlarmApproximateDelta(think_time_in_s * 1000000, boa); in AddToOutputOrder()
169 epoll_server_->UnregisterAlarm(pmp.alarm_token); in RemoveStreamId()
Dacceptor_thread.cc62 &epoll_server_, ssl_state_, memory_cache_, acceptor_, "client_conn: "); in NewConnection()
79 epoll_server_.RegisterFD(acceptor_->listen_fd_, this, EPOLLIN | EPOLLET); in InitWorker()
108 &epoll_server_, in HandleConnection()
184 epoll_server_.set_timeout_in_us(10 * 1000); // 10 ms in Run()
185 epoll_server_.WaitForEventsAndExecuteCallbacks(); in Run()
Dsm_connection.cc46 epoll_server_(epoll_server), in SMConnection()
64 EpollServer* SMConnection::epoll_server() { return epoll_server_; } in epoll_server()
69 epoll_server_->SetFDReady(fd_, EPOLLIN | EPOLLOUT); in ReadyToSend()
124 if (epoll_server_ && registered_in_epoll_server_ && fd_ != -1) { in InitSMConnection()
125 epoll_server_->UnregisterFD(fd_); in InitSMConnection()
144 epoll_server_ = epoll_server; in InitSMConnection()
153 epoll_server_->RegisterFD(fd_, this, EPOLLIN | EPOLLOUT | EPOLLET); in InitSMConnection()
379 new StreamerSM(this, NULL, epoll_server_, acceptor_); in SetupProtocolInterfaces()
398 this, NULL, epoll_server_, memory_cache_, acceptor_, version); in SetupProtocolInterfaces()
636 epoll_server_->UnregisterFD(fd_); in Reset()
Dstreamer_interface.cc24 epoll_server_(epoll_server), in StreamerSM()
121 epoll_server_, NULL, NULL, acceptor_, "server_conn: "); in PostAcceptHook()
129 new StreamerSM(server_connection, this, epoll_server_, acceptor_); in PostAcceptHook()
136 epoll_server_, in PostAcceptHook()
Doutput_ordering.h44 EpollServer* epoll_server_; variable
69 EpollServer* epoll_server_; member
Dhttp_interface_test.cc76 epoll_server_.reset(new EpollServer); in FlipHttpSMTest()
77 connection_.reset(new MockSMConnection(epoll_server_.get(), in FlipHttpSMTest()
91 epoll_server_->UnregisterFD(acceptor_->listen_fd_); in TearDown()
106 scoped_ptr<EpollServer> epoll_server_; member in net::__anon539ba2cb0111::FlipHttpSMTest
Dspdy_interface_test.cc141 epoll_server_.reset(new EpollServer); in SpdySMTestBase()
142 connection_.reset(new FakeSMConnection(epoll_server_.get(), in SpdySMTestBase()
150 epoll_server_.get(), in SpdySMTestBase()
162 epoll_server_->UnregisterFD(acceptor_->listen_fd_); in ~SpdySMTestBase()
183 scoped_ptr<EpollServer> epoll_server_; member in net::__anon72099feb0111::SpdySMTestBase
213 NULL, NULL, epoll_server_.get(), -1, "", "", "", false); in TEST_P()
Dacceptor_thread.h81 EpollServer epoll_server_;
Dspdy_interface.cc47 epoll_server_(epoll_server), in SpdySM()
77 SMConnection::NewSMConnection(epoll_server_, in NewConnectionInterface()
114 epoll_server_, in FindOrMakeNewSMConnectionInterface()
/external/chromium_org/net/tools/quic/test_tools/
Dquic_test_client.h166 EpollServer* epoll_server() { return &epoll_server_; } in epoll_server()
176 EpollServer epoll_server_;
Dquic_test_client.cc170 &epoll_server_)) { in QuicTestClient()
184 &epoll_server_)) { in QuicTestClient()
202 &epoll_server_)) { in QuicTestClient()

12