| Index: net/tools/quic/quic_epoll_connection_helper.cc
|
| diff --git a/net/tools/quic/quic_epoll_connection_helper.cc b/net/tools/quic/quic_epoll_connection_helper.cc
|
| index 2534ade5787f6b74640d73d54e937fc102fdf45c..d1e3d1b5a6f97ccaf40a9cd8cb0004b4a7723df3 100644
|
| --- a/net/tools/quic/quic_epoll_connection_helper.cc
|
| +++ b/net/tools/quic/quic_epoll_connection_helper.cc
|
| @@ -4,67 +4,18 @@
|
|
|
| #include "net/tools/quic/quic_epoll_connection_helper.h"
|
|
|
| -#include <errno.h>
|
| #include <sys/socket.h>
|
| +#include <errno.h>
|
|
|
| #include "base/logging.h"
|
| -#include "base/stl_util.h"
|
| -#include "net/base/ip_endpoint.h"
|
| #include "net/quic/crypto/quic_random.h"
|
| #include "net/tools/epoll_server/epoll_server.h"
|
| -#include "net/tools/quic/quic_socket_utils.h"
|
|
|
| namespace net {
|
|
|
| -namespace {
|
| -
|
| -class QuicEpollAlarm : public QuicAlarm {
|
| - public:
|
| - QuicEpollAlarm(EpollServer* epoll_server,
|
| - QuicArenaScopedPtr<Delegate> delegate)
|
| - : QuicAlarm(std::move(delegate)),
|
| - epoll_server_(epoll_server),
|
| - epoll_alarm_impl_(this) {}
|
| -
|
| - protected:
|
| - void SetImpl() override {
|
| - DCHECK(deadline().IsInitialized());
|
| - epoll_server_->RegisterAlarm(
|
| - deadline().Subtract(QuicTime::Zero()).ToMicroseconds(),
|
| - &epoll_alarm_impl_);
|
| - }
|
| -
|
| - void CancelImpl() override {
|
| - DCHECK(!deadline().IsInitialized());
|
| - epoll_alarm_impl_.UnregisterIfRegistered();
|
| - }
|
| -
|
| - private:
|
| - class EpollAlarmImpl : public EpollAlarm {
|
| - public:
|
| - explicit EpollAlarmImpl(QuicEpollAlarm* alarm) : alarm_(alarm) {}
|
| -
|
| - int64_t OnAlarm() override {
|
| - EpollAlarm::OnAlarm();
|
| - alarm_->Fire();
|
| - // Fire will take care of registering the alarm, if needed.
|
| - return 0;
|
| - }
|
| -
|
| - private:
|
| - QuicEpollAlarm* alarm_;
|
| - };
|
| -
|
| - EpollServer* epoll_server_;
|
| - EpollAlarmImpl epoll_alarm_impl_;
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| QuicEpollConnectionHelper::QuicEpollConnectionHelper(EpollServer* epoll_server,
|
| QuicAllocator type)
|
| - : epoll_server_(epoll_server),
|
| - clock_(epoll_server),
|
| + : clock_(epoll_server),
|
| random_generator_(QuicRandom::GetInstance()),
|
| allocator_type_(type) {}
|
|
|
| @@ -78,23 +29,6 @@ QuicRandom* QuicEpollConnectionHelper::GetRandomGenerator() {
|
| return random_generator_;
|
| }
|
|
|
| -QuicAlarm* QuicEpollConnectionHelper::CreateAlarm(
|
| - QuicAlarm::Delegate* delegate) {
|
| - return new QuicEpollAlarm(epoll_server_,
|
| - QuicArenaScopedPtr<QuicAlarm::Delegate>(delegate));
|
| -}
|
| -
|
| -QuicArenaScopedPtr<QuicAlarm> QuicEpollConnectionHelper::CreateAlarm(
|
| - QuicArenaScopedPtr<QuicAlarm::Delegate> delegate,
|
| - QuicConnectionArena* arena) {
|
| - if (arena != nullptr) {
|
| - return arena->New<QuicEpollAlarm>(epoll_server_, std::move(delegate));
|
| - } else {
|
| - return QuicArenaScopedPtr<QuicAlarm>(
|
| - new QuicEpollAlarm(epoll_server_, std::move(delegate)));
|
| - }
|
| -}
|
| -
|
| QuicBufferAllocator* QuicEpollConnectionHelper::GetBufferAllocator() {
|
| if (allocator_type_ == QuicAllocator::BUFFER_POOL) {
|
| return &buffer_allocator_;
|
|
|