关于Message_Block的一些问题

peakzhang

写了如下程序,

2. #include "ace/OS.h"
3. #include "ace/ACE.h"
4. #include "ace/Message_Block.h"
5. #include "ace/Log_Msg.h"
6. #pragma pack(1)
7. struct Head
8. {
9.   int status;
10.   short seq;
11.   char name[20];
12. };
13. #pragma pack()
14. int
15. main(void)
16. {
17.   ACE_Message_Block *mblk = new ACE_Message_Block (sizeof (Head) * 4);
18.   Head First_Head;
19. First_Head.status = 0;
20.   First_Head.seq = 12456;
21.   ACE_OS::strcpy(First_Head.name, "Lien.C");
22.   mblk->copy((char*)&First_Head, sizeof (Head));
23.   ACE_DEBUG((LM_DEBUG, "Message Block Size = %d\n", mblk->size()));
25.   Head Second_Head;
26.   mblk->copy((char*)&First_Head, sizeof (Head));
27.   ACE_OS::memcpy(&Second_Head, mblk->rd_ptr(), sizeof Second_Head);
28.   Head Third_Head;
29.   mblk->rd_ptr(sizeof (Head) * 2);
30.   ACE_OS::strcpy(First_Head.name, "中华人民共和国");
31.   mblk->copy((char*)&First_Head, sizeof (Head));
32.   ACE_OS::memcpy(&Third_Head, mblk->rd_ptr(), sizeof Second_Head);
33.   
34.   
35.   ACE_DEBUG((LM_DEBUG, "Message Block Size = %d\n", mblk->space()));
36.   
37.   ACE_DEBUG((LM_DEBUG, "Second_Head Infomation: name - %s\n", Second_Head.name));
38.   ACE_DEBUG((LM_DEBUG, "Third_Head Infomation: name - %s\n", Third_Head.name));
39.   ACE_Message_Block *mblk_2 = mblk->clone();
40.   mblk_2->duplicate(mblk);
41.   ACE_DEBUG((LM_DEBUG, "Message Block Cloned Size = %d\n", mblk_2->size()));
42.   mblk_2->reset();
43.   mblk->cont(mblk_2);
44.   
45.   mblk->rd_ptr(sizeof (Head) * 3);
46.   Head Fourth_Head;
47.   ACE_OS::memcpy(&Fourth_Head, mblk->rd_ptr(), sizeof (Head));
48.   ACE_DEBUG((LM_DEBUG, "Third_Head Infomation: name - %s\n", Fourth_Head.name));
49.   mblk->release();
50.   mblk = 0;
51.   mblk_2->release();
52.   mblk_2 = 0;
53.   
54.    
55.   return 0;
56. }

复制代码

运行结果:
Message Block Size = 104
Message Block Size = 26
Second_Head Infomation: name - Lien.C
Third_Head Infomation: name - 中华人民共和国
Message Block Cloned Size = 104
Third_Head Infomation: name - œß@(乱码)
Illegal instruction (不知道为什么会输出这个, 可能地址越界)

在做mblk->cont以后发现信息似乎没有被写进来. 请问是在mblk->clone()的时候出了问题, 还是我的读指针rd_ptr不对呢?

peakzhang

似乎解决了呢.

将mblk->cont(mblk_2)改成:

mblk->wr_ptr ( mblk->size() );

mblk->size ( mblk->size() + mblk_2->size() );

mblk_2->reset();

mblk->copy ( mblk_2->rd_ptr(), mblk_2->size() );

在ace的例子Logging_Handler.cpp中对ACE_Message_Block的数据块连接处理似乎简洁, 不知道为什么我的不太好用,只好用这个笨一点的办法了. 希望有人指点直接连接多个ACE_Message_Block块的方法.

注: mblk->clone()是深拷贝, mblk->duplicate()是浅拷贝

     mblk->copy()会将写指针wr_ptr向后移动新拷贝数据块大小

     mblk->reset()会根据align方式移动到原点(默认原点是数据块头)

     还有一个ACE_Message_Queue似乎是用来管理以ACE_Message_Block块为数据结点的链表, 正在研究怎么用.

peakzhang

C++网络编程卷1里面有详细的解释。
你对这个类的认识不清，所以上面的code有很多问题，看着都累人呐。加油。