C,TCP-Server

Вот это мне не совсем понятно:

Вопрос, как заставить тсп сервер сразу отправить это сообщение девайсу? Как вариант входящие сообщения от второго сервиса складывать в очередь и при новом сообщении от девайса проверять в этой очереди наличие сообщения. но такой способ будет работать с задержкой, т.к новое сообщение от девайса может придти через 5,10 минут.

Почему, если tcp-сервер на Си, если он получил сообщение, не может его сразу передать устройству, а должен ждать, пока придёт сообщение от устройства? Он, что, получает сообщение для устройсва не через libevent?

Сервер, который слушает, пусть сам и организует очередь. При получении сообщения смотрит, если устройсво подключено, отправляет сообщение сразу, если не подключено, складывает в очередь. При подключении устройсва проходит по очереди и смотрит, есть ли для него сообщения.

Ну вот и я так думал сначала, что-то подобное:

<цикл перебора очереди сообщений> 
    <цикл перебора активных девайсов>
        <если идентификатор девайса совпадает с идентификатором получателя сообщения>
            <отправка сообщения>

И вынести этот цикл тогда в отдельный процесс, т.к сообщение может придти в любой момент. Но на сколько такой вариант будет накладным? Каждый раз так перебирать 2 очереди. И могут ли возникнуть проблемы, если вдруг одновременно придет сообщение от этого девайса и другой потом в этом цикле начнет отправлять сообщение этому же девайсу?

На go, который был создан ровно для таких задач, всё, что вы написали делается в сотню строк за час. Хватит уже сишечку мучать, 2015 год на дворе.

это и так делается на Си за час - просто вопрошающий про основы спрашивает

Ну и еще вопрос по критическим секциям. В итоге у нас получается как минимум 2 очереди: 1-ая с активными девайсами 2-ая со списком сообщений для этих девайсов.

В основном таске где крутится libevent мы в первую очередь пихаем подключившегося клиента (в функции добавления клиента в очереди вешаем семафор, добавили семафор отдаем). Во втором таске, где идет выборка сообщений из базы при обнаружении новых сообщений добавляем их в очередь сообщений (также через своб функцию, которая свою очередь забирает на время добавления и потом отдает свой семафор). И в третьем таске где постоянно проверяется наличие сообщений для клиентов:

<цикл перебора активных девайсов> 
    <цикл перебора очереди сообщений>
        <если идентификатор девайса совпадает с идентификатором получателя сообщения>
            <отправка сообщения>

критические секции???? нда..., вы не понимаете как работает libevent ..

Может не совсем правильно выразился. Таск с libevent добавляет данные о подключившемся клиенте в очередь, а эта очередь уже может использоваться в другом таске, например при проверки наличия сообщения для клиента. И чтобы не было такого: что клиент отключился и его данные были убраны из очереди, а в этот момент другой таск запустил цикл проверки сообщения. До удаления из очереди забираем семафор и соотвествено цикл проверки сообщений будет ждать пока этот семафор освободится.

для либевента не нужны таски, это асинхронная модель поведения, вы ее пытаетесь сломать, перевести на таски, и прибить гвоздями там кучу каких то семафоров циклов итд

Хорошо, вот есть такая система: либэвент принимает сообщения и разбирает их, дальше складывает в очередь эта очередь выгружается в другой сервис, который говорит об этом клиенту, клиент видит, что устройство в сети - отправляет ему сообщение - это сообщение передается серверу на либэвенте как тогда без циклов и очередей сразу эту передать нужному устройству?

Тебе может что-то вроде ZeroMQ нужно?

Устройства кучу бинарных пакетов шлют, на си уже есть готовая либа, которая разбирает их.