typedef struct Query Query;
typedef struct Resolver Resolver;
typedef struct OptionInfo OptionInfo;
-static void asynch_check(Resolver *res);
-static void asynch_sethandlers(Resolver *res, int shutdown);
+
+static void asynch_sethandlers(Resolver *res);
+static void asynch_cancelhandlers(Resolver *res);
+static void asynch_perturbed(Resolver *res);
+
static void asynch_query_dispose(Tcl_Interp *interp, Query *query);
/*---------- common resolver/query option processing ----------*/
}
adns_finish(res->ads);
}
- asynch_sethandlers(res,1);
+ asynch_cancelhandlers(res);
TFREE(res);
/* fixme what about the default resolver */
}
ec= adns_wait(res->ads,&aqu,answer_r,0);
assert(!ec);
- asynch_check(res);
+ asynch_perturbed(res);
return TCL_OK;
}
Tcl_Obj *xargs;
};
+static void asynch_check_now(Resolver *res);
+
static void asynch_timerhandler(void *res_v) {
Resolver *res= res_v;
res->timertoken= 0;
adns_processtimeouts(res->ads,0);
- asynch_check(res);
+ asynch_check_now(res);
}
static void asynch_filehandler(void *res_v, int mask) {
ec= adns_processany(res->ads);
if (ec) adns_globalsystemfailure(res->ads);
- asynch_check(res);
+ asynch_check_now(res);
}
-static void asynch_sethandlers(Resolver *res, int shutdown) {
+static void asynch_sethandlers_generic(Resolver *res,
+ int shutdown /*from _cancelhandlers*/,
+ int immediate /*from _perturbed*/) {
fd_set want[3];
int maxfd;
struct timeval tv_buf, *timeout;
Tcl_DeleteTimerHandler(res->timertoken);
- if (timeout) {
+ if (immediate) {
+ res->timertoken= Tcl_CreateTimerHandler(0,asynch_timerhandler,res);
+ } else if (timeout) {
int milliseconds;
if (timeout->tv_sec >= INT_MAX/1000 - 1)
}
}
-static void asynch_check(Resolver *res) {
+static void asynch_sethandlers(Resolver *res) {
+ asynch_sethandlers_generic(res,0,0);
+}
+static void asynch_cancelhandlers(Resolver *res) {
+ asynch_sethandlers_generic(res,1,0);
+}
+static void asynch_perturbed(Resolver *res) {
+ asynch_sethandlers_generic(res,0,1);
+}
+
+static void asynch_check_now(Resolver *res) {
Tcl_Interp *interp= res->interp;
adns_query aqu;
adns_answer *answer;
asynch_query_dispose(interp, query);
}
- asynch_sethandlers(res,0);
+ asynch_sethandlers(res);
}
int do_adns_asynch(ClientData cd, Tcl_Interp *ip,
x_rc:
if (query) asynch_query_dispose(ip, query);
- if (res) asynch_sethandlers(res,0);
+ if (res) asynch_perturbed(res);
return rc;
}
Query *query= query_v;
Resolver *res= query->res;
asynch_query_dispose(ip, query);
- asynch_sethandlers(res,0);
+ asynch_perturbed(res);
return TCL_OK;
}