Lines Matching refs:params
102 static int decode_msg_advertise(struct net_buf_simple *buf, struct mqtt_sn_param_advertise *params) in decode_msg_advertise() argument
108 params->gw_id = net_buf_simple_pull_u8(buf); in decode_msg_advertise()
109 params->duration = net_buf_simple_pull_be16(buf); in decode_msg_advertise()
114 static int decode_msg_searchgw(struct net_buf_simple *buf, struct mqtt_sn_param_searchgw *params) in decode_msg_searchgw() argument
120 params->radius = net_buf_simple_pull_u8(buf); in decode_msg_searchgw()
125 static int decode_msg_gwinfo(struct net_buf_simple *buf, struct mqtt_sn_param_gwinfo *params) in decode_msg_gwinfo() argument
131 params->gw_id = net_buf_simple_pull_u8(buf); in decode_msg_gwinfo()
134 decode_data(buf, ¶ms->gw_add); in decode_msg_gwinfo()
136 params->gw_add.size = 0; in decode_msg_gwinfo()
142 static int decode_msg_connack(struct net_buf_simple *buf, struct mqtt_sn_param_connack *params) in decode_msg_connack() argument
148 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_connack()
163 static int decode_msg_register(struct net_buf_simple *buf, struct mqtt_sn_param_register *params) in decode_msg_register() argument
169 params->topic_id = net_buf_simple_pull_be16(buf); in decode_msg_register()
170 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_register()
171 decode_data(buf, ¶ms->topic); in decode_msg_register()
176 static int decode_msg_regack(struct net_buf_simple *buf, struct mqtt_sn_param_regack *params) in decode_msg_regack() argument
182 params->topic_id = net_buf_simple_pull_be16(buf); in decode_msg_regack()
183 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_regack()
184 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_regack()
189 static int decode_msg_publish(struct net_buf_simple *buf, struct mqtt_sn_param_publish *params) in decode_msg_publish() argument
198 params->dup = flags.dup; in decode_msg_publish()
199 params->qos = flags.qos; in decode_msg_publish()
200 params->retain = flags.retain; in decode_msg_publish()
201 params->topic_type = flags.topic_type; in decode_msg_publish()
202 params->topic_id = net_buf_simple_pull_be16(buf); in decode_msg_publish()
203 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_publish()
204 decode_data(buf, ¶ms->data); in decode_msg_publish()
209 static int decode_msg_puback(struct net_buf_simple *buf, struct mqtt_sn_param_puback *params) in decode_msg_puback() argument
215 params->topic_id = net_buf_simple_pull_be16(buf); in decode_msg_puback()
216 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_puback()
217 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_puback()
222 static int decode_msg_pubrec(struct net_buf_simple *buf, struct mqtt_sn_param_pubrec *params) in decode_msg_pubrec() argument
228 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubrec()
233 static int decode_msg_pubrel(struct net_buf_simple *buf, struct mqtt_sn_param_pubrel *params) in decode_msg_pubrel() argument
239 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubrel()
244 static int decode_msg_pubcomp(struct net_buf_simple *buf, struct mqtt_sn_param_pubcomp *params) in decode_msg_pubcomp() argument
250 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_pubcomp()
255 static int decode_msg_suback(struct net_buf_simple *buf, struct mqtt_sn_param_suback *params) in decode_msg_suback() argument
265 params->qos = flags.qos; in decode_msg_suback()
267 params->topic_id = net_buf_simple_pull_be16(buf); in decode_msg_suback()
268 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_suback()
269 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_suback()
274 static int decode_msg_unsuback(struct net_buf_simple *buf, struct mqtt_sn_param_unsuback *params) in decode_msg_unsuback() argument
280 params->msg_id = net_buf_simple_pull_be16(buf); in decode_msg_unsuback()
297 struct mqtt_sn_param_disconnect *params) in decode_msg_disconnect() argument
304 struct mqtt_sn_param_willtopicresp *params) in decode_msg_willtopicresp() argument
310 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_willtopicresp()
316 struct mqtt_sn_param_willmsgresp *params) in decode_msg_willmsgresp() argument
322 params->ret_code = net_buf_simple_pull_u8(buf); in decode_msg_willmsgresp()
327 int mqtt_sn_decode_msg(struct net_buf_simple *buf, struct mqtt_sn_param *params) in mqtt_sn_decode_msg() argument
341 params->type = (enum mqtt_sn_msg_type)net_buf_simple_pull_u8(buf); in mqtt_sn_decode_msg()
343 LOG_INF("Decoding message type: %d", params->type); in mqtt_sn_decode_msg()
345 switch (params->type) { in mqtt_sn_decode_msg()
347 return decode_msg_advertise(buf, ¶ms->params.advertise); in mqtt_sn_decode_msg()
349 return decode_msg_searchgw(buf, ¶ms->params.searchgw); in mqtt_sn_decode_msg()
351 return decode_msg_gwinfo(buf, ¶ms->params.gwinfo); in mqtt_sn_decode_msg()
353 return decode_msg_connack(buf, ¶ms->params.connack); in mqtt_sn_decode_msg()
359 return decode_msg_register(buf, ¶ms->params.reg); in mqtt_sn_decode_msg()
361 return decode_msg_regack(buf, ¶ms->params.regack); in mqtt_sn_decode_msg()
363 return decode_msg_publish(buf, ¶ms->params.publish); in mqtt_sn_decode_msg()
365 return decode_msg_puback(buf, ¶ms->params.puback); in mqtt_sn_decode_msg()
367 return decode_msg_pubrec(buf, ¶ms->params.pubrec); in mqtt_sn_decode_msg()
369 return decode_msg_pubrel(buf, ¶ms->params.pubrel); in mqtt_sn_decode_msg()
371 return decode_msg_pubcomp(buf, ¶ms->params.pubcomp); in mqtt_sn_decode_msg()
373 return decode_msg_suback(buf, ¶ms->params.suback); in mqtt_sn_decode_msg()
375 return decode_msg_unsuback(buf, ¶ms->params.unsuback); in mqtt_sn_decode_msg()
381 return decode_msg_disconnect(buf, ¶ms->params.disconnect); in mqtt_sn_decode_msg()
383 return decode_msg_willtopicresp(buf, ¶ms->params.willtopicresp); in mqtt_sn_decode_msg()
385 return decode_msg_willmsgresp(buf, ¶ms->params.willmsgresp); in mqtt_sn_decode_msg()
387 LOG_ERR("Got unexpected message type %d", params->type); in mqtt_sn_decode_msg()