Принцип формирования сигналов на примере QTcpSocket

[kuzulis]

Доброго всем всего!

Вот тут : http://forum.vingrad.ru/forum/topic-268430/kw-qiodevice.html

я пытался узнать, как же формируется сигнал readyRead() при приходе данных в сокет, но мне так никто ничего толком и не рассказал.

Имеется ввиду то, что например когда мы создаем сокет и коннектимся к его сигналу readyRead() - у меня возникает вопрос: а каким образом этот сигнал выдается???

Ведь (если рассматривать к примеру Вин сокеты) для отлова событий от сокета необходимо использовать API функцию select (или WSASelect) . Если посмортеть исходники, то видно, что эту функцию запускает метод класса QAbstractSocket::waitForReadyRead(msecs) - НО ФИШКА В ТОМ, ЧТО мы то не вызываем этот метод! И при этом успешно отлавливаем сигнал readyRead()

Поэтому вопрос: кто/что/какая функция выдает нам сигнал  readyRead() Я запутался в исходниках.. уже не могу понять ничего

[Авварон]

ищи emit readyRead() по идее она должна стоять после селекта

[Alex Custov]

Поэтому вопрос: кто/что/какая функция выдает нам сигнал  readyRead()

По событию на сокете вызывается метод

bool QAbstractSocketPrivate::canReadNotification()
{

    ...

    if (!emittedReadyRead && hasData) {
        emittedReadyRead = true;
        emit q->readyRead();
        emittedReadyRead = false;
    }

    ...

}

[BRE]

select отрабытывет в цикле обработки событий.

[kuzulis]

По событию на сокете вызывается метод

Цитировать
bool QAbstractSocketPrivate::canReadNotification()
.....

да, это все так.... метод canReadNotification() вызывается например тут:

Код:

bool QAbstractSocket::waitForReadyRead(int msecs)
{
...
         if (!d->socketEngine->waitForReadOrWrite(&readyToRead, &readyToWrite, true, !d->writeBuffer.isEmpty(),
                                               qt_timeout_value(msecs, stopWatch.elapsed()))) {
            d->socketError = d->socketEngine->error();
            setErrorString(d->socketEngine->errorString());
#if defined (QABSTRACTSOCKET_DEBUG)
            qDebug("QAbstractSocket::waitForReadyRead(%i) failed (%i, %s)",
                   msecs, d->socketError, errorString().toLatin1().constData());
#endif
            emit error(d->socketError);
            if (d->socketError != SocketTimeoutError)
                close();
            return false;
        }

        if (readyToRead) {
            if (d->canReadNotification())
                return true;
        }

        if (readyToWrite)
            d->canWriteNotification();

        if (state() != ConnectedState)
            return false;
    }
    return false;
}

НО! кто вызывает waitForReadyRead(msecs) ??

select отрабытывет в цикле обработки событий.

где это реализовано в коде? а?  

[BRE]

где это реализовано в коде? а? 

/src/corelib/kernel/qeventdispatcher_unix.cpp
функция doSelect.

[kuzulis]

блина, сложно то как!

А если я хочу сделать к примеру аналогично сокету - но для последовательного порта, то что я должен сделать, чтобы при создании класса последовательного порта - в цикле сообщений стало вызываться select (для UNIX) или waitForSingleObject (для Windows) ?

Например в классе последовательного порта реализован метод waitForReadyRead(msecs) c использованием этих ядерных функций : select и waitForSingleObject + к тому класс последовательного порта является наследником от QIODevice - НО я хочу сделать так, чтобы сигнал readyRead() емиттился сам при создании класса! А не только при вызове waitForReadyRead()!

[BRE]

блина, сложно то как!

А если я хочу сделать к примеру аналогично сокету - но для последовательного порта, то что я должен сделать, чтобы при создании класса последовательного порта - в цикле сообщений стало вызываться select (для UNIX) или waitForSingleObject (для Windows) ?

