mirror of
https://github.com/nmap/nmap.git
synced 2025-12-06 12:41:29 +00:00
mass_dns: prioritize sending new requests over retransmissions
This commit is contained in:
@@ -452,14 +452,14 @@ static void do_possible_writes() {
|
|||||||
for(servI = servs.begin(); servI != servs.end(); servI++) {
|
for(servI = servs.begin(); servI != servs.end(); servI++) {
|
||||||
if (servI->write_busy == 0 && servI->reqs_on_wire < servI->capacity) {
|
if (servI->write_busy == 0 && servI->reqs_on_wire < servI->capacity) {
|
||||||
tpreq = NULL;
|
tpreq = NULL;
|
||||||
if (!servI->to_process.empty()) {
|
if (!new_reqs.empty()) {
|
||||||
tpreq = servI->to_process.front();
|
|
||||||
servI->to_process.pop_front();
|
|
||||||
} else if (!new_reqs.empty()) {
|
|
||||||
tpreq = new_reqs.front();
|
tpreq = new_reqs.front();
|
||||||
assert(tpreq != NULL);
|
assert(tpreq != NULL);
|
||||||
tpreq->first_server = tpreq->curr_server = &*servI;
|
tpreq->first_server = tpreq->curr_server = &*servI;
|
||||||
new_reqs.pop_front();
|
new_reqs.pop_front();
|
||||||
|
} else if (!servI->to_process.empty()) {
|
||||||
|
tpreq = servI->to_process.front();
|
||||||
|
servI->to_process.pop_front();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (tpreq) {
|
if (tpreq) {
|
||||||
|
|||||||
Reference in New Issue
Block a user