mirror of
https://github.com/mollyim/webrtc.git
synced 2025-05-13 22:00:47 +01:00
24ee167a3d
This name will better describe what implementation should do and how users will interact with this class. The real simulation is done by FakeNetworkPipe and this class is just operates with packages metadata, so it is more about describing behavior. Bug: webrtc:9630 Change-Id: I00977e6be0ca84e7c233b4c35f0677e8263e4382 Reviewed-on: https://webrtc-review.googlesource.com/c/95944 Reviewed-by: Karl Wiberg <kwiberg@webrtc.org> Reviewed-by: Sebastian Jansson <srte@webrtc.org> Commit-Queue: Artem Titov <titovartem@webrtc.org> Cr-Commit-Position: refs/heads/master@{#24989}
83 lines
2.8 KiB
C++
83 lines
2.8 KiB
C++
/*
|
|
* Copyright (c) 2018 The WebRTC project authors. All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by a BSD-style license
|
|
* that can be found in the LICENSE file in the root of the source
|
|
* tree. An additional intellectual property rights grant can be found
|
|
* in the file PATENTS. All contributing project authors may
|
|
* be found in the AUTHORS file in the root of the source tree.
|
|
*/
|
|
|
|
#ifndef API_TEST_SIMULATED_NETWORK_H_
|
|
#define API_TEST_SIMULATED_NETWORK_H_
|
|
|
|
#include <stddef.h>
|
|
#include <stdint.h>
|
|
#include <deque>
|
|
#include <queue>
|
|
#include <vector>
|
|
|
|
#include "absl/types/optional.h"
|
|
#include "rtc_base/criticalsection.h"
|
|
#include "rtc_base/random.h"
|
|
#include "rtc_base/thread_annotations.h"
|
|
|
|
namespace webrtc {
|
|
|
|
struct PacketInFlightInfo {
|
|
PacketInFlightInfo(size_t size, int64_t send_time_us, uint64_t packet_id)
|
|
: size(size), send_time_us(send_time_us), packet_id(packet_id) {}
|
|
|
|
size_t size;
|
|
int64_t send_time_us;
|
|
// Unique identifier for the packet in relation to other packets in flight.
|
|
uint64_t packet_id;
|
|
};
|
|
|
|
struct PacketDeliveryInfo {
|
|
static constexpr int kNotReceived = -1;
|
|
PacketDeliveryInfo(PacketInFlightInfo source, int64_t receive_time_us)
|
|
: receive_time_us(receive_time_us), packet_id(source.packet_id) {}
|
|
int64_t receive_time_us;
|
|
uint64_t packet_id;
|
|
};
|
|
|
|
// DefaultNetworkSimulationConfig is a default network behavior configuration
|
|
// for default network behavior that will be used by WebRTC if no custom
|
|
// NetworkBehaviorInterface is provided.
|
|
struct DefaultNetworkSimulationConfig {
|
|
DefaultNetworkSimulationConfig() {}
|
|
// Queue length in number of packets.
|
|
size_t queue_length_packets = 0;
|
|
// Delay in addition to capacity induced delay.
|
|
int queue_delay_ms = 0;
|
|
// Standard deviation of the extra delay.
|
|
int delay_standard_deviation_ms = 0;
|
|
// Link capacity in kbps.
|
|
int link_capacity_kbps = 0;
|
|
// Random packet loss.
|
|
int loss_percent = 0;
|
|
// If packets are allowed to be reordered.
|
|
bool allow_reordering = false;
|
|
// The average length of a burst of lost packets.
|
|
int avg_burst_loss_length = -1;
|
|
};
|
|
|
|
class NetworkBehaviorInterface {
|
|
public:
|
|
virtual bool EnqueuePacket(PacketInFlightInfo packet_info) = 0;
|
|
// Retrieves all packets that should be delivered by the given receive time.
|
|
virtual std::vector<PacketDeliveryInfo> DequeueDeliverablePackets(
|
|
int64_t receive_time_us) = 0;
|
|
// Returns time in microseconds when caller should call
|
|
// DequeueDeliverablePackets to get next set of packets to deliver.
|
|
virtual absl::optional<int64_t> NextDeliveryTimeUs() const = 0;
|
|
virtual ~NetworkBehaviorInterface() = default;
|
|
};
|
|
|
|
// Deprecated. DO NOT USE. Use NetworkBehaviorInterface instead.
|
|
using NetworkSimulationInterface = NetworkBehaviorInterface;
|
|
|
|
} // namespace webrtc
|
|
|
|
#endif // API_TEST_SIMULATED_NETWORK_H_
|