我的应用程序由一个有几个子控制器组成。控制器使用管道与第一个子节点通信,子节点之间使用管道将问题传递给下一个兄弟节点。当子进程可以处理这个问题时,它会向控制器管道发送一个帧以做出无罪释放。
我的问题是,因为每个子线程都可以在控制器管道中写入内容,控制器有可能在同一流中读取多个子线程的帧。
所以,我想分割这个流来单独处理子帧。
控制器只接收到一种类型的帧:
Acquittal Frame
0 1 2 3
0 1 2 3 4 5 6 7 8 0 1 2 3 4 5 6 7 8 0 1 2 3 4 5 6 7 8
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| CMD | NODE ID | ERROR FLAG |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| DATA LENGTH (optional) | |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
| DATA WITH UNDETERMINED SIZE (char *) (optional) |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
| END FRAME |
+-+-+-+-+-+-+-+-+-+
这个框架是由多个信息组成的:
- CMD:向控制器表示质询孩子响应的无罪表扬
- 节点ID:子节点的唯一标识符
- 错误标志:在结果和命令的函数中可以有不同的值
命令:
- A_SET (0 xa2):
- 此命令只允许2个错误标志SUCCESS(0x20)和INTERNAL_ERROR(0x50)
- 使用此命令,帧大小为4,没有数据长度和数据
- A_DUMP (0 xd2):
- 此命令只允许2个错误标志SUCCESS(0x20)和INTERNAL_ERROR(0x50)
- 使用此命令,帧大小为4,没有数据长度和数据
- A_LOOKUP (0 xb2):
- 如果此命令有错误标志INTERNAL_ERROR(0x50)或NOT_FOUND(0x44),则帧大小将为4
- 如果这个命令有错误标志SUCCESS(0x20),帧大小将是4 + DATA长度,用两个字节编码
在我的例子中,我想要这样写:
{0xd2,0x04,0x20,0x04,0xd2,0x05,0x20,0x04,0xd2,0x06,0x20,0x04,0xd2,0x07,0x20,0x04,0xb2,0x08,0x20,0x01,0x08,0x62,0x6f,0x6e,0x6a,0x6f,0x75,0x72,0x04}
我想提取一个像这样的数组
[0] : {0xd2,0x04,0x20,0x04}
[1] : {0xd2,0x05,0x20,0x04}
[2] : {0xd2,0x06,0x20,0x04}
[3] : {0xd2,0x07,0x20,0x04}
[4] : {0xb2,0x08,0x20,0x01,0x08,0x62,0x6f,0x6e,0x6a,0x6f,0x75,0x72,0x04}
我尝试过很多事情:用手动阵列跑酷,用strtok()
函数。因此,我向您展示了最后一次使用鹳函数的尝试:
enum frameComponents {
END_FRAME=(unsigned char)0x04,
...
}
...
unsigned int getNbFrames(unsigned char * framesStream){
unsigned int lenFrames = strlen((char * )framesStream);
unsigned int i,k;
for(i=0,k=0;i<lenFrames;i++){
if(framesStream[i]==END_FRAME){
k++;
}
}
return k;
}
unsigned char ** deserialisation(unsigned char * frameStream){
//this function return the number of identify frame in the stream
unsigned int nbFrame = getNbFrames(frameStream);
unsigned int lenFrames = strlen((char * )frameStream);
unsigned char **framesArray = malloc(nbFrame * sizeof(unsigned char *));
unsigned char *tempFrameStream = malloc(sizeof(unsigned char)*lenFrames+1);
unsigned char * extractedFrame = (unsigned char *) strtok(tempFrameStream, (char *)END_FRAME);
strcpy((char *)tempFrameStream,(char *) frameStream);
int i = 0;
while(extractedFrame != NULL ) {
extractedFrame = (unsigned char *) strtok(NULL, (char *)END_FRAME);
framesArray[i]= malloc(strlen((char *)extractedFrame)+1);
strcpy((char *)framesArray[i],(char *)extractedFrame);
i++;
}
free(tempFrameStream);
free(extractedFrame);
return framesArray;
}
但是我这里有很多问题
首先,strtok()
似乎不能正常工作,因为当我尝试使用一个字符串时,我在数组中有null返回。我不知道这是不是来自于数组的unsigned int类型?
其次,当我试图访问函数外的帧数组时,我有分段错误。即使有malloc()在我的数组
由于您的输入数据不是字符串,而是原始字节流(又称无符号字符流),因此您不能将字符串函数用于解码器。
你需要实现一个考虑到协议的解析器,也就是说,你需要查看每一帧,看看它是什么命令。一旦您知道了该命令,就可以相应地解析数据。
我不会为您实现一个完整的解析器,但下面是一些显示主体的代码。代码不会将帧放入分配的内存中(我将把它留给你),代码只是打印帧(在三分之二的情况下,最后一种情况我将留给你实现)。
#define A_SET (0xA2)
#define A_DUMP (0xD2)
#define A_LOOKUP (0xB2)
void deserialisation(unsigned char * frameStream, size_t n)
{
size_t index = 0;
while (index < n)
{
switch(frameStream[index])
{
case A_SET:
if (index + 4 > n)
{
puts("Too little data! can't continue...");
index = n;
}
else
{
// Good frame - just print it for now
printf("A_SET cmd: ");
for (size_t i = 0; i < 4; ++i) printf("0x%02X ", frameStream[index + i]);
puts("");
index += 4;
}
break;
case A_DUMP:
if (index + 4 > n)
{
puts("Too little data! can't continue...");
index = n;
}
else
{
// Good frame - just print it for now
printf("A_DUMP cmd: ");
for (size_t i = 0; i < 4; ++i) printf("0x%02X ", frameStream[index + i]);
puts("");
index += 4;
}
break;
case A_LOOKUP:
printf("A_LOOKUP cmd: ");
// Add code here...
break;
default:
puts("Unknow frame! Can't continue...");
index = n;
break;
}
}
}
int main(void)
{
unsigned char pipeData[] = {0xA2, 0x01, 0x20, 0x04, 0xD2, 0x14, 0x50, 0x04};
deserialisation(pipeData, sizeof pipeData / sizeof pipeData[0]);
return 0;
}
输出:
A_SET cmd: 0xA2 0x01 0x20 0x04
A_DUMP cmd: 0xD2 0x14 0x50 0x04