Lines Matching refs:request
100 // args passed to UDP request handler thread as void*
110 // args passed to TCP request handler thread as void*
693 UDPServerTransaction(const DaemonInfo *d, const PktMsg *request, PktMsg *reply, mDNSBool *trunc)
713 ntohs(request->msg.h.numQuestions),
714 ntohs(request->msg.h.numAnswers),
715 ntohs(request->msg.h.numAuthorities),
716 ntohs(request->msg.h.numAdditionals));
717 res = sendto( sd, (char *)&request->msg, request->len, 0, ( struct sockaddr* ) &d->ns_addr, sizeof( d->ns_addr ) );
718 require_action( res == (int) request->len, exit, err = mStatus_UnknownErr; LogErr( "UDPServerTransaction", "sendto" ) );
755 // check if a request and server response complete a successful dynamic update
756 mDNSlocal mDNSBool SuccessfulUpdateTransaction(PktMsg *request, PktMsg *reply)
762 if (!request || !reply) { vlogmsg = "NULL message"; goto failure; }
763 if (request->len < sizeof(DNSMessageHeader) || reply->len < sizeof(DNSMessageHeader)) { vlogmsg = "Malformatted message"; goto failure; }
765 // check request operation
766 if ((request->msg.h.flags.b[0] & kDNSFlag0_QROP_Mask) != (request->msg.h.flags.b[0] & kDNSFlag0_QROP_Mask))
767 { vlogmsg = "Request opcode not an update"; goto failure; }
774 VLog("Successful update from %s", inet_ntop(AF_INET, &request->src.sin_addr, buf, 32));
778 VLog("Request %s: %s", inet_ntop(AF_INET, &request->src.sin_addr, buf, 32), vlogmsg);
1370 // main update request handling
1507 PktMsg * request
1517 if ((request->msg.h.flags.b[0] & kDNSFlag0_QROP_Mask) == kDNSFlag0_OP_Update)
1520 const mDNSu8 *ptr, *end = (mDNSu8 *)&request->msg + request->len;
1521 HdrNToH(request);
1522 lease = GetPktLease(&mDNSStorage, &request->msg, end);
1523 ptr = LocateAuthorities(&request->msg, end);
1524 for (i = 0; i < request->msg.h.mDNS_numUpdates; i++)
1527 ptr = GetLargeResourceRecord(NULL, &request->msg, ptr, end, 0, kDNSRecordTypePacketAns, &lcr);
1530 HdrHToN(request);
1534 Log("Rejecting Update Request with %d additions but no lease", adds);
1540 InitializeDNSMessage(&reply->msg.h, request->msg.h.id, UpdateRefused);
1548 if ( request->len <= 512 )
1552 if ( UDPServerTransaction( self, request, &buf, &trunc) < 0 )
1572 require_action_quiet( sock, exit, err = mStatus_UnknownErr ; Log( "Discarding request from %s due to connection errors", inet_ntop( AF_INET, &request->src.sin_addr, addrbuf, 32 ) ) );
1574 res = SendPacket( sock, request );
1575 require_action_quiet( res >= 0, exit, err = mStatus_UnknownErr ; Log( "Couldn't relay message from %s to server. Discarding.", inet_ntop(AF_INET, &request->src.sin_addr, addrbuf, 32 ) ) );
1588 mDNSBool ok = SuccessfulUpdateTransaction( request, reply );
1589 require_action( ok, exit, err = mStatus_UnknownErr; VLog( "Message from %s not a successful update.", inet_ntop(AF_INET, &request->src.sin_addr, addrbuf, 32 ) ) );
1591 UpdateLeaseTable( request, self, lease );
2118 // Handle a refresh request from client
2346 // According to RFC 2671, "One OPT pseudo-RR can be added to the additional data section of either a request or a response."
2522 // request handler wrappers for TCP and UDP requests
2536 // !!!KRS strictly speaking, we shouldn't use TCP for a UDP request because the server
2682 // read the request
