dd2eebef5e
Because DirectTransport is switched on SimulatedPacketReceiverInterface we can't create it from some specific config in ctor, so all ctors, that accept specific config are deprecated and you should pass concrete implementation of underlying implememntation instead. Bug: webrtc:9630 Change-Id: I7f241f310c993d8136b40898e55a6915924d61bd Reviewed-on: https://webrtc-review.googlesource.com/94841 Reviewed-by: Sebastian Jansson <srte@webrtc.org> Reviewed-by: Patrik Höglund <phoglund@webrtc.org> Commit-Queue: Artem Titov <titovartem@webrtc.org> Cr-Commit-Position: refs/heads/master@{#24344}
104 lines
3.5 KiB
C++
104 lines
3.5 KiB
C++
/*
|
|
* Copyright (c) 2013 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 TEST_DIRECT_TRANSPORT_H_
|
|
#define TEST_DIRECT_TRANSPORT_H_
|
|
|
|
#include <assert.h>
|
|
|
|
#include <memory>
|
|
|
|
#include "api/call/transport.h"
|
|
#include "api/test/simulated_network.h"
|
|
#include "call/call.h"
|
|
#include "call/simulated_packet_receiver.h"
|
|
#include "rtc_base/sequenced_task_checker.h"
|
|
#include "rtc_base/thread_annotations.h"
|
|
#include "test/single_threaded_task_queue.h"
|
|
|
|
namespace webrtc {
|
|
|
|
class Clock;
|
|
class PacketReceiver;
|
|
|
|
namespace test {
|
|
class Demuxer {
|
|
public:
|
|
explicit Demuxer(const std::map<uint8_t, MediaType>& payload_type_map);
|
|
~Demuxer() = default;
|
|
MediaType GetMediaType(const uint8_t* packet_data,
|
|
const size_t packet_length) const;
|
|
const std::map<uint8_t, MediaType> payload_type_map_;
|
|
RTC_DISALLOW_COPY_AND_ASSIGN(Demuxer);
|
|
};
|
|
|
|
// Objects of this class are expected to be allocated and destroyed on the
|
|
// same task-queue - the one that's passed in via the constructor.
|
|
class DirectTransport : public Transport {
|
|
public:
|
|
// Deprecated. DO NOT USE. Use the constructor that takes an
|
|
// explicit pipe instead.Because there can be different ways to simulated
|
|
// underlying network passing implementation specific config to the transport
|
|
// constructor makes no sense.
|
|
DirectTransport(SingleThreadedTaskQueueForTesting* task_queue,
|
|
Call* send_call,
|
|
const std::map<uint8_t, MediaType>& payload_type_map);
|
|
|
|
// Deprecated. DO NOT USE. Use the constructor that takes an
|
|
// explicit pipe instead.Because there can be different ways to simulated
|
|
// underlying network passing implementation specific config to the transport
|
|
// constructor makes no sense.
|
|
DirectTransport(SingleThreadedTaskQueueForTesting* task_queue,
|
|
const DefaultNetworkSimulationConfig& config,
|
|
Call* send_call,
|
|
const std::map<uint8_t, MediaType>& payload_type_map);
|
|
|
|
DirectTransport(SingleThreadedTaskQueueForTesting* task_queue,
|
|
std::unique_ptr<SimulatedPacketReceiverInterface> pipe,
|
|
Call* send_call,
|
|
const std::map<uint8_t, MediaType>& payload_type_map);
|
|
|
|
~DirectTransport() override;
|
|
|
|
void SetConfig(const DefaultNetworkSimulationConfig& config);
|
|
|
|
RTC_DEPRECATED void StopSending();
|
|
|
|
// TODO(holmer): Look into moving this to the constructor.
|
|
virtual void SetReceiver(PacketReceiver* receiver);
|
|
|
|
bool SendRtp(const uint8_t* data,
|
|
size_t length,
|
|
const PacketOptions& options) override;
|
|
bool SendRtcp(const uint8_t* data, size_t length) override;
|
|
|
|
int GetAverageDelayMs();
|
|
|
|
private:
|
|
void SendPackets();
|
|
void SendPacket(const uint8_t* data, size_t length);
|
|
void Start();
|
|
|
|
Call* const send_call_;
|
|
Clock* const clock_;
|
|
|
|
SingleThreadedTaskQueueForTesting* const task_queue_;
|
|
SingleThreadedTaskQueueForTesting::TaskId next_scheduled_task_
|
|
RTC_GUARDED_BY(&sequence_checker_);
|
|
|
|
const Demuxer demuxer_;
|
|
const std::unique_ptr<SimulatedPacketReceiverInterface> fake_network_;
|
|
|
|
rtc::SequencedTaskChecker sequence_checker_;
|
|
};
|
|
} // namespace test
|
|
} // namespace webrtc
|
|
|
|
#endif // TEST_DIRECT_TRANSPORT_H_
|