xuxiuxi

2017-05-11 109ffe9a777658936a38d0c146579a67c60a0d17

 FaceServer/ev_server.cpp

@@ -132,6 +132,7 @@
      }

      

      evpHeader = (EVPHeader*)headerBuff;

      evpHeader->ntoh();

      

      // check header

      if (evpHeader->proto <= EVPProto::EVPP__FIRST || evpHeader->proto >= EVPProto::EVPP__LAST || 

@@ -166,9 +167,10 @@
   do

   {

      readSize = bufferevent_read(bufev, client->recvbuff + client->recvbuff_end, client->recvbuff_max - client->recvbuff_end);

      client->read_times++;

      if (readSize == 0)

         break;

      else

         client->read_times++;



      client->recvbuff_end += readSize;

   } while (readSize > 0);

@@ -204,10 +206,10 @@
   }

   else

   {

      LOG_WARN << "recvbuff incomplete, evpHeader.size=" << evpHeader->size 
         << ", recvbuff_end=" << client->recvbuff_end 
         << ", read_times=" << client->read_times 
         << LOG_ENDL;

      //LOG_WARN << "recvbuff incomplete, evpHeader.size=" << evpHeader->size 
      //   << ", recvbuff_end=" << client->recvbuff_end 
      //   << ", read_times=" << client->read_times 
      //   << LOG_ENDL;

   }

   

   // check read times

@@ -352,7 +354,9 @@
   EVPHeader* evpHeader = new (client.sendBuff) EVPHeader;

   evpHeader->cmd = EVPCommand::EVPC_STATUS;

   evpHeader->size = client.sendBuffSize;

   evpHeader->hton();

   

   EVP_Status* evpStatus = new (client.sendBuff + sizeof(EVPHeader)) EVP_Status;

   evpStatus->status = status;

   evpHeader->hton();

}