Lines Matching refs:pbuf
187 struct pbuf *pbuf; member
210 struct pbuf *pbuf; member
302 mdns_readname_loop(struct pbuf *p, u16_t offset, struct mdns_domain *domain, unsigned depth) in mdns_readname_loop()
374 mdns_readname(struct pbuf *p, u16_t offset, struct mdns_domain *domain) in mdns_readname()
734 mdns_compress_domain(struct pbuf *pbuf, u16_t *offset, struct mdns_domain *domain) in mdns_compress_domain() argument
741 if (pbuf == NULL) { in mdns_compress_domain()
744 target_end = mdns_readname(pbuf, *offset, &target); in mdns_compress_domain()
795 u16_t len = mdns_compress_domain(outpkt->pbuf, &offset, domain); in mdns_write_domain()
806 res = pbuf_take_at(outpkt->pbuf, domain->name, writelen, outpkt->write_offset); in mdns_write_domain()
824 res = pbuf_take_at(outpkt->pbuf, &jump, DOMAIN_JUMP_SIZE, outpkt->write_offset); in mdns_write_domain()
852 if (!outpkt->pbuf) { in mdns_add_question()
854 outpkt->pbuf = pbuf_alloc(PBUF_TRANSPORT, OUTPACKET_SIZE, PBUF_RAM); in mdns_add_question()
855 if (!outpkt->pbuf) { in mdns_add_question()
863 if (outpkt->write_offset + question_len > outpkt->pbuf->tot_len) { in mdns_add_question()
876 res = pbuf_take_at(outpkt->pbuf, &field16, sizeof(field16), outpkt->write_offset); in mdns_add_question()
887 res = pbuf_take_at(outpkt->pbuf, &field16, sizeof(field16), outpkt->write_offset); in mdns_add_question()
924 if (!reply->pbuf) { in mdns_add_answer()
926 reply->pbuf = pbuf_alloc(PBUF_TRANSPORT, OUTPACKET_SIZE, PBUF_RAM); in mdns_add_answer()
927 if (!reply->pbuf) { in mdns_add_answer()
941 if (reply->write_offset + answer_len > reply->pbuf->tot_len) { in mdns_add_answer()
951 res = pbuf_take_at(reply->pbuf, &field32, sizeof(field32), reply->write_offset); in mdns_add_answer()
964 res = pbuf_take_at(reply->pbuf, buf, (u16_t)buf_length, reply->write_offset); in mdns_add_answer()
981 res = pbuf_take_at(reply->pbuf, &field16, sizeof(field16), rdlen_offset); in mdns_add_answer()
998 pkt->parse_offset = mdns_readname(pkt->pbuf, pkt->parse_offset, &info->domain); in mdns_read_rr_info()
1003 copied = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), pkt->parse_offset); in mdns_read_rr_info()
1010 copied = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), pkt->parse_offset); in mdns_read_rr_info()
1032 if (pkt->pbuf->tot_len < pkt->parse_offset) { in mdns_read_question()
1072 if (pkt->pbuf->tot_len < pkt->parse_offset) { in mdns_read_answer()
1092 copied = pbuf_copy_partial(pkt->pbuf, &ttl, sizeof(ttl), pkt->parse_offset); in mdns_read_answer()
1099 copied = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), pkt->parse_offset); in mdns_read_answer()
1407 if (outpkt->pbuf) { in mdns_send_outpacket()
1420 pbuf_take(outpkt->pbuf, &hdr, sizeof(hdr)); in mdns_send_outpacket()
1423 pbuf_realloc(outpkt->pbuf, outpkt->write_offset); in mdns_send_outpacket()
1437 udp_sendto_if(mdns_pcb, outpkt->pbuf, &outpkt->dest_addr, outpkt->dest_port, outpkt->netif); in mdns_send_outpacket()
1439 udp_sendto_if(mdns_pcb, outpkt->pbuf, mcast_destaddr, MDNS_PORT, outpkt->netif); in mdns_send_outpacket()
1444 if (outpkt->pbuf) { in mdns_send_outpacket()
1445 pbuf_free(outpkt->pbuf); in mdns_send_outpacket()
1446 outpkt->pbuf = NULL; in mdns_send_outpacket()
1581 len = mdns_readname(pkt->pbuf, ans.rd_offset, &known_ans); in mdns_handle_question()
1603 pbuf_memcmp(pkt->pbuf, ans.rd_offset, netif_ip4_addr(pkt->netif), ans.rd_length) == 0) { in mdns_handle_question()
1612 … pbuf_memcmp(pkt->pbuf, ans.rd_offset, netif_ip6_addr(pkt->netif, 0), ans.rd_length) == 0) { in mdns_handle_question()
1635 len = mdns_readname(pkt->pbuf, ans.rd_offset, &known_ans); in mdns_handle_question()
1659 len = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), read_pos); in mdns_handle_question()
1665 len = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), read_pos); in mdns_handle_question()
1671 len = pbuf_copy_partial(pkt->pbuf, &field16, sizeof(field16), read_pos); in mdns_handle_question()
1677 len = mdns_readname(pkt->pbuf, read_pos, &known_ans); in mdns_handle_question()
1688 pbuf_memcmp(pkt->pbuf, ans.rd_offset, service->txtdata.name, ans.rd_length) == 0) { in mdns_handle_question()
1700 if (reply.pbuf) { in mdns_handle_question()
1702 pbuf_free(reply.pbuf); in mdns_handle_question()
1703 reply.pbuf = NULL; in mdns_handle_question()
1747 mdns_recv(void *arg, struct udp_pcb *pcb, struct pbuf *p, const ip_addr_t *addr, u16_t port) in mdns_recv()
1779 packet.pbuf = p; in mdns_recv()