Lines Matching defs:repinfo

191 	if(a->repinfo.c) {
192 sldns_buffer_free(a->repinfo.c->buffer);
193 free(a->repinfo.c);
370 struct comm_reply repinfo;
385 repinfo.c = &c;
386 repinfo.addrlen = pend->addrlen;
387 memcpy(&repinfo.addr, &pend->addr, pend->addrlen);
397 if((*cb)(&c, cb_arg, NETEVENT_NOERROR, &repinfo)) {
413 if(ans->repinfo.c->type == comm_udp)
417 &ans->repinfo.addr, ans->repinfo.addrlen) == 0) &&
430 if(ans->repinfo.c->tcp_keepalive)
450 struct comm_reply repinfo;
451 memset(&repinfo, 0, sizeof(repinfo));
452 repinfo.c = (struct comm_point*)calloc(1, sizeof(struct comm_point));
453 repinfo.addrlen = (socklen_t)sizeof(struct sockaddr_in);
455 repinfo.addrlen = todo->addrlen;
456 memcpy(&repinfo.addr, &todo->addr, todo->addrlen);
458 repinfo.c->fd = -1;
459 repinfo.c->ev = (struct internal_event*)runtime;
460 repinfo.c->buffer = sldns_buffer_new(runtime->bufsize);
462 repinfo.c->type = comm_tcp;
463 repinfo.c->tcp_timeout_msec = 30000;
464 repinfo.c->tcp_keepalive = runtime->tcp_seen_keepalive;
466 repinfo.c->type = comm_udp;
467 fill_buffer_with_reply(repinfo.c->buffer, todo->match, NULL, 0, 0);
472 if((*runtime->callback_query)(repinfo.c, runtime->cb_arg,
473 NETEVENT_NOERROR, &repinfo)) {
475 comm_point_send_reply(&repinfo);
478 memset(&repinfo, 0, sizeof(repinfo));
489 struct comm_reply repinfo;
509 repinfo.c = &c;
510 repinfo.addrlen = p->addrlen;
511 memcpy(&repinfo.addr, &p->addr, p->addrlen);
521 if((*cb)(&c, cb_arg, error, &repinfo)) {
1001 comm_point_send_reply(struct comm_reply* repinfo)
1005 struct replay_runtime* runtime = (struct replay_runtime*)repinfo->c->ev;
1009 memcpy(&ans->repinfo, repinfo, sizeof(struct comm_reply));
1017 ans->pkt = memdup(sldns_buffer_begin(ans->repinfo.c->buffer),
1018 sldns_buffer_limit(ans->repinfo.c->buffer));
1019 ans->pkt_len = sldns_buffer_limit(ans->repinfo.c->buffer);
1025 comm_point_drop_reply(struct comm_reply* repinfo)
1028 if(repinfo->c) {
1029 sldns_buffer_free(repinfo->c->buffer);
1030 free(repinfo->c);