readytowrite.cc

2007年机器人足球世界杯3D仿真组亚军

#include "monitorclient.ih"

bool MonitorClient::ready_to_write()
{
  //std::cerr << "Write!" << std::endl;
  d_gameModel.lock();
  queue<string>& sendQueue = d_gameModel.getSendQueue();
  d_gameModel.unlock();
  
  while (!sendQueue.empty())
  {
    string msg = "W" + sendQueue.front();
    sendQueue.pop();
    unsigned int len = htonl(msg.size());
    string prefix((const char*)&len,sizeof(unsigned int));
    msg = prefix + msg;

    socket.write(msg.c_str(), msg.size());
    //string endOfLine = "\n";
    //socket.write(endOfLine.c_str(), endOfLine.size());
  }
  
  return true;
}