Lines Matching refs:task_probe
102 /** move to sending the probe packets, next if fails. task_probe */
2174 if(!xfer_set_masters(&x->task_probe->masters, c, 0)) {
2330 if(xfr->task_probe) {
2331 auth_free_masters(xfr->task_probe->masters);
2332 comm_point_delete(xfr->task_probe->cp);
2333 comm_timer_delete(xfr->task_probe->timer);
2334 free(xfr->task_probe);
3992 /** copy the master addresses from the task_probe lookups to the allow_notify
4048 /** start the lookups for task_probe */
4053 xfr->task_probe->scan_addr = NULL;
4054 xfr_masterlist_free_addrs(xfr->task_probe->masters);
4057 xfr->task_probe->lookup_target = xfr->task_probe->masters;
4058 xfr->task_probe->lookup_aaaa = 0;
4061 /** move to the next lookup of hostname for task_probe */
4065 if(!xfr->task_probe->lookup_target)
4067 if(!xfr->task_probe->lookup_aaaa && env->cfg->do_ip6) {
4069 xfr->task_probe->lookup_aaaa = 1;
4072 xfr->task_probe->lookup_target = xfr->task_probe->lookup_target->next;
4073 xfr->task_probe->lookup_aaaa = 0;
4074 if(!env->cfg->do_ip4 && xfr->task_probe->lookup_target!=NULL)
4075 xfr->task_probe->lookup_aaaa = 1;
4105 /** start the iteration of the task_probe list of masters */
4110 xfr->task_probe->scan_specific = find_master_by_host(
4111 xfr->task_probe->masters, spec->host);
4112 if(xfr->task_probe->scan_specific) {
4113 xfr->task_probe->scan_target = NULL;
4114 xfr->task_probe->scan_addr = NULL;
4115 if(xfr->task_probe->scan_specific->list)
4116 xfr->task_probe->scan_addr =
4117 xfr->task_probe->scan_specific->list;
4122 xfr->task_probe->scan_specific = NULL;
4123 xfr->task_probe->scan_addr = NULL;
4125 xfr->task_probe->scan_target = xfr->task_probe->masters;
4126 if(xfr->task_probe->scan_target && xfr->task_probe->scan_target->list)
4127 xfr->task_probe->scan_addr =
4128 xfr->task_probe->scan_target->list;
4140 /** pick up the master that is being scanned right now, task_probe */
4144 if(xfr->task_probe->scan_specific)
4145 return xfr->task_probe->scan_specific;
4146 return xfr->task_probe->scan_target;
4157 /** true if at end of list, task_probe */
4161 return !xfr->task_probe->scan_specific && !xfr->task_probe->scan_target;
4196 /** move to next master in list, task_probe */
4200 if(!xfr->task_probe->scan_specific && !xfr->task_probe->scan_target)
4202 if(xfr->task_probe->scan_addr) {
4203 xfr->task_probe->scan_addr = xfr->task_probe->scan_addr->next;
4204 if(xfr->task_probe->scan_addr)
4207 if(xfr->task_probe->scan_specific) {
4208 xfr->task_probe->scan_specific = NULL;
4209 xfr->task_probe->scan_target = xfr->task_probe->masters;
4210 if(xfr->task_probe->scan_target && xfr->task_probe->
4212 xfr->task_probe->scan_addr =
4213 xfr->task_probe->scan_target->list;
4216 if(!xfr->task_probe->scan_target)
4218 xfr->task_probe->scan_target = xfr->task_probe->scan_target->next;
4219 if(xfr->task_probe->scan_target && xfr->task_probe->
4221 xfr->task_probe->scan_addr =
4222 xfr->task_probe->scan_target->list;
4309 if(LDNS_ID_WIRE(sldns_buffer_begin(pkt)) != xfr->task_probe->id)
6341 /** disown task_probe. caller must hold xfr.lock */
6346 comm_timer_delete(xfr->task_probe->timer);
6347 xfr->task_probe->timer = NULL;
6349 comm_point_delete(xfr->task_probe->cp);
6350 xfr->task_probe->cp = NULL;
6352 xfr->task_probe->worker = NULL;
6353 xfr->task_probe->env = NULL;
6356 /** send the UDP probe to the master, this is part of task_probe */
6373 if(xfr->task_probe->scan_addr) {
6374 addrlen = xfr->task_probe->scan_addr->addrlen;
6375 memmove(&addr, &xfr->task_probe->scan_addr->addr, addrlen);
6405 xfr->task_probe->id = GET_RANDOM_ID(env->rnd);
6407 xfr->task_probe->id);
6409 if(xfr->task_probe->cp &&
6410 ((xfr->task_probe->cp_is_ip6 && !addr_is_ip6(&addr, addrlen)) ||
6411 (!xfr->task_probe->cp_is_ip6 && addr_is_ip6(&addr, addrlen)))
6413 comm_point_delete(xfr->task_probe->cp);
6414 xfr->task_probe->cp = NULL;
6416 if(!xfr->task_probe->cp) {
6418 xfr->task_probe->cp_is_ip6 = 1;
6419 else xfr->task_probe->cp_is_ip6 = 0;
6420 xfr->task_probe->cp = outnet_comm_point_for_udp(env->outnet,
6422 if(!xfr->task_probe->cp) {
6431 if(!xfr->task_probe->timer) {
6432 xfr->task_probe->timer = comm_timer_create(env->worker_base,
6434 if(!xfr->task_probe->timer) {
6441 if(!comm_point_send_udp_msg(xfr->task_probe->cp, env->scratch_buffer,
6457 xfr->task_probe->timeout = timeout;
6462 comm_timer_set(xfr->task_probe->timer, &t);
6467 /** callback for task_probe timer */
6473 log_assert(xfr->task_probe);
6475 env = xfr->task_probe->env;
6486 if(xfr->task_probe->timeout <= AUTH_PROBE_TIMEOUT_STOP) {
6488 if(xfr_probe_send_probe(xfr, env, xfr->task_probe->timeout*2)) {
6494 comm_point_delete(xfr->task_probe->cp);
6495 xfr->task_probe->cp = NULL;
6502 /** callback for task_probe udp packets */
6509 log_assert(xfr->task_probe);
6511 env = xfr->task_probe->env;
6521 comm_timer_disable(xfr->task_probe->timer);
6565 xfr->task_probe->have_new_lease = 1;
6584 comm_point_delete(xfr->task_probe->cp);
6585 xfr->task_probe->cp = NULL;
6600 struct auth_master* master = xfr->task_probe->lookup_target;
6628 if(xfr->task_probe->lookup_aaaa)
6636 " for task_probe", buf2);
6666 /** move to sending the probe packets, next if fails. task_probe */
6671 while(xfr->task_probe->lookup_target) {
6696 if(xfr->task_probe->only_lookup) {
6698 xfr->task_probe->only_lookup = 0;
6723 if(xfr->task_probe->have_new_lease) {
6752 /** callback for task_probe lookup of host name, of A or AAAA */
6759 log_assert(xfr->task_probe);
6761 env = xfr->task_probe->env;
6773 if(xfr->task_probe->lookup_aaaa)
6783 xfr_master_add_addrs(xfr->task_probe->
6789 verbose(VERB_ALGO, "auth zone %s host %s type %s probe lookup has nodata", zname, xfr->task_probe->lookup_target->host, (xfr->task_probe->lookup_aaaa?"AAAA":"A"));
6796 verbose(VERB_ALGO, "auth zone %s host %s type %s probe lookup has no address", zname, xfr->task_probe->lookup_target->host, (xfr->task_probe->lookup_aaaa?"AAAA":"A"));
6804 verbose(VERB_ALGO, "auth zone %s host %s type %s probe lookup failed", zname, xfr->task_probe->lookup_target->host, (xfr->task_probe->lookup_aaaa?"AAAA":"A"));
6807 if(xfr->task_probe->lookup_target->list &&
6808 xfr->task_probe->lookup_target == xfr_probe_current_master(xfr))
6809 xfr->task_probe->scan_addr = xfr->task_probe->lookup_target->list;
6812 * or move to send the probes, or, if nothing to do, end task_probe */
6873 /** start task_probe if possible, if no masters for probe start task_transfer
6882 if(xfr->task_probe->worker == NULL) {
6883 if(!have_probe_targets(xfr->task_probe->masters) &&
6884 !(xfr->task_probe->only_lookup &&
6885 xfr->task_probe->masters != NULL)) {
6886 /* useless to pick up task_probe, no masters to
6897 xfr->task_probe->worker = env->worker;
6898 xfr->task_probe->env = env;
6899 xfr->task_probe->cp = NULL;
6903 xfr->task_probe->have_new_lease = 0;
6989 if(tv.tv_sec != 0 && lookup_only && xfr->task_probe->masters) {
6993 if(xfr->task_probe->worker == NULL)
6994 xfr->task_probe->only_lookup = 1;
7041 if(x->task_probe && x->task_probe->worker != NULL) {
7080 xfr->task_probe = (struct auth_probe*)calloc(1,
7082 if(!xfr->task_probe) {
7091 free(xfr->task_probe);
7115 lock_protect(&xfr->lock, &xfr->task_probe->worker,
7116 sizeof(xfr->task_probe->worker));
8673 m += auth_primaries_get_mem(xfr->task_probe->masters);
8674 m += comm_point_get_mem(xfr->task_probe->cp);
8675 m += comm_timer_get_mem(xfr->task_probe->timer);
8736 if(xfr->task_probe->worker == worker) {