Lines Matching refs:dm
122 struct dt_msg *dm,
125 memset(dm, 0, sizeof(*dm));
126 dm->d.base.descriptor = &dnstap__dnstap__descriptor;
127 dm->m.base.descriptor = &dnstap__message__descriptor;
128 dm->d.type = DNSTAP__DNSTAP__TYPE__MESSAGE;
129 dm->d.message = &dm->m;
130 dm->m.type = mtype;
132 dm->d.identity.data = (uint8_t *) env->identity;
133 dm->d.identity.len = (size_t) env->len_identity;
134 dm->d.has_identity = 1;
137 dm->d.version.data = (uint8_t *) env->version;
138 dm->d.version.len = (size_t) env->len_version;
139 dm->d.has_version = 1;
349 dt_msg_fill_net(struct dt_msg *dm,
364 dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET6;
365 dm->m.has_socket_family = 1;
379 dm->m.socket_family = DNSTAP__SOCKET_FAMILY__INET;
380 dm->m.has_socket_family = 1;
422 dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__UDP;
423 dm->m.has_socket_protocol = 1;
427 dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__TCP;
428 dm->m.has_socket_protocol = 1;
431 dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__DOT;
432 dm->m.has_socket_protocol = 1;
436 dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__DOH;
437 dm->m.has_socket_protocol = 1;
440 dm->m.socket_protocol = DNSTAP__SOCKET_PROTOCOL__TCP;
441 dm->m.has_socket_protocol = 1;
454 struct dt_msg dm;
465 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_QUERY);
469 &dm.m.query_time_sec, &dm.m.has_query_time_sec,
470 &dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
473 dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
476 dt_msg_fill_net(&dm, qsock, rsock, cptype, cpssl,
477 &dm.m.query_address, &dm.m.has_query_address,
478 &dm.m.query_port, &dm.m.has_query_port,
479 &dm.m.response_address, &dm.m.has_response_address,
480 &dm.m.response_port, &dm.m.has_response_port);
483 if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
484 dt_send(env, dm.buf, dm.len_buf);
495 struct dt_msg dm;
504 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__CLIENT_RESPONSE);
508 &dm.m.response_time_sec, &dm.m.has_response_time_sec,
509 &dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
512 dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
515 dt_msg_fill_net(&dm, qsock, rsock, cptype, cpssl,
516 &dm.m.query_address, &dm.m.has_query_address,
517 &dm.m.query_port, &dm.m.has_query_port,
518 &dm.m.response_address, &dm.m.has_response_address,
519 &dm.m.response_port, &dm.m.has_response_port);
521 if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
522 dt_send(env, dm.buf, dm.len_buf);
534 struct dt_msg dm;
548 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_QUERY);
552 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_QUERY);
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);
566 dt_fill_buffer(qmsg, &dm.m.query_message, &dm.m.has_query_message);
569 dt_msg_fill_net(&dm, rsock, qsock, cptype, cpssl,
570 &dm.m.response_address, &dm.m.has_response_address,
571 &dm.m.response_port, &dm.m.has_response_port,
572 &dm.m.query_address, &dm.m.has_query_address,
573 &dm.m.query_port, &dm.m.has_query_port);
575 if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
576 dt_send(env, dm.buf, dm.len_buf);
591 struct dt_msg dm;
605 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__FORWARDER_RESPONSE);
609 dt_msg_init(env, &dm, DNSTAP__MESSAGE__TYPE__RESOLVER_RESPONSE);
613 dm.m.query_zone.data = zone;
614 dm.m.query_zone.len = zone_len;
615 dm.m.has_query_zone = 1;
619 &dm.m.query_time_sec, &dm.m.has_query_time_sec,
620 &dm.m.query_time_nsec, &dm.m.has_query_time_nsec);
624 &dm.m.response_time_sec, &dm.m.has_response_time_sec,
625 &dm.m.response_time_nsec, &dm.m.has_response_time_nsec);
628 dt_fill_buffer(rmsg, &dm.m.response_message, &dm.m.has_response_message);
631 dt_msg_fill_net(&dm, rsock, qsock, cptype, cpssl,
632 &dm.m.response_address, &dm.m.has_response_address,
633 &dm.m.response_port, &dm.m.has_response_port,
634 &dm.m.query_address, &dm.m.has_query_address,
635 &dm.m.query_port, &dm.m.has_query_port);
637 if (dt_pack(&dm.d, &dm.buf, &dm.len_buf))
638 dt_send(env, dm.buf, dm.len_buf);
Indexes created Sat Mar 21 00:23:06 UTC 2026