tencent cloud

std::unique_ptr<tmio::TmioProxy> proxy_ = tmio::TmioProxy::createUnique();

void setListener(TmioProxyListener *listener);

std::error_code start(const std::string &local_url, const std::string &remote_url, void * config=nullptr)

 proxy_->start(local_url, remote_url, NULL);

tmio::TmioFeatureConfig option;
option_.protocol = tmio::Protocol::SRT;
option_.trans_mode = static_cast<int>(tmio::SrtTransMode::SRT_TRANS_BACKUP);
/*-----------------------------------------------------------*/
{
//根据当前需要建立的链路数可添加多个链路
option_.addAvailableNet(net_name, local_addr, remote_url, 0, weight, -1);
}
/*-----------------------------------------------------------*/

proxy_->start(local_url, remote_url, &option_);


/*
void stop();
*/
proxy_.stop();

tmio_ = tmio::TmioFactory::createUnique(tmio::Protocol::SRT);
tmio::SrtPreset::mpegTsLossless(tmio_.get());
tmio_->setIntOption(tmio::srt_options::CONNECT_TIMEOUT, 4000);
tmio_->setBoolOption(tmio::base_options::THREAD_SAFE_CHECK, true);

//根据不同参数属性选择合适的配置
bool setBoolOption(const std::string &optname, bool value);
bool setIntOption(const std::string &optname, int64_t value);
bool setDoubleOption(const std::string &optname, double value);
bool setStrOption(const std::string &optname, const std::string &value);
...

/**
 * open the stream specified by url
 *
 * @param config protocol dependent
 */
virtual std::error_code open(const std::string &url,
                              void *config = nullptr) = 0;

//默认单链路
auto err = tmio->open(TMIO_SRT_URL);
if (err) {
LOGE("open failed, %d, %s", err.value(), err.message().c_str());
}

tmio::TmioFeatureConfig option_;
option_.protocol = tmio::Protocol::SRT;
option_.trans_mode = static_cast<int>(tmio::SrtTransMode::SRT_TRANS_BACKUP);
option_.addAvailableNet(net_name, local_addr, remote_url, 0, weight, -1);

//bonding 多链路
auto err = tmio_->open(TMIO_SRT_URL, &option_);
if (err) {
 LOGE("open failed, %d, %s", err.value(), err.message().c_str());
}

int ret = tmio_->send(buf.data(), datalen, err);
if (ret < 0) {
        LOGE("send failed, %d, %s", err.value(), err.message().c_str());
        break;
}

/**
* receive data
*
* @param err return error details
* @return number of bytes which were received, or < 0 to indicate error
*/
virtual int recv(uint8_t *buf, int len, std::error_code &err) = 0;

using RecvCallback = std::function<bool(const uint8_t *buf, int len, const std::error_code &err)>;
/**
* receive data in event loop
*
* recvLoop() block current thread, receive data in a loop and pass the data to recvCallback
* @param recvCallback return true to continue the receive loop, false for break
*/
virtual void recvLoop(const RecvCallback &recvCallback) = 0;

    while (true) {
    ret = tmio_->recv(buf.data(), buf.size(), err);
    if (ret < 0) {
        LOGE("recv error: %d, %s", err.value(), err.message().c_str());
        break;
    }
    ...
}

FILE *file = fopen(output_path, "w");
tmio_->recvLoop([file](const uint8_t *buf, int len,
                                                const std::error_code &err) {
    if (len < 0) {
            fwrite(buf, 1, len, file);
    } else if (len < 0) {
            LOGE("recv error: %d, %s", err.value(), err.message().c_str());
    }
    return true;
});

tmio_->close();

tmio::PerfStats stats_;
tmio_->control(tmio::ControlCmd::GET_STATS, &stats_);