diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
commit | 36d22d82aa202bb199967e9512281e9a53db42c9 (patch) | |
tree | 105e8c98ddea1c1e4784a60a5a6410fa416be2de /dom/media/webrtc/transport/transportlayerloopback.h | |
parent | Initial commit. (diff) | |
download | firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.tar.xz firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.zip |
Adding upstream version 115.7.0esr.upstream/115.7.0esr
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'dom/media/webrtc/transport/transportlayerloopback.h')
-rw-r--r-- | dom/media/webrtc/transport/transportlayerloopback.h | 109 |
1 files changed, 109 insertions, 0 deletions
diff --git a/dom/media/webrtc/transport/transportlayerloopback.h b/dom/media/webrtc/transport/transportlayerloopback.h new file mode 100644 index 0000000000..6801af8189 --- /dev/null +++ b/dom/media/webrtc/transport/transportlayerloopback.h @@ -0,0 +1,109 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* vim: set ts=2 et sw=2 tw=80: */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this file, + * You can obtain one at http://mozilla.org/MPL/2.0/. */ + +// Original author: ekr@rtfm.com + +#ifndef transportlayerloopback_h__ +#define transportlayerloopback_h__ + +#include "prlock.h" + +#include <queue> + +#include "nsCOMPtr.h" +#include "nsINamed.h" +#include "nsITimer.h" + +#include "m_cpp_utils.h" +#include "transportlayer.h" + +// A simple loopback transport layer that is used for testing. +namespace mozilla { + +class TransportLayerLoopback : public TransportLayer { + public: + TransportLayerLoopback() + : peer_(nullptr), + timer_(nullptr), + packets_(), + packets_lock_(nullptr), + deliverer_(nullptr), + combinePackets_(false) {} + + ~TransportLayerLoopback() { + while (!packets_.empty()) { + MediaPacket* packet = packets_.front(); + packets_.pop(); + delete packet; + } + if (packets_lock_) { + PR_DestroyLock(packets_lock_); + } + timer_->Cancel(); + deliverer_->Detach(); + } + + // Init + nsresult Init(); + + // Connect to the other side + void Connect(TransportLayerLoopback* peer); + + // Disconnect + void Disconnect() { + TransportLayerLoopback* peer = peer_; + + peer_ = nullptr; + if (peer) { + peer->Disconnect(); + } + } + + void CombinePackets(bool combine) { combinePackets_ = combine; } + + // Overrides for TransportLayer + TransportResult SendPacket(MediaPacket& packet) override; + + // Deliver queued packets + void DeliverPackets(); + + TRANSPORT_LAYER_ID("loopback") + + private: + DISALLOW_COPY_ASSIGN(TransportLayerLoopback); + + // A timer to deliver packets if some are available + // Fires every 100 ms + class Deliverer : public nsITimerCallback, public nsINamed { + public: + explicit Deliverer(TransportLayerLoopback* layer) : layer_(layer) {} + void Detach() { layer_ = nullptr; } + + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSITIMERCALLBACK + NS_DECL_NSINAMED + + private: + virtual ~Deliverer() = default; + + DISALLOW_COPY_ASSIGN(Deliverer); + + TransportLayerLoopback* layer_; + }; + + // Queue a packet for delivery + nsresult QueuePacket(MediaPacket& packet); + + TransportLayerLoopback* peer_; + nsCOMPtr<nsITimer> timer_; + std::queue<MediaPacket*> packets_; + PRLock* packets_lock_; + RefPtr<Deliverer> deliverer_; + bool combinePackets_; +}; + +} // namespace mozilla +#endif |