Lines Matching defs:pkt
172 char *pkt, const size_t start, int remain_pos)
180 pkt[conn_flags_pos] |= 0x40;
183 pkt[start] = (char)((plen >> 8) & 0xFF);
184 pkt[start + 1] = (char)(plen & 0xFF);
185 memcpy(&pkt[start + 2], passwd, plen);
191 unsigned char *pkt, const size_t start, int remain_pos)
199 pkt[conn_flags_pos] |= 0x80;
201 pkt[start] = (unsigned char)((ulen >> 8) & 0xFF);
202 pkt[start + 1] = (unsigned char)(ulen & 0xFF);
203 memcpy(&pkt[start + 2], username, ulen);
209 char *pkt, const size_t start)
213 pkt[start] = 0x00;
214 pkt[start + 1] = MQTT_CLIENTID_LEN;
215 memcpy(&pkt[start + 2], client_id, MQTT_CLIENTID_LEN);
520 unsigned char *pkt = NULL;
544 pkt = malloc(remaininglength + 1 + encodelen);
545 if(!pkt) {
551 pkt[i++] = MQTT_MSG_PUBLISH;
552 memcpy(&pkt[i], encodedbytes, encodelen);
554 pkt[i++] = (topiclen >> 8) & 0xff;
555 pkt[i++] = (topiclen & 0xff);
556 memcpy(&pkt[i], topic, topiclen);
558 memcpy(&pkt[i], payload, payloadlen);
560 result = mqtt_send(data, (char *)pkt, i);
563 free(pkt);