blob: 3136b42862accad6ff14fda2e57274ce101c22e6 [file] [log] [blame]
// Copyright (c) 2019 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include <linux/if_ether.h>
#include "quic/core/quic_packets.h"
#include "quic/qbone/platform/kernel_interface.h"
#include "quic/qbone/platform/netlink_interface.h"
#include "quic/qbone/qbone_client_interface.h"
#include "quic/qbone/qbone_packet_exchanger.h"
namespace quic {
class TunDevicePacketExchanger : public QbonePacketExchanger {
class StatsInterface {
StatsInterface() = default;
StatsInterface(const StatsInterface&) = delete;
StatsInterface& operator=(const StatsInterface&) = delete;
StatsInterface(StatsInterface&&) = delete;
StatsInterface& operator=(StatsInterface&&) = delete;
virtual ~StatsInterface() = default;
virtual void OnPacketRead(size_t count) = 0;
virtual void OnPacketWritten(size_t count) = 0;
virtual void OnReadError(std::string* error) = 0;
virtual void OnWriteError(std::string* error) = 0;
ABSL_MUST_USE_RESULT virtual int64_t PacketsRead() const = 0;
ABSL_MUST_USE_RESULT virtual int64_t PacketsWritten() const = 0;
// |mtu| is the mtu of the TUN device.
// |kernel| is not owned but should out live objects of this class.
// |visitor| is not owned but should out live objects of this class.
// |max_pending_packets| controls the number of packets to be queued should
// the TUN device become blocked.
// |stats| is notified about packet read/write statistics. It is not owned,
// but should outlive objects of this class.
TunDevicePacketExchanger(size_t mtu, KernelInterface* kernel,
NetlinkInterface* netlink,
QbonePacketExchanger::Visitor* visitor,
size_t max_pending_packets, bool is_tap,
StatsInterface* stats, absl::string_view ifname);
void set_file_descriptor(int fd);
ABSL_MUST_USE_RESULT const StatsInterface* stats_interface() const;
// From QbonePacketExchanger.
std::unique_ptr<QuicData> ReadPacket(bool* blocked,
std::string* error) override;
// From QbonePacketExchanger.
bool WritePacket(const char* packet,
size_t size,
bool* blocked,
std::string* error) override;
std::unique_ptr<QuicData> ApplyL2Headers(const QuicData& l3_packet);
std::unique_ptr<QuicData> ConsumeL2Headers(const QuicData& l2_packet);
int fd_ = -1;
size_t mtu_;
KernelInterface* kernel_;
NetlinkInterface* netlink_;
const std::string ifname_;
const bool is_tap_;
uint8_t tap_mac_[ETH_ALEN]{};
bool mac_initialized_ = false;
StatsInterface* stats_;
} // namespace quic