5

UNIX C ++ソケットとのソケット接続があり、接続後、完全なメッセージが得られるまでバイトごとに読み取るループがありました。受信するメッセージの最初の2バイトと、その長さ（15バイト）を知っています。したがって、関数は次のようになります。

bool mastControl::findPacket(int sockfd, st_messageMastToPc * messageReceived, bool * connected) {

    int n = 0;
    bool messageFound = false;
    char * buffer = (char *) messageReceived;

    unsigned int pos = 0;

    while ( ((n = read(sockfd, &(buffer[pos]), 1)) > 0) and not messageFound) {

         if (n == 1) {
            pos++;

            if ( (pos == 1) && (buffer[0] == 0x02)) { // First byte to receive
                std::cout << "INFO - Rcv1" << std::endl;
            } else if ( (pos == 2) && (buffer[1] == 0x33) ) { // Second byte
                std::cout << "INFO - Rcv2" << std::endl;
            } else if (pos >= uiMessageMastToPcSize) { // Full msg received
                messageFound = true;
                std::cout << "INFO - Complete message received" << std::endl;
            } else if (pos <= 2) { // Wrong values for the first 2 bytes
                std::cout << "WARN - Reseting (byte " << pos << " -> " << int(pos) << ")" << std::endl;
                pos = 0;
            }
        }
    }

    if (n < 0){
        //EROR
        *connected = false;
    }

    return messageFound;
}

今、私はQTcpSocketsで同じことを実装しています。接続が確立されたら、次のように呼び出します。

if(socket->waitForReadyRead(Global::tiempoMaximoDeEsperaParaRecibirDatosMastil)){
                /* Read socket to find a valid packet */
                if (findPacket(socket, &messageReceived)) {
                    qDebug()<<"New packet found!";
//...
}
}

だから私はいくつかの情報が読めるようになるまで待ってから、findPacketを呼び出します。これは今ではほとんど同じで、バイトごとに読み取っています。

bool mastControl::findPacket(QTcpSocket *socket, st_messageMastToPc * messageReceived) {
    int n = 0;
    bool messageFound = false;
    char * buffer = (char *) messageReceived;
    unsigned int pos = 0;

    while ( ((n = socket->read(&(buffer[pos]), 1)) >= 0) and not messageFound) {
        if (n == 1) {
            qDebug()<<"Recibido: "<<buffer[pos]<<", en pos: "<<pos;
            pos++;
            if ( (pos == 1) && (buffer[0] == 0x022)) {
                qDebug()<<"0x02 in first position";
//                std::cout << "INFO - Rcv1" << std::endl;
            } else if ( (pos == 2) && (buffer[1] == 0x33) ) {
                qDebug()<<"0x33 in second";
                std::cout << "INFO - Rcv2" << std::endl;
            } else if (pos >= uiMessageMastToPcSize) {
                messageFound = true;
                std::cout << "INFO - Complete message received" << std::endl;
            } else if (pos <= 2) {
                std::cout << "WARN - Reseting (byte " << pos << " -> " << int(pos) << ")" << std::endl;
                pos = 0;
            }
        }
    }

    if (n < 0){
      qDebug()<< "Disconnected. Reason: " << socket->errorString();
    }

    return messageFound;
}

見た目はほとんど同じですが、機能しません。waitForReadyReadを待ったら、findPacketのループに入り、受信した最初の4バイトを読み取ることができます。その後、データは受信されなくなります。それはfindPacketのループチェックの内部に何度も何度も残りますが、read関数は常に0バイトの読み取りを返します。新しい情報は受信されません。サーバーが数ミリ秒ごとに同じパケットを送信しているため、これは不可能です。したがって、一部のデータが失われたとしても、最終的には何かを読み取る必要があります。

だから、私が間違っているのは何ですか？別の方法で待つ必要がありますか？読み取り関数が0バイトの読み取りを返すのを初めて待つ必要がありますか？この読み取り関数とC++ライブラリの関数の違いは何ですか？

4

1 に答える 1

0

最後に、問題は、読み取り関数によって返された最初のゼロの後に新しいデータを待つのではなく、常に読み取ろうとすることでした。それは魅力のように機能します！

于 2012-05-04T07:57:56.930 に答える