| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 | /* Encode a message using msgid field as prefix */#include <stdio.h>#include <stdlib.h>#include <string.h>#include <pb_encode.h>#include "msgid_example.pb.h"#include "test_helpers.h"/* This function writes the message id as a prefix to the message, allowing * the receiving side to identify message type. Here we use uint8_t to store * it, but e.g. varint or some custom header struct would work just as well. */bool write_prefix(pb_ostream_t *stream, int msgid){    uint8_t prefix = msgid;    return pb_write(stream, &prefix, 1);}/* The main logic will call one of these functions. * Normally which function you call would be selected based on what message * you want to send, here it is decided based on command line parameter. */bool encode_MyMessage1(pb_ostream_t *stream){    MyMessage1 msg = MyMessage1_init_default;    msg.intvalue = 1234;    return write_prefix(stream, MyMessage1_msgid)           && pb_encode(stream, MyMessage1_fields, &msg);}bool encode_MyMessage2(pb_ostream_t *stream){    MyMessage2 msg = MyMessage2_init_default;    msg.intvalue = 9999;    strcpy(msg.strvalue, "Msg2");    return write_prefix(stream, MyMessage2_msgid)           && pb_encode(stream, MyMessage2_fields, &msg);}bool encode_MyMessage3(pb_ostream_t *stream){    MyMessage3 msg = MyMessage3_init_default;    msg.boolvalue = true;    return write_prefix(stream, MyMessage3_msgid)           && pb_encode(stream, MyMessage3_fields, &msg);}int main(int argc, char **argv){    uint8_t buffer[128];    pb_ostream_t stream;    bool status = false;    int option;    if (argc != 2)    {        fprintf(stderr, "Usage: encode_msgid [number]\n");        return 1;    }    option = atoi(argv[1]);    stream = pb_ostream_from_buffer(buffer, sizeof(buffer));    if (option == 1)    {        status = encode_MyMessage1(&stream);    }    else if (option == 2)    {        status = encode_MyMessage2(&stream);    }    else if (option == 3)    {        status = encode_MyMessage3(&stream);    }    if (status)    {        SET_BINARY_MODE(stdout);        fwrite(buffer, 1, stream.bytes_written, stdout);        return 0;    }    else    {        fprintf(stderr, "Encoding failed: %s\n", PB_GET_ERROR(&stream));        return 1;    }}
 |