gentoo / glibc Goto Github PK

tpp.c:84: __pthread_tpp_change_priority: Assertion `new_prio == -1 || (new_prio >= fifo_min_prio && new_prio <= fifo_max_prio)' failed.
Aborted (core dumped)

// threads.c
void *t1(void *args)
{

    // block till the fifo for T1 thread is created
    pthread_mutex_lock(&lock);
    while(threadWakeupIdx >= (T1_IDX + 1))
    {
        pthread_cond_wait(&cond, &lock);
    }
    pthread_mutex_unlock(&lock);
    
    // ...
}

void *t2(void *args)
{

    // block till the fifo for T2 thread is created
    pthread_mutex_lock(&lock);
    while(threadWakeupIdx >= (T2_IDX + 1))
    {
        pthread_cond_wait(&cond, &lock);
    }
    pthread_mutex_unlock(&lock); 
    
    // ...
}

void *t3(void *args)
{

    // block till the fifo for T3 thread is created
    pthread_mutex_lock(&lock);
    while(threadWakeupIdx >= (T3_IDX + 1))
    {
        pthread_cond_wait(&cond, &lock);
    }
    pthread_mutex_unlock(&lock);
    
    // ...
}

void *t4(void *args)
{

    // block till the fifo for T4 thread is created
    pthread_mutex_lock(&lock);
    while(threadWakeupIdx >= (T4_IDX + 1))
    {
        pthread_cond_wait(&cond, &lock);
    }
    pthread_mutex_unlock(&lock);
    
    // ...
}

// main.h
typedef enum
{
    T1_INDEX = 0,
    T2_INDEX,
    T3_INDEX,
    T4_INDEX,
    NUM_ACTIVE_THREADS
} WakeUpThreadIdx;

typedef struct
{
    char fifoPath[100];        
    int fd;
} FifoInfo;

#define FIFO_REF_PATH     "/tmp"

// main.c
int threadWakeupIdx = 0;
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

static const char *threadNameList[NUM_ACTIVE_THREADS] = {T1_FIFO_NAME, T2_FIFO_NAME, T3_FIFO_NAME, T4_FIFO_NAME};

static pthread_t t1Handler;
static pthread_t t2Handler;
static pthread_t t3Handler;
static pthread_t t4Handler;

// init fifo for each thread
void InitFifo(FifoInfo *fifoList)
{
    char fifoPath[100] = {0};
    for (int idx = T1_INDEX; idx < NUM_ACTIVE_THREADS; idx++)
    {
        strcpy(fifoPath, FIFO_REF_PATH);
        strcat(fifoPath, threadNameList[idx]);
        strcpy(fifoList[idx].fifoPath, fifoPath);
        
        // create fifo ...

        // wake up a respective thread once the fifo is init'd
       pthread_mutex_lock(&lock);
       threadWakeupIdx++;
       pthread_cond_broadcast(&cond);
       pthread_mutex_unlock(&lock);

       memset(fifoPath, 0, sizeof(fifoPath));
    }
    
}

int main() 
{
    FifoInfo fifoList[NUM_ACTIVE_THREADS] = {0};
    InitFifo(fifoList);

    pthread_create(&t1Handler, NULL, t1, <argument>);
    pthread_create(&t2Handler, NULL, t2, <argument>);
    pthread_create(&t3Handler, NULL, t3, <argument>);
    pthread_create(&t4Handler, NULL, t4, <argument>);
    
    // .....
    
    pthread_join(t1Handler, 0);
    pthread_join(t2Handler, 0);
    pthread_join(t3Handler, 0);
    pthread_join(t4Handler, 0);
    
    return 0;
}