rtp_uncompressed_payloader.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_PAYLOADER_H_
#define UNCOMPRESSED_RTP_UNCOMPRESSED_PAYLOADER_H_
 
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
 
#include <array>
#include <chrono>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
#if _WIN32
#include <winsock2.h>
#else
#include <netdb.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/types.h>
#endif
#include "rtp/rtp_payloader.h"
#include "rtp/rtp_types.h"
 
namespace mediax::rtp::uncompressed {
 
class RtpUncompressedPayloader : public ::mediax::rtp::RtpPayloader {
 public:
 
  RtpUncompressedPayloader();
 
  ~RtpUncompressedPayloader() final;
 
  void SetStreamInfo(const ::mediax::rtp::StreamInformation &stream_information) final;
 
  bool Open() final;
 
  void Close() final;
 
  int Transmit(uint8_t *rgbframe, bool blocking = true) final;
 
  static void SendFrame(RtpUncompressedPayloader *stream);
 
  std::mutex &GetMutex() { return mutex_; }
 
 private:
  static uint32_t sequence_number_;
  rtp::TxData arg_tx;
  struct addrinfo *server_out_;
  struct sockaddr_in server_addr_out_;
  socklen_t server_len_out_;
  static std::vector<uint8_t> buffer_in_;
  std::thread tx_thread_;
  std::mutex mutex_;
 
  void UpdateHeader(rtp::RtpHeader *packet, int line, int bytes_per_pixel, int last, int32_t timestamp, int32_t source);
 
  static void TransmitThread(RtpUncompressedPayloader *stream);
 
  static int32_t GenerateTimestamp90kHz();
};
 
}  // namespace mediax::rtp::uncompressed
 
#endif  // UNCOMPRESSED_RTP_UNCOMPRESSED_PAYLOADER_H_