Function rtpstream_audioecho_thread

src/rtpstream.cpp:2626–2887

}

void rtpstream_audioecho_thread(void* param)
{
    int exit_code = 0;
#ifdef USE_TLS
    my_unique_ptr<unsigned char[]> msg {
        reinterpret_cast<unsigned char*>(malloc(media_bufsize)) };
    ssize_t nr;
    ssize_t ns;
    sipp_socklen_t len;
    struct sockaddr_storage remote_rtp_addr;
    sigset_t              mask;
    int rc = 0;
    struct timespec tspec;
    int sock = 0;
    int flags;
    std::vector<unsigned char> rtp_header;
    std::vector<unsigned char> payload_data;
    std::vector<unsigned char> audio_packet_in;
    std::vector<unsigned char> audio_packet_out;
    unsigned short seq_num = 0;
    unsigned short host_flags = 0;
    unsigned short host_seqnum = 0;
    unsigned int host_timestamp = 0;
    unsigned int host_ssrc = 0;
    bool abnormal_termination = false;
    quit_audioecho_thread = false;
    ParamPass p;

    tspec.tv_sec = 0;
    tspec.tv_nsec = 10000000; /* 10ms */

    p.p = param;

    if (param != nullptr)
    {
        sock = p.i;
    }

    if ((flags = fcntl(sock, F_GETFL, 0)) < 0)
    {
        pthread_mutex_lock(&debugremutexaudio);
        if (debugrefileaudio != nullptr)
        {
            fprintf(debugrefileaudio, "rtp_audioecho_thread():  fcntl() GETFL UNBLOCK failed...\n");
        }
        pthread_mutex_unlock(&debugremutexaudio);
        pthread_exit((void*) 1);
    }

    if (fcntl(sock, F_SETFL, flags | O_NONBLOCK) < 0)
    {
        pthread_mutex_lock(&debugremutexaudio);
        if (debugrefileaudio != nullptr)
        {
            fprintf(debugrefileaudio, "rtp_audioecho_thread():  fcntl() SETFL UNBLOCK failed...\n");
        }
        pthread_mutex_unlock(&debugremutexaudio);
        pthread_exit((void*) 2);