message_connect()

Создать соединение с каналом

Прототип:

#include <sys/iofunc.h>
#include <sys/dispatch.h>
                                       
int message_connect( dispatch_t *dpp,
                     int flags );

Аргументы:

dpp

Дескриптор структуры диспетчера, возвращаемый функцией dispatch_create().

flags

На данный момент в <sys/dispatch.h> определены следующие флаги:

MSG_FLAG_SIDE_CHANNEL: Запросить возврат ID соединения из другого пространства. Этот ID будет больше, чем любой допустимый файловый дескриптор. После создания нет разницы в использовании примитивов сообщений для данного ID.

Функция message_connect() создаёт соединение по каналу, используемому в дескрипторе структуры диспетчера dpp. Функция производит системный вызов ConnectAttach(). Для открепления ID соединения можно вызвать ConnectDetach().

Функция message_connect() работает только в том случае, если тип блокирования диспетчера - получение, т.е. прикрепления были выполнены для событий типа resmgr, message, или select. Если прикрепления ещё не были выполнены, message_connect() завершится ошибкой, так как диспетчер не может определить, будут ли использоваться блокировки получения или блокировки sigwait.

Возвращаемое значение:

Идентификатор соединения. Если возникла ошибка функция возвращает -1, код ошибки записывается в errno.

Коды ошибок:

EAGAIN: Все объекты соединений в ядре используются.
EINVAL: Диспетчер dpp не имеет каналов.

Примеры:

#include <sys/dispatch.h>
#include <time.h>
#include <stdio.h>
#include <stdlib.h>
        
int main( int argc, char **argv )
{
    dispatch_t  *dpp;
    int         flags, coid, id;
        
    if ( (dpp = dispatch_create()) == NULL )
    {
        fprintf( stderr, "%s: Unable to allocate dispatch context.\n", argv[0] );
        return (EXIT_FAILURE);
    }
                                       
    id = resmgr_attach( ... );
    ...
                                       
    if ( (coid = message_connect ( dpp, flags )) == -1 )
    {
        fprintf( stderr, "Failed to create connection to channel used by dispatch.\n");
        return (1);
    }
    /* else connection to channel used by dispatch is created */
    ...
}