我们使用nanopb库作为我们的 Protocol Buffers 库。我们定义了以下消息:
simple.proto
:
syntax = "proto2";
message repField {
required float x = 1;
required float y = 2;
required float z = 3;
}
message SimpleMessage {
required float lucky_number = 1;
repeated repField vector = 2;
}
和simple.options
SimpleMessage.vector max_count:300
所以我们知道repField
有一个固定的大小 300 并因此定义它。
生成的部分如下所示:
simple.pb.c
:
const pb_field_t repField_fields[4] = {
PB_FIELD( 1, FLOAT , REQUIRED, STATIC , FIRST, repField, x, x, 0),
PB_FIELD( 2, FLOAT , REQUIRED, STATIC , OTHER, repField, y, x, 0),
PB_FIELD( 3, FLOAT , REQUIRED, STATIC , OTHER, repField, z, y, 0),
PB_LAST_FIELD
};
const pb_field_t SimpleMessage_fields[3] = {
PB_FIELD( 1, FLOAT , REQUIRED, STATIC , FIRST, SimpleMessage, lucky_number, lucky_number, 0),
PB_FIELD( 2, MESSAGE , REPEATED, STATIC , OTHER, SimpleMessage, vector, lucky_number, &repField_fields),
PB_LAST_FIELD
};
和一部分simple.pb.h
:
/* Struct definitions */
typedef struct _repField {
float x;
float y;
float z;
/* @@protoc_insertion_point(struct:repField) */
} repField;
typedef struct _SimpleMessage {
float lucky_number;
pb_size_t vector_count;
repField vector[300];
/* @@protoc_insertion_point(struct:SimpleMessage) */
} SimpleMessage;
我们尝试通过执行以下操作对消息进行编码:
// Init message
SimpleMessage message = SimpleMessage_init_zero;
pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer));
// Fill in message
[...]
// Encode message
status = pb_encode(&stream, SimpleMessage_fields, &message);
// stream.bytes_written is wrong!
但是这stream.bytes_written
是错误的,这意味着它没有正确编码,尽管status=1
.
在它的文档中pb_encode()
说:
[...] 但是,子消息必须被序列化两次:首先计算它们的大小,然后将它们实际写入输出。这会对回调字段造成一些限制,这些字段必须在每次调用时返回相同的数据。
但是,我们不确定如何解释这句话 - 究竟要遵循哪些步骤来实现这一点。
所以我们的问题是:
- 使用nanopb库对包含固定大小(重复)子消息的消息进行编码的正确方法是什么?
谢谢!