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()
191 int err_code; in fixed_header_decode() local
193 err_code = unpack_uint8(buf, type_and_flags); in fixed_header_decode()
194 if (err_code != 0) { in fixed_header_decode()
195 return err_code; in fixed_header_decode()
198 err_code = unpack_variable_int(buf, length); in fixed_header_decode()
199 if (err_code < 0) { in fixed_header_decode()
200 return err_code; in fixed_header_decode()
669 int err_code; in connect_ack_decode() local
672 err_code = unpack_uint8(buf, &flags); in connect_ack_decode()
673 if (err_code != 0) { in connect_ack_decode()
674 return err_code; in connect_ack_decode()
677 err_code = unpack_uint8(buf, &ret_code); in connect_ack_decode()
678 if (err_code != 0) { in connect_ack_decode()
679 return err_code; in connect_ack_decode()
693 err_code = connack_properties_decode(buf, param); in connect_ack_decode()
694 if (err_code < 0) { in connect_ack_decode()
695 return err_code; in connect_ack_decode()
828 int err_code; in publish_decode() local
835 err_code = unpack_utf8_str(buf, ¶m->message.topic.topic); in publish_decode()
836 if (err_code != 0) { in publish_decode()
837 return err_code; in publish_decode()
843 err_code = unpack_uint16(buf, ¶m->message_id); in publish_decode()
844 if (err_code != 0) { in publish_decode()
845 return err_code; in publish_decode()
852 err_code = publish_properties_decode(buf, param); in publish_decode()
853 if (err_code < 0) { in publish_decode()
854 return err_code; in publish_decode()
858 var_header_length += err_code; in publish_decode()
860 err_code = publish_topic_alias_check(client, param); in publish_decode()
861 if (err_code < 0) { in publish_decode()
862 return err_code; in publish_decode()
1027 int err_code; in subscribe_ack_decode() local
1029 err_code = unpack_uint16(buf, ¶m->message_id); in subscribe_ack_decode()
1030 if (err_code != 0) { in subscribe_ack_decode()
1031 return err_code; in subscribe_ack_decode()
1035 err_code = suback_properties_decode(buf, param); in subscribe_ack_decode()
1036 if (err_code < 0) { in subscribe_ack_decode()
1037 return err_code; in subscribe_ack_decode()