Message Block问题

peakzhang

在使用Proactor框架时一般怎么样将数据放到Message_Block再进行发送？我使用下边的方法为什么会出现异常，选择“终止”后，提示“内存不能为读”。

2. handle_read_stream()
3. {
4. ACE_Message_Block &mblk = result.message_block();
5. if(!result.success || result.bytes_transferred()==0)
6. {
7. mblk.release();
8. delete this;
9. return;
10. }
11. else
12. {
13.    USER_INFO *user_info=new USER_INFO;   //USER_INFO是我定义的一个结构体,我发送的消息一般都是这个结构体
14.    ACE_OS::memcpy(user_info,mblk.rd_ptr(),sizeof(USER_INFO));
15.    switch(user_info->l1)
16. {
17. case MG_TRANSFER:
18. {
19.     user_info->l2="测试";
20.     ACE_OS::memcpy(mblk.wr_ptr(),user_info,sizeof(USER_INFO));
21.     mblk.wr_ptr(sizeof(USER_INFO));
22. ws_.write(mblk,mblk.length());     //ws_定义为 ACE_Asynch_Write_Stream  ws_;
23. mblk.release();
24. }
25. break;
26. }
27. }

复制代码

peakzhang

可以继续复用前一个消息块，不一定非得重新生成一个，再说消息块本身就有引用计数

peakzhang

可以直接把此消息块放入一个单独的发送线程中，这个问题本网站上有类似情况，你可以搜一下