Lines Matching refs:tcpInfo
662 if (n->tcpInfo.sock) { mDNSPlatformTCPCloseConnection(n->tcpInfo.sock); n->tcpInfo.sock = mDNSNULL; }
737 if (n->tcpInfo.sock) { mDNSPlatformTCPCloseConnection(n->tcpInfo.sock); n->tcpInfo.sock = mDNSNULL; }
848 mDNSPlatformMemZero(&traversal->tcpInfo, sizeof(traversal->tcpInfo));
1247 tcpInfo_t *tcpInfo = (tcpInfo_t *)context;
1249 mDNS *m = tcpInfo->m;
1250 DNSQuestion *const q = tcpInfo->question;
1253 tcpInfo->rr ? &tcpInfo->rr->tcp : mDNSNULL;
1254 if (backpointer && *backpointer != tcpInfo)
1255 LogMsg("tcpCallback: %d backpointer %p incorrect tcpInfo %p question %p rr %p",
1256 mDNSPlatformTCPGetFD(tcpInfo->sock), *backpointer, tcpInfo, q, tcpInfo->rr);
1262 mDNSu8 *end = ((mDNSu8*) &tcpInfo->request) + tcpInfo->requestLen;
1267 if (tcpInfo->rr && tcpInfo->rr->resrec.name != &tcpInfo->rr->namestorage)
1268 LogMsg("tcpCallback: ERROR: tcpInfo->rr->resrec.name %p != &tcpInfo->rr->namestorage %p",
1269 tcpInfo->rr->resrec.name, &tcpInfo->rr->namestorage);
1270 if (tcpInfo->rr && tcpInfo->rr->resrec.name != &tcpInfo->rr->namestorage) return;
1272 AuthInfo = tcpInfo->rr ? GetAuthInfoForName(m, tcpInfo->rr->resrec.name) : mDNSNULL;
1278 end = ((mDNSu8*) &tcpInfo->request) + tcpInfo->requestLen;
1289 llqData.err = GetLLQEventPort(m, &tcpInfo->Addr); // We're using TCP; tell server what UDP port to send notifications to
1293 InitializeDNSMessage(&tcpInfo->request.h, q->TargetQID, uQueryFlags);
1294 end = putLLQ(&tcpInfo->request, tcpInfo->request.data, q, &llqData);
1302 InitializeDNSMessage(&tcpInfo->request.h, q->TargetQID, (DNSSECQuestion(q) ? DNSSecQFlags : uQueryFlags));
1303 end = putQuestion(&tcpInfo->request, tcpInfo->request.data, tcpInfo->request.data + AbsoluteMaxDNSMessageData, &q->qname, q->qtype, q->qclass);
1307 end = DNSProxySetAttributes(q, &tcpInfo->request.h, &tcpInfo->request, end, tcpInfo->request.data + AbsoluteMaxDNSMessageData);
1309 end = putDNSSECOption(&tcpInfo->request, end, tcpInfo->request.data + AbsoluteMaxDNSMessageData);
1315 err = mDNSSendDNSMessage(m, &tcpInfo->request, end, mDNSInterface_Any, mDNSNULL, &tcpInfo->Addr, tcpInfo->Port, sock, AuthInfo, mDNSfalse);
1332 if (tcpInfo->nread < 2) // First read the two-byte length preceeding the DNS message
1334 mDNSu8 *lenptr = (mDNSu8 *)&tcpInfo->replylen;
1335 n = mDNSPlatformReadTCP(sock, lenptr + tcpInfo->nread, 2 - tcpInfo->nread, &closed);
1348 if (tcpInfo->numReplies == 0)
1350 LogMsg("ERROR: socket closed prematurely tcpInfo->nread = %d", tcpInfo->nread);
1360 DisposeTCPConn(tcpInfo);
1365 tcpInfo->nread += n;
1366 if (tcpInfo->nread < 2) goto exit;
1368 tcpInfo->replylen = (mDNSu16)((mDNSu16)lenptr[0] << 8 | lenptr[1]);
1369 if (tcpInfo->replylen < sizeof(DNSMessageHeader))
1370 { LogMsg("ERROR: tcpCallback - length too short (%d bytes)", tcpInfo->replylen); err = mStatus_UnknownErr; goto exit; }
1372 tcpInfo->reply = mDNSPlatformMemAllocate(tcpInfo->replylen);
1373 if (!tcpInfo->reply) { LogMsg("ERROR: tcpCallback - malloc failed"); err = mStatus_NoMemoryErr; goto exit; }
1376 n = mDNSPlatformReadTCP(sock, ((char *)tcpInfo->reply) + (tcpInfo->nread - 2), tcpInfo->replylen - (tcpInfo->nread - 2), &closed);
1386 if (tcpInfo->numReplies == 0)
1388 LogMsg("ERROR: socket closed prematurely tcpInfo->nread = %d", tcpInfo->nread);
1398 DisposeTCPConn(tcpInfo);
1403 tcpInfo->nread += n;
1405 if ((tcpInfo->nread - 2) == tcpInfo->replylen)
1408 DNSMessage *reply = tcpInfo->reply;
1409 mDNSu8 *end = (mDNSu8 *)tcpInfo->reply + tcpInfo->replylen;
1410 mDNSAddr Addr = tcpInfo->Addr;
1411 mDNSIPPort Port = tcpInfo->Port;
1413 tcpInfo->numReplies++;
1414 tcpInfo->reply = mDNSNULL; // Detach reply buffer from tcpInfo_t, to make sure client callback can't cause it to be disposed
1415 tcpInfo->nread = 0;
1416 tcpInfo->replylen = 0;
1432 { *backpointer = mDNSNULL; DisposeTCPConn(tcpInfo); }
1514 DisposeTCPConn(tcpInfo);