Boost.Asio-Socket wird blockiert

Question

Die for-Schleife in main.cpp, die eine Funktion aufruft, die boost :: mutex verwendet und die mit read_until aus einem Socket liest, wird nur einmal ausgeführt, danach ist es wie blockiert. Ich habe versucht, eine Fortsetzung vor den schließenden Klammern zu setzen und dann stürzt es ab. Es hängt wahrscheinlich mit Threading zusammen. input stream error aufgrund der Serialisierung Input/Output: ein Fehler passiert

// MAIN.CPP 

int main(int argc, char* argv[]) 
{ 
    std::cout << "Enter port number: "; 
    std::string port; 
    std::getline(std::cin, port); 
    int tempPort = std::stoi(port); 
    Network * network = new Network(tempPort); 

    int it = 0; 
    boost::thread * t1; 
    t1 = new boost::thread([&network, &it] 
    { 
     while (true) 
     { 
      boost::asio::ip::tcp::socket * sock = new boost::asio::ip::tcp::socket(network->io_service); 
      network->accept(*sock); 

      if (network->socketList.size() > 0) 
      { 
       for (boost::asio::ip::tcp::socket * s : network->socketList) 
       { 
        if (s->remote_endpoint().address().to_string() == sock->remote_endpoint().address().to_string()) 
        { 
         continue; 
        } 
        else { 
         network->socketList.push_back(sock); 
         std::cout << s->remote_endpoint().address().to_string() << " connected." << std::endl; 
        } 
       } 
      } 
      else { 
       network->socketList.push_back(sock); 
       std::cout << sock->remote_endpoint().address().to_string() << " connected." << std::endl; 
      } 
     } 
    }); 

    while (true) 
    { 
     for (boost::asio::ip::tcp::socket * sock : network->socketList) 
     { 
      std::cout << "on range-based for loop" << std::endl; 
      network->readChatMessage(*(sock)); 
     } 
    } 
    t1->join(); 

    return 0; 
} 

// NETWORK.CPP 
int Network::sendChatMessage(boost::asio::ip::tcp::socket & socket, ChatMessage & message) 
{ 
    try 
    { 
     boost::system::error_code err; 

     boost::asio::streambuf buf; 
     { 
      std::ostream out(&buf); 
      boost::archive::text_oarchive oa(out); 
      oa & message; 

      std::cout << std::string(message.text.begin(), message.text.end()) << std::endl; 
     } 

     m.lock(); 
     write(socket, buf, err); 

     if (err) 
     { 
      std::cout << err.message() << std::endl; 
     } 

     m.unlock(); 

     std::cout << "Mensagem enviada com sucesso!" << std::endl; 
    } 
    catch (std::exception& e) 
    { 
     std::cout << e.what() << std::endl; 
    } 

    return 0; 
} 

int Network::readChatMessage(boost::asio::ip::tcp::socket & socket) 
{ 
    std::cout << "in readChatMessage()" << std::endl; 

    boost::system::error_code err; 

    boost::asio::streambuf buf; 

    m.lock(); 
    boost::asio::read_until(socket, buf, '\0', err); 

    if (err) 
    { 
     std::cout << err.message() << std::endl; 
    } 

    m.unlock(); 

    std::istream in(&buf); 
    ChatMessage message; 

    boost::archive::text_iarchive ia(in); 
    ia & message; 

    std::cout << std::string(message.text.begin(), message.text.end()) << std::endl; 
    this->sendChatMessage(socket, message); 

    return 0; 
} 

Answer 1

ich in der Lage war, das Problem nach dem Debuggen zu beheben und Bearbeiten dem Code ein wenig, dann war ich in der Lage, dort zu sehen war. Ich habe den Fehler richtig behandelt, den Mutex entsperrt, als der Fehler auftrat, und den Mutex nicht ungeschehen gemacht.

Snippet:

int Network::readChatMessage(boost::asio::ip::tcp::socket & socket) 
{ 
    std::cout << "in readChatMessage()" << std::endl; 

    boost::system::error_code err; 

    boost::asio::streambuf buf; 

    m.lock(); 
    boost::asio::read_until(socket, buf, '\0', err); 

    if (err) 
    { 
     m.unlock(); 
     std::cout << err.message() << std::endl; 
     return 0; 
    } 
    else { 

     m.unlock(); 

     std::istream in(&buf); 
     ChatMessage message; 

     boost::archive::text_iarchive ia(in); 
     ia & message; 

     std::cout << std::string(message.text.begin(), message.text.end()) << std::endl; 
     this->sendChatMessage(socket, message); 
     return 0; 
    } 
    m.unlock(); 

    return 0; 
}