0

我们使用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库对包含固定大小(重复)子消息的消息进行编码的正确方法是什么?

谢谢!

4

1 回答 1

2

您在这里没有使用回调字段,因此该报价对您来说无关紧要。但如果你是,那只是意味着在某些情况下你的回调会被多次调用。

和论坛里的人是同一个人吗?您的堆栈溢出问题没有显示,但是论坛上的人有类似的问题,似乎是由于未设置vector_count. 然后它将保持为 0 长度数组。所以尝试添加:

message.vector_count = 300;

以后,请等待几天再在多个地方发布相同的问题。多次回答同一个问题是浪费志愿者时间。

于 2019-06-25T07:01:11.950 回答