Почему sem_timedwait() не просыпается?

Question

Я работаю на встроенной системе с eCos: у меня есть 2 потока в одном процессе и 1 семафор.

1. Поток A инициализирует семафор до 0, поэтому первая попытка его захвата блокируется.
2. Поток A отправляет команду в Поток B, обеспечивая обратный вызов.
3. Поток А ждет на семафор с sem_timedwait
4. Поток B обрабатывает команду и увеличивает семафор
5. Поток А должен быть разбужен, но все еще заблокирован

Вот код:

Нить А

static sem_t semaphore;

void callback()
{
    // Do some stuff
    int ret = sem_post(&semaphore);
    // print confirmation message
}

void foo()
{
    int ret = sem_init(&semaphore, 0, 0);
    if(ret != 0)
    {
        // print errno
    }

    struct timespec ts; 
    clock_gettime(CLOCK_REALTIME,&ts); // Get current date
    ts.tv_sec += 2; // Add 2s for the deadline

    send_command_to_thread_B(&callback);

    ret = sem_timedwait(&semaphore, &ts);
    if(ret != 0)
    {
        // print errno
    }

    // print waking up message
}

То, что есть в теме B, не имеет значения.

Для отладки я попробовал следующее:

1. С помощью sem_wait скорее, чем sem_timedwait работает: поток А заблокирован, затем разблокирован после обратного вызова. Но я не хочу использовать его, потому что в случае сбоя в процессе обратного вызова, который не позволяет увеличить семафор, поток A будет ждать вечно.
2. Если я не добавлю 2 к timespec структура, sem_timedwait немедленно возвращается и errno установлен в ETIMEDOUT (выглядит вполне законно). Обратный вызов вызывается, но это слишком поздно для потока А.
3. Я поместил трассировки в вызов обратного вызова, чтобы убедиться, что семафор действительно увеличен с 0 до 1: весь процесс завершен, обратный вызов завершен, но поток A все еще заблокирован.

Ребята, вы понимаете? Я что-то пропустил?

Answer 1

Итак, на самом деле все в порядке с этим кодом, проблема была в другом месте: у меня была проблема с повторным входом, которая вызвала тупик.
Мораль: тщательно защищайте свои ресурсы и адреса в многопоточном контексте