handle_read_stream的问题

peakzhang

2. void Receiver::handle_read_stream(const ACE_Asynch_Read_Stream::Result &result)
3. {
4.     if (!result.success()||result.bytes_transferred()==0)
5.     {
6. cout<<"delete ..."<<endl;
7. delete this;
8. return ;
9.     }
10.    //ProactorTPSingleton::instance()->putq(&result.message_block());
11. //ACE_OS::printf("%d:putq\n",global++);
12.    else if (mblk_->length() == SIZE_TO_READ)//获得需要接收的字节数
13.    {
14. cout<<"sizetoread == "<<SIZE_TO_READ<<endl;
15. cout<<"data is..."<<mblk_->rd_ptr()<<endl;
16. cout<<"trasfered "<<result.bytes_transferred()<<endl;
17.         /* ACE_InputCDR cdr (mblk_); 参照C＋＋NP2上的例子没得到正确结果
18.        ACE_CDR::Boolean byte_order;
19.        cdr >> ACE_InputCDR::to_boolean (byte_order);
20.        cdr.reset_byte_order (byte_order);
21.        ACE_CDR::ULong length;
22. cdr >> length;
23. cout<<"need read :"<<length<<endl;*/
24. char *len = mblk_->rd_ptr();
25.   u_long length = atoi(len);
26. cout<<"need read :"<<length<<endl;
28.        mblk_->size(length+SIZE_TO_READ);//扩大容量，接收数据
29.        rs_.read(*mblk_,length);//投递读
30.    }
31.     else//问题出在这，执行上面的else if时，这个else语句块也执行！！！不解
32.     {
33. cout<<"recv data..."<<mblk_->rd_ptr()<< endl;
34. ProactorTPSingleton::instance()->putq(mblk_);
36. ACE_NEW(mblk_,ACE_Message_Block(SIZE_TO_READ));
38. //ACE_CDR::mb_align (mblk_);
39. rs_.read(*mblk_,SIZE_TO_READ);
41. cout<<" another read ..."<<endl;
43.     }
44. };

复制代码

peakzhang

客户端发测试数据：

  char buf[]="1111";
     
  peer.send(buf,sizeof buf)

可以发现，else if语句块，和最后的else语句块都执行了，感觉很奇怪，只发了一次数据，读取完后，应该只执行一次，handle_read_stream ,但结果好像时执行了2次，为什么？

peakzhang

你这里没有处理“短读”的问题，就是实际收取的数据长度，小于你要求的数据长度。
}else if(result.bytes_transferred() < result.bytes_to_read())
{

}

peakzhang

基本上就是你说的问题