NGIAgoraRtmpConnection.h

Go to the documentation of this file.

//
//  Agora RTMP connection
//
//  Created by Haonong Yu in 2020-02.
//  Copyright (c) 2020 Agora.io. All rights reserved.
//
 
#pragma once  // NOLINT(build/header_guard)
 
#include "AgoraBase.h"
#include "AgoraRefPtr.h"
 
namespace agora {
namespace rtc {
 
class IRtmpLocalUser;
 
struct RtmpStreamingAudioConfiguration {
  int sampleRateHz;
 
  int bytesPerSample;
 
  int numberOfChannels;
 
  int bitrate;
 
  RtmpStreamingAudioConfiguration(): sampleRateHz(44100), bytesPerSample(2),
      numberOfChannels(1), bitrate(48000) {}
};
 
struct RtmpStreamingVideoConfiguration {
  int width;
 
  int height;
 
  int framerate;
 
  int bitrate;
 
  int maxBitrate;
 
  int minBitrate;
 
  unsigned int gopInMs;
 
  int encoderHwSwMode;
 
  ORIENTATION_MODE orientationMode;
 
  RtmpStreamingVideoConfiguration(): width(640), height(360), framerate(15),
      bitrate(800), maxBitrate(960), minBitrate(600), gopInMs(2000), encoderHwSwMode(0),
      orientationMode(ORIENTATION_MODE_ADAPTIVE) {}
};
 
 
enum RTMP_CONNECTION_ERROR {
  RTMP_CONNECTION_ERR_OK = 0,
 
  RTMP_CONNECTION_ERR_FAILED = 1,
 
  RTMP_CONNECTION_ERR_INVALID_URL = 2,
 
  RTMP_CONNECTION_ERR_BAD_NAME = 3,
};
 
enum RTMP_CONNECTION_STATE {
  STATE_DISCONNECTED = 1,
 
  STATE_CONNECTING = 2,
 
  STATE_CONNECTED = 3,
 
  STATE_RECONNECTING = 4,
 
  STATE_FAILED = 5,
 
  STATE_RECONNECTED = 6
};
 
struct RtmpConnectionConfiguration {
  RtmpStreamingAudioConfiguration audioConfig;
  RtmpStreamingVideoConfiguration videoConfig;
  bool enableWriteFlvFile;
  RtmpConnectionConfiguration() : enableWriteFlvFile(false) {}
};
 
struct RtmpConnectionInfo {
  RTMP_CONNECTION_STATE state;
 
  RtmpConnectionInfo() : state(STATE_DISCONNECTED) {}
};
 
 
class IRtmpConnectionObserver {
 public:
  virtual void onConnected(const RtmpConnectionInfo& connectionInfo) = 0;
 
  virtual void onDisconnected(const RtmpConnectionInfo& connectionInfo) = 0;
 
  virtual void onReconnecting(const RtmpConnectionInfo& connectionInfo) = 0;
 
  virtual void onReconnected(const RtmpConnectionInfo& connectionInfo) = 0;
 
  virtual void onConnectionFailure(const RtmpConnectionInfo& connectionInfo,
                                   RTMP_CONNECTION_ERROR errCode) = 0;
 
  virtual void onTransferStatistics(uint64_t video_width,  uint64_t video_height, uint64_t video_bitrate, uint64_t audio_bitrate, uint64_t video_frame_rate, uint64_t push_video_frame_cnt, uint64_t pop_video_frame_cnt) = 0;
 
  virtual ~IRtmpConnectionObserver() {}
};
 
class IRtmpConnection : public RefCountInterface {
 public:
    ~IRtmpConnection() {}
 
  virtual int connect(const char* url, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
 
  virtual int disconnect(aosl_ref_t ares = AOSL_REF_INVALID) = 0;
 
  virtual RtmpConnectionInfo getConnectionInfo() = 0;
 
  virtual IRtmpLocalUser* getRtmpLocalUser() = 0;
 
  virtual int registerObserver(IRtmpConnectionObserver* observer, void(*safeDeleter)(IRtmpConnectionObserver*) = NULL, aosl_ref_t ares = AOSL_REF_INVALID) = 0;
 
  virtual int unregisterObserver(IRtmpConnectionObserver* observer) = 0;
};
 
}  // namespace rtc
}  // namespace agora