Function rtpstream_start_task

src/rtpstream.cpp:1426–1521

code checked */

/* code checked */
static int rtpstream_start_task(rtpstream_callinfo_t* callinfo)
{
    int           ready_index;
    int           allocsize;
    threaddata_t  **threadlist;
    threaddata_t  *threaddata;
    pthread_t     threadID;

    /* safety check... */
    if (!callinfo->taskinfo) {
        return 0;
    }

    /* we count on the fact that only one thread can add/remove playback tasks */
    /* thus we don't have mutexes to protect the thread list objects.          */
    for (ready_index = 0; ready_index < num_ready_threads; ready_index++) {
        /* ready threads have a spare task slot or should have one very shortly */
        /* if we find a task with no spare slots, just skip to the next one.    */
        if (ready_threads[ready_index]->num_tasks < ready_threads[ready_index]->max_tasks) {
            /* we found a thread with an open task slot. */
            break;
        }
    }

    if (ready_index == num_ready_threads) {
        /* did not find a thread with spare task slots, thus we create one here */
        if (num_ready_threads >= ready_threads_max) {
            /* need to allocate more memory for thread list */
            ready_threads_max += RTPSTREAM_THREADBLOCKSIZE;
            threadlist = (threaddata_t **) realloc(ready_threads, sizeof(*ready_threads) * ready_threads_max);
            if (!threadlist) {
                /* could not allocate bigger block... worry [about it later] */
                ready_threads_max -= RTPSTREAM_THREADBLOCKSIZE;
                return 0;
            }
            ready_threads = threadlist;
        }
        /* create and initialise data structure for new thread */
        allocsize = sizeof(*threaddata) + sizeof(threaddata->tasklist) * (rtp_tasks_per_thread - 1);
        threaddata = (threaddata_t *) malloc(allocsize);
        if (!threaddata) {
            return 0;
        }
        memset(threaddata, 0, allocsize);
        threaddata->max_tasks = rtp_tasks_per_thread;
        threaddata->busy_list_index = -1;
        pthread_mutex_init(&(threaddata->tasklist_mutex), nullptr);
        /* create the thread itself */
        if (pthread_create(&threadID, nullptr, rtpstream_playback_thread, threaddata)) {
            /* error creating the thread */
            free(threaddata);
            return 0;
        }

        threaddata->id = threadID;

        printAudioHex("CREATED THREAD: ", "", 0, getThreadId(threadID), 0);
        printVideoHex("CREATED THREAD: ", "", 0, getThreadId(threadID), 0);