Lines Matching refs:err_code
93 int err_code; in unpack_utf8_str() local
97 err_code = unpack_uint16(buf, &utf8_strlen); in unpack_utf8_str()
98 if (err_code != 0) { in unpack_utf8_str()
99 return err_code; in unpack_utf8_str()
201 int err_code; in fixed_header_decode() local
203 err_code = unpack_uint8(buf, type_and_flags); in fixed_header_decode()
204 if (err_code != 0) { in fixed_header_decode()
205 return err_code; in fixed_header_decode()
214 int err_code; in connect_ack_decode() local
217 err_code = unpack_uint8(buf, &flags); in connect_ack_decode()
218 if (err_code != 0) { in connect_ack_decode()
219 return err_code; in connect_ack_decode()
222 err_code = unpack_uint8(buf, &ret_code); in connect_ack_decode()
223 if (err_code != 0) { in connect_ack_decode()
224 return err_code; in connect_ack_decode()
243 int err_code; in publish_decode() local
250 err_code = unpack_utf8_str(buf, ¶m->message.topic.topic); in publish_decode()
251 if (err_code != 0) { in publish_decode()
252 return err_code; in publish_decode()
258 err_code = unpack_uint16(buf, ¶m->message_id); in publish_decode()
259 if (err_code != 0) { in publish_decode()
260 return err_code; in publish_decode()
302 int err_code; in subscribe_ack_decode() local
304 err_code = unpack_uint16(buf, ¶m->message_id); in subscribe_ack_decode()
305 if (err_code != 0) { in subscribe_ack_decode()
306 return err_code; in subscribe_ack_decode()