unbound/dnstap/dnstap.c

97 	    struct dt_msg *dm,
100 	memset(dm, 0, sizeof(*dm));
101 	dm->d.base.descriptor = &dnstap__dnstap__descriptor;
102 	dm->m.base.descriptor = &dnstap__message__descriptor;
103 	dm->d.type = DNSTAP__DNSTAP__TYPE__MESSAGE;
104 	dm->d.message = &dm->m;
105 	dm->m.type = mtype;
107 		dm->d.identity.data = (uint8_t *) env->identity;
108 		dm->d.identity.len = (size_t) env->len_identity;
109 		dm->d.has_identity = 1;
112 		dm->d.version.data = (uint8_t *) env->version;
113 		dm->d.version.len = (size_t) env->len_version;
114 		dm->d.has_version = 1;
304 dt_msg_fill_net(struct dt_msg *dm,
315 		dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET6;
316 		dm->m.has_socket_family = 1;
330 		dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET;
331 		dm->m.has_socket_family = 1;
346 		dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__UDP;
347 		dm->m.has_socket_protocol = 1;
350 		dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__TCP;
351 		dm->m.has_socket_protocol = 1;
361 	struct dt_msg dm;
367 	dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_QUERY);
371 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
372 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
375 	dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
379 	dt_msg_fill_net(&dm, qsock, cptype,
380 			&dm.m.query_address, &dm.m.has_query_address,
381 			&dm.m.query_port, &dm.m.has_query_port);
383 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
384 		dt_send(env, dm.buf, dm.len_buf);
393 	struct dt_msg dm;
399 	dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_RESPONSE);
403 			&dm.m.response_time_sec, &dm.m.has_response_time_sec,
404 			&dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
407 	dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
411 	dt_msg_fill_net(&dm, qsock, cptype,
412 			&dm.m.query_address, &dm.m.has_query_address,
413 			&dm.m.query_port, &dm.m.has_query_port);
415 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
416 		dt_send(env, dm.buf, dm.len_buf);
426 	struct dt_msg dm;
437 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_QUERY);
441 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_QUERY);
445 	dm.m.query_zone.data = zone;
446 	dm.m.query_zone.len = zone_len;
447 	dm.m.has_query_zone = 1;
451 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
452 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
455 	dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
459 	dt_msg_fill_net(&dm, rsock, cptype,
460 			&dm.m.response_address, &dm.m.has_response_address,
461 			&dm.m.response_port, &dm.m.has_response_port);
463 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
464 		dt_send(env, dm.buf, dm.len_buf);
477 	struct dt_msg dm;
488 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_RESPONSE);
492 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_RESPONSE);
496 	dm.m.query_zone.data = zone;
497 	dm.m.query_zone.len = zone_len;
498 	dm.m.has_query_zone = 1;
502 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
503 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
507 			&dm.m.response_time_sec, &dm.m.has_response_time_sec,
508 			&dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
511 	dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
515 	dt_msg_fill_net(&dm, rsock, cptype,
516 			&dm.m.response_address, &dm.m.has_response_address,
517 			&dm.m.response_port, &dm.m.has_response_port);
519 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
520 		dt_send(env, dm.buf, dm.len_buf);