rtp_uncompressed_depayloader.h

Go to the documentation of this file.

//
// Copyright (c) 2025, Astute Systems PTY LTD
//
// This file is part of the VivoeX project developed by Astute Systems.
//
// Licensed under the Attribution-NonCommercial 4.0 International (CC BY-NC 4.0)
// License. See the LICENSE file in the project root for full license details.
//
 
#ifndef UNCOMPRESSED_RTP_UNCOMPRESSED_DEPAYLOADER_H_
#define UNCOMPRESSED_RTP_UNCOMPRESSED_DEPAYLOADER_H_
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
 
#include <array>
#include <chrono>
#include <string>
#include <thread>
#if _WIN32
#include <winsock2.h>
#else
#include <netdb.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/types.h>
#endif
#include <atomic>
#include <limits>
#include <vector>
 
#include "rtp/rtp_depayloader.h"
#include "rtp/rtp_types.h"
 
namespace mediax::rtp::uncompressed {
 
class RtpUncompressedDepayloader : public ::mediax::rtp::RtpDepayloader {
 public:
 
  RtpUncompressedDepayloader();
 
  ~RtpUncompressedDepayloader(void) final = default;
 
  RtpUncompressedDepayloader(RtpUncompressedDepayloader &&other) = delete;
 
  void SetStreamInfo(const ::mediax::rtp::StreamInformation &stream_information) final;
 
  bool Open() final;
 
  void Start() final;
 
  void Stop() final;
 
  void Close() final;
 
  bool Receive(::mediax::rtp::RtpFrameData *data, int32_t timeout = 0) final;
 
  void Callback(::mediax::rtp::RtpFrameData frame) const final;
 
 private:
  std::atomic<bool> new_rx_frame_ = false;
  bool rx_thread_running_ = true;
  ::mediax::rtp::TxData arg_tx;
  pthread_mutex_t mutex_;
  std::array<uint8_t, ::mediax::rtp::kMaxUdpData> udpdata;
  std::thread rx_thread_;
  uint32_t sequence_number_ = 0;
 
  void UpdateHeader(::mediax::rtp::RtpHeaderData *packet, int line, int last, int32_t timestamp, int32_t source) const;
 
  static void TransmitThread(RtpUncompressedDepayloader *stream);
 
  static void ReceiveThread(RtpUncompressedDepayloader *stream);
 
  bool WaitForFrame(uint8_t **cpu, int32_t timeout);
 
  static int32_t GenerateTimestamp90kHz();
 
  bool ReadRtpHeader(RtpUncompressedDepayloader *stream, ::mediax::rtp::RtpPacket *packet);
 
  bool ReceiveLines(::mediax::rtp::RtpPacket *packet, bool *last_scan_line, int *last_packet);
};
 
}  // namespace mediax::rtp::uncompressed
 
#endif  // UNCOMPRESSED_RTP_UNCOMPRESSED_DEPAYLOADER_H_