Lines Matching refs:dm

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);