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,
319 		dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET6;
320 		dm->m.has_socket_family = 1;
334 		dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET;
335 		dm->m.has_socket_family = 1;
377 		dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__UDP;
378 		dm->m.has_socket_protocol = 1;
382 			dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__TCP;
383 			dm->m.has_socket_protocol = 1;
386 			dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__DOT;
387 			dm->m.has_socket_protocol = 1;
391 		dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__DOH;
392 		dm->m.has_socket_protocol = 1;
395 		dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__TCP;
396 		dm->m.has_socket_protocol = 1;
409 	struct dt_msg dm;
417 	dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_QUERY);
421 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
422 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
425 	dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
428 	dt_msg_fill_net(&dm, qsock, rsock, cptype, cpssl,
429 			&dm.m.query_address, &dm.m.has_query_address,
430 			&dm.m.query_port, &dm.m.has_query_port,
431 			&dm.m.response_address, &dm.m.has_response_address,
432 			&dm.m.response_port, &dm.m.has_response_port);
435 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
436 		dt_send(env, dm.buf, dm.len_buf);
447 	struct dt_msg dm;
453 	dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_RESPONSE);
457 			&dm.m.response_time_sec, &dm.m.has_response_time_sec,
458 			&dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
461 	dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
464 	dt_msg_fill_net(&dm, qsock, rsock, cptype, cpssl,
465 			&dm.m.query_address, &dm.m.has_query_address,
466 			&dm.m.query_port, &dm.m.has_query_port,
467                         &dm.m.response_address, &dm.m.has_response_address,
468                         &dm.m.response_port, &dm.m.has_response_port);
470 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
471 		dt_send(env, dm.buf, dm.len_buf);
483 	struct dt_msg dm;
494 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_QUERY);
498 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_QUERY);
502 	dm.m.query_zone.data = zone;
503 	dm.m.query_zone.len = zone_len;
504 	dm.m.has_query_zone = 1;
508 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
509 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
512 	dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
515 	dt_msg_fill_net(&dm, rsock, qsock, cptype, cpssl,
516 			&dm.m.response_address, &dm.m.has_response_address,
517 			&dm.m.response_port, &dm.m.has_response_port,
518 			&dm.m.query_address, &dm.m.has_query_address,
519 			&dm.m.query_port, &dm.m.has_query_port);
521 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
522 		dt_send(env, dm.buf, dm.len_buf);
537 	struct dt_msg dm;
548 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_RESPONSE);
552 		dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_RESPONSE);
556 	dm.m.query_zone.data = zone;
557 	dm.m.query_zone.len = zone_len;
558 	dm.m.has_query_zone = 1;
562 			&dm.m.query_time_sec, &dm.m.has_query_time_sec,
563 			&dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
567 			&dm.m.response_time_sec, &dm.m.has_response_time_sec,
568 			&dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
571 	dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
574 	dt_msg_fill_net(&dm, rsock, qsock, cptype, cpssl,
575 			&dm.m.response_address, &dm.m.has_response_address,
576 			&dm.m.response_port, &dm.m.has_response_port,
577 			&dm.m.query_address, &dm.m.has_query_address,
578 			&dm.m.query_port, &dm.m.has_query_port);
580 	if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
581 		dt_send(env, dm.buf, dm.len_buf);