Home
last modified time | relevance | path

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

12

/external/chromium_org/net/tools/quic/
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::__anon54f6e1bb0111::QuicEpollAlarm
66 : epoll_server_(epoll_server), in QuicEpollConnectionHelper()
84 return new QuicEpollAlarm(epoll_server_, delegate); in CreateAlarm()
Dquic_epoll_connection_helper_test.cc35 QuicEpollConnectionHelperTest() : helper_(&epoll_server_) {} in QuicEpollConnectionHelperTest()
37 MockEpollServer epoll_server_; member in net::tools::test::__anoncde3b67a0111::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()
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_client.cc77 epoll_server_.set_timeout_in_us(50 * 1000); in Initialize()
140 epoll_server_.RegisterFD(fd_, this, kEpollFlags); in Initialize()
183 epoll_server_.UnregisterFD(fd_); in Disconnect()
214 epoll_server_.WaitForEventsAndExecuteCallbacks(); in WaitForStreamToClose()
222 epoll_server_.WaitForEventsAndExecuteCallbacks(); in WaitForCryptoHandshakeConfirmed()
229 epoll_server_.WaitForEventsAndExecuteCallbacks(); in WaitForEvents()
283 return new QuicEpollConnectionHelper(&epoll_server_); in CreateQuicConnectionHelper()
Dquic_server.cc69 epoll_server_.set_timeout_in_us(50 * 1000); in Initialize()
73 QuicEpollClock clock(&epoll_server_); in Initialize()
149 epoll_server_.RegisterFD(fd_, this, kEpollFlags); in Listen()
152 fd_, &epoll_server_)); in Listen()
158 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_time_wait_list_manager_test.cc81 &writer_, &epoll_server_, QuicSupportedVersions()), in QuicTimeWaitListManagerTest()
139 MockFakeTimeEpollServer epoll_server_; member in net::tools::test::__anonbb8e64880111::QuicTimeWaitListManagerTest
297 epoll_server_.set_now_in_usec(0); in TEST_F()
305 epoll_server_.set_now_in_usec(time_wait_period.ToMicroseconds()); in TEST_F()
312 epoll_server_.set_now_in_usec(time_wait_period.Add(offset).ToMicroseconds()); in TEST_F()
314 int64 next_alarm_time = epoll_server_.ApproximateNowInUsec() + in TEST_F()
316 EXPECT_CALL(epoll_server_, RegisterAlarm(next_alarm_time, _)); in TEST_F()
Dquic_dispatcher.cc48 epoll_server_(epoll_server), in QuicDispatcher()
51 helper_(new QuicEpollConnectionHelper(epoll_server_)), in QuicDispatcher()
208 epoll_server_->RegisterAlarmApproximateDelta( in OnConnectionClosed()
Dquic_dispatcher.h125 EpollServer* epoll_server() { return epoll_server_; }
152 EpollServer* epoll_server_; // Owned by the server.
Dquic_client.h122 EpollServer* epoll_server() { return &epoll_server_; } in epoll_server()
178 EpollServer epoll_server_; variable
Dquic_epoll_clock.h33 EpollServer* epoll_server_;
Dquic_server.h92 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.cc61 &epoll_server_, ssl_state_, memory_cache_, acceptor_, "client_conn: "); in NewConnection()
78 epoll_server_.RegisterFD(acceptor_->listen_fd_, this, EPOLLIN | EPOLLET); in InitWorker()
107 &epoll_server_, in HandleConnection()
183 epoll_server_.set_timeout_in_us(10 * 1000); // 10 ms in Run()
184 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()
396 this, NULL, epoll_server_, memory_cache_, acceptor_, version); in SetupProtocolInterfaces()
634 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::__anon17cfd0fe0111::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::__anon363dce1e0111::SpdySMTestBase
213 NULL, NULL, epoll_server_.get(), -1, "", "", "", false); in TEST_P()
/external/chromium/net/tools/flip_server/
Doutput_ordering.cc20 epoll_server_ = connection->epoll_server(); in OutputOrdering()
30 epoll_server_->UnregisterAlarm(pmp.alarm_token); in Reset()
50 epoll_server_(NULL) { in BeginOutputtingAlarm()
54 if (epoll_server_ && pmp_->alarm_enabled) in ~BeginOutputtingAlarm()
55 epoll_server_->UnregisterAlarm(pmp_->alarm_token); in ~BeginOutputtingAlarm()
69 epoll_server_ = eps; in OnRegistration()
117 epoll_server_->RegisterAlarmApproximateDelta( in AddToOutputOrder()
172 epoll_server_->UnregisterAlarm(pmp.alarm_token); in RemoveStreamId()
Dsm_connection.cc39 epoll_server_(epoll_server), in SMConnection()
59 return epoll_server_; in epoll_server()
65 epoll_server_->SetFDReady(fd_, EPOLLIN | EPOLLOUT); in ReadyToSend()
123 if (epoll_server_ && registered_in_epoll_server_ && fd_ != -1) { in InitSMConnection()
124 epoll_server_->UnregisterFD(fd_); in InitSMConnection()
143 epoll_server_ = epoll_server; in InitSMConnection()
152 epoll_server_->RegisterFD(fd_, this, EPOLLIN | EPOLLOUT | EPOLLET); in InitSMConnection()
354 epoll_server_, in SetupProtocolInterfaces()
368 epoll_server_, in SetupProtocolInterfaces()
388 epoll_server_, in SetupProtocolInterfaces()
[all …]
Dacceptor_thread.cc61 SMConnection::NewSMConnection(&epoll_server_, ssl_state_, in NewConnection()
80 epoll_server_.RegisterFD(acceptor_->listen_fd_, this, EPOLLIN | EPOLLET); in InitWorker()
106 &epoll_server_, in HandleConnection()
180 epoll_server_.set_timeout_in_us(10 * 1000); // 10 ms in Run()
181 epoll_server_.WaitForEventsAndExecuteCallbacks(); in Run()
Dstreamer_interface.cc24 epoll_server_(epoll_server), in StreamerSM()
120 SMConnection::NewSMConnection(epoll_server_, NULL, NULL, in PostAcceptHook()
129 epoll_server_, acceptor_); in PostAcceptHook()
135 epoll_server_, -1, in PostAcceptHook()
Doutput_ordering.h42 EpollServer* epoll_server_; variable
67 EpollServer* epoll_server_; member
Dspdy_interface.cc74 epoll_server_(epoll_server), in SpdySM()
102 SMConnection::NewSMConnection(epoll_server_, in NewConnectionInterface()
114 epoll_server_, in NewConnectionInterface()
141 epoll_server_, -1, in FindOrMakeNewSMConnectionInterface()

12