Linux за българи: Форуми

Някой има ли идея в примерите с localfortune client/server как може да се чете от страна на сървъра, използвам следния код при newConnection() сигнал, но size-а винаги е 0.

GeSHi (C++):
void Server::readIt()
{
    QLocalSocket *socket = server->nextPendingConnection();
    QDataStream in(socket);
    in.setVersion(QDataStream::Qt_4_0);
    quint16 blockSize = 0;
 
    if (blockSize == 0) {
        if (socket->bytesAvailable() < (int)sizeof(quint16))
            return;
        in >> blockSize;
    }
 
    if (in.atEnd())
        return;
 
    QString nextFortune;
    in >> nextFortune;
 
    qDebug() << nextFortune;
}
 

Изпращането става с:

GeSHi (C++):
void Client::sendIt()
{   
    socket->connectToServer(hostLineEdit->text());
    QByteArray block;               
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_0);
    out.setDevice(socket);
    out << (quint16)0;
    out << tr("blaaaaa");
    out.device()->seek(0);
    out << (quint16)(block.size() - sizeof(quint16));
 
    socket->write(block);
    socket->flush();
    socket->disconnectFromServer();
}
 

@lkr: Пропуснал си една итерация. Правиш опит да четеш при newConnection, което е грешка. Всъщност при този сигнал само трябва да инициализираш socket-а. Трябва да четеш, когато съответния QLocalSocket получен при newConnection изпрати readReady сигнал. В момента четеш от socket-а още преди да е получил данните и затова се получава така.

Отделен е въпросът, че в примера, който се опитваш да модифицираш blockSize се използва за проверка на това дали са получени всичките данни. Нещо, което при теб не се проверява. Както замисли се какъв е смисълът на ред 8 в сървърното приложение при наличие на ред 6. Най-вероятно компилатора ще го оптимизира, но все пак.

Дори когато взема сокета с nextPendingConnection() и задам connect(socket, SIGNAL(readReady()), this, SLOT(read_that())) ефектът е същия.

@lkr: Дай да видим това read_that какво прави, тъй като поне при това закачане към слот-а не знам по какъв начин той разбира от кой localSocket да чете.

Оправих се, явно предния път при закачане към слота е имало друг проблем.

GeSHi (C++):
void Server::read_that()
{
    QDataStream in(socket);
    in.setVersion(QDataStream::Qt_4_0);
    quint16 blockSize = 0;
 
    if (blockSize == 0) {
        if (socket->bytesAvailable() < (int)sizeof(quint16))
            return;
        in >> blockSize;
    }
 
    if (in.atEnd())
        return;
 
    QString nextFortune;
    in >> nextFortune;
 
    qDebug() << nextFortune;
}
 
void Server::readIt()
{
    socket = server->nextPendingConnection();
    connect(socket, SIGNAL(readyRead()), this, SLOT(read_that()));
}
 

@lkr: Тази схема няма да работи, когато към сървъра се закачат няколко клиента, които предават едновременно информация към него, тъй като всяко от връзките ще има отделен localSocket. За да се справиш с този проблем на read_that като параметър трябва да предаваш socket-а. В  тази ситуация закачането на този сигнал към readReady е малко по-сложно, но на помощ идва QSignalMapper.

Но на мен не ми трябва да работи с няколко клиента :) Благодаря все пак.