Home | History | Annotate | Download | only in mDNSShared

Lines Matching refs:rep

387 mDNSlocal void append_reply(request_state *req, reply_state *rep)
392 *ptr = rep;
393 rep->next = NULL;
398 // On successful completion rep is set to point to a malloc'd reply_state struct
400 request_state *const request, reply_state **const rep, reply_op_t op, DNSServiceFlags flags, mStatus err)
404 *rep = NULL;
428 *rep = create_reply(op, len, request);
429 (*rep)->rhdr->flags = dnssd_htonl(flags);
430 (*rep)->rhdr->ifi = dnssd_htonl(mDNSPlatformInterfaceIndexfromInterfaceID(&mDNSStorage, id, mDNSfalse));
431 (*rep)->rhdr->error = dnssd_htonl(err);
434 data = (char *)&(*rep)->rhdr[1];
446 request_state *const request, reply_state **const rep, reply_op_t op, DNSServiceFlags flags, mStatus err)
454 *rep = NULL;
471 *rep = create_reply(op, len, request);
472 (*rep)->rhdr->flags = dnssd_htonl(flags);
473 (*rep)->rhdr->ifi = dnssd_htonl(mDNSPlatformInterfaceIndexfromInterfaceID(&mDNSStorage, id, mDNSfalse));
474 (*rep)->rhdr->error = dnssd_htonl(err);
477 data = (char *)&(*rep)->rhdr[1];
747 reply_state *rep;
749 if (GenerateNTDResponse(srs->RR_SRV.resrec.name, srs->RR_SRV.resrec.InterfaceID, instance->request, &rep, reg_service_reply_op, 0, mStatus_NoError) != mStatus_NoError)
751 else { append_reply(instance->request, rep); instance->clientnotified = mDNSfalse; }
761 reply_state *rep;
802 if (GenerateNTDResponse(srs->RR_SRV.resrec.name, srs->RR_SRV.resrec.InterfaceID, instance->request, &rep, reg_service_reply_op, kDNSServiceFlagsAdd, result) != mStatus_NoError)
804 else { append_reply(instance->request, rep); instance->clientnotified = mDNStrue; }
848 if (GenerateNTDResponse(srs->RR_SRV.resrec.name, srs->RR_SRV.resrec.InterfaceID, instance->request, &rep, reg_service_reply_op, kDNSServiceFlagsAdd, result) != mStatus_NoError)
850 else { append_reply(instance->request, rep); instance->clientnotified = mDNStrue; }
859 if (GenerateNTDResponse(srs->RR_SRV.resrec.name, srs->RR_SRV.resrec.InterfaceID, instance->request, &rep, reg_service_reply_op, kDNSServiceFlagsAdd, result) != mStatus_NoError)
861 else { append_reply(instance->request, rep); instance->clientnotified = mDNStrue; }
1738 reply_state *rep;
1744 if (GenerateNTDResponse(&answer->rdata->u.name, answer->InterfaceID, req, &rep, browse_reply_op, flags, mStatus_NoError) != mStatus_NoError)
1750 GenerateBonjourBrowserResponse(&answer->rdata->u.name, answer->InterfaceID, req, &rep, browse_reply_op, flags, mStatus_NoError);
1765 append_reply(req, rep);
2230 reply_state *rep;
2261 rep = create_reply(resolve_reply_op, len, req);
2262 rep->rhdr->flags = dnssd_htonl(0);
2263 rep->rhdr->ifi = dnssd_htonl(mDNSPlatformInterfaceIndexfromInterfaceID(m, answer->InterfaceID, mDNSfalse));
2264 rep->rhdr->error = dnssd_htonl(kDNSServiceErr_NoError);
2266 data = (char *)&rep->rhdr[1];
2277 append_reply(req, rep);
2637 reply_state *rep;
2810 rep = create_reply(req->hdr.op == query_request ? query_reply_op : addrinfo_reply_op, len, req);
2812 rep->rhdr->flags = dnssd_htonl(AddRecord ? kDNSServiceFlagsAdd : 0);
2820 rep->rhdr->ifi = dnssd_htonl(mDNSPlatformInterfaceIndexfromInterfaceID(m, answer->InterfaceID, mDNStrue));
2821 rep->rhdr->error = dnssd_htonl(error);
2823 data = (char *)&rep->rhdr[1];
2832 if (!putRData(mDNSNULL, (mDNSu8 *)data, (mDNSu8 *)rep->rhdr + len, answer))
2833 LogMsg("queryrecord_result_callback putRData failed %d", (mDNSu8 *)rep->rhdr + len - (mDNSu8 *)data);
2837 append_reply(req, rep);
3254 reply_state *rep;
3267 rep = create_reply(port_mapping_reply_op, replyLen, request);
3269 rep->rhdr->flags = dnssd_htonl(0);
3270 rep->rhdr->ifi = dnssd_htonl(mDNSPlatformInterfaceIndexfromInterfaceID(m, n->InterfaceID, mDNSfalse));
3271 rep->rhdr->error = dnssd_htonl(n->Result);
3273 data = (char *)&rep->rhdr[1];
3291 append_reply(request, rep);
4589 reply_state *rep;
4590 for (rep = req->replies; rep; rep=rep->next)
4591 if (rep->next == (reply_state *)~0)
4592 LogMemCorruption("UDS req->replies: %p is garbage", rep);
4639 reply_state *const rep = req->replies; // Send the first waiting reply
4643 ConvertHeaderBytes(rep->mhdr);
4644 nwriten = send(req->sd, (char *)&rep->mhdr + rep->nwriten, rep->totallen - rep->nwriten, 0);
4645 ConvertHeaderBytes(rep->mhdr);
4659 rep->totallen - rep->nwriten, rep->totallen, req->sd, dnssd_errno, dnssd_strerror(dnssd_errno));
4664 rep->nwriten += nwriten;
4665 return (rep->nwriten == rep->totallen) ? t_complete : t_morecoming;