Например в классе последовательного порта реализован метод waitForReadyRead(msecs) c использованием этих ядерных функций : select и waitForSingleObject + к тому класс последовательного порта является наследником от QIODevice - НО я хочу сделать так, чтобы сигнал readyRead() емиттился сам при создании класса! А не только при вызове waitForReadyRead()!

Под linux ничего делать не надо, подсовываешь в QSocketNotifier дескриптор открытого последовательного порта и все будет работать.
С вендой помочь не могу...
Хотя можно попробовать периодически вызывать waitForSingleObject (по таймеру например) и при необходимости генерировать сигнал.
Реализация QSocketNotifier не так уж и сложна. При создании объекта, он регистрируется в глобальном списке. Далее в цикле обработки событий проверяются все зарегистрированные дескрипторы и для тех которые сработали, вызывается сигнал.

[kuzulis]

Под linux ничего делать не надо, подсовываешь в QSocketNotifier дескриптор открытого последовательного порта и все будет работать.

а поподробнее пжлста! Куда и что подсовывать конкретно? Лучше примерчик!

С вендой помочь не могу...
Хотя можно попробовать периодически вызывать waitForSingleObject (по таймеру например) и при необходимости генерировать сигнал.

ну там не только waitForSingleObject  нужен.. там целая цепочка функций

Реализация QSocketNotifier не так уж и сложна. При создании объекта, он регистрируется в глобальном списке. Далее в цикле обработки событий проверяются все зарегистрированные дескрипторы и для тех которые сработали, вызывается сигнал.

для меня это непонятно

[BRE]

а поподробнее пжлста! Куда и что подсовывать конкретно? Лучше примерчик!

Код

C++ (Qt)
int fd = ::open( "/dev/ttyS0", O_RDWR | O_NONBLOCK | O_NOCTTY );
QSocketNotifier *readNotifier = new QSocketNotifier( fd, QSocketNotifier::Read );
connect( readNotifier, SIGNAL( activated( int ) ), ... );
 

[kuzulis]

....
connect( readNotifier, SIGNAL( activated( int ) ), ... );
....

т.е. далее мне нужно в таком случае написать что-то подобное:

Код:

int fd = ::open( "/dev/ttyS0", O_RDWR | O_NONBLOCK | O_NOCTTY );
QSocketNotifier *readNotifier = new QSocketNotifier( fd, QSocketNotifier::Read );
connect( readNotifier, SIGNAL( activated( int ) , this, SIGNAL(readyRead() );

, где this - это мой класс "последовательный порт" , ккоторый имеет сигнал readyRead() ?

а удалять объект *readNotifier нужно ?

[BRE]

т.е. далее мне нужно в таком случае написать что-то подобное:

Код:

int fd = ::open( "/dev/ttyS0", O_RDWR | O_NONBLOCK | O_NOCTTY );
QSocketNotifier *readNotifier = new QSocketNotifier( fd, QSocketNotifier::Read );
connect( readNotifier, SIGNAL( activated( int ) , this, SIGNAL(readyRead() );

, где this - это мой класс "последовательный порт" , ккоторый имеет сигнал readyRead() ?

Да. И добавить this в конструктор:

Код

C++ (Qt)
QSocketNotifier *readNotifier = new QSocketNotifier( fd, QSocketNotifier::Read, this );

[kuzulis]

ааааа!!! спасибо огромное! щас буду пробовать!  Все кажется теперь таким простым...

А вот все-таки теперь с виндус проблема остается...  (

[BRE]

А вот все-таки теперь с виндус проблема остается...  (

Посмотрел я реализацию у тебя в QSerialDevice.
В примитиве, если по таймеру вызывать waitForReadyRead( 0, true ), то получим похожий функционал....
Дальше подумай как это лучше организовать. 

[Alex Custov]

НО! кто вызывает waitForReadyRead(msecs) ??

При чём тут вообще waitForReadyRead() ? Ещё раз - по событию на сокете вызывается метод canReadNotification(), который и эмитит сигнал.