send dns-queries to the service-dns and pretty-print them
authorPhilipp Tölke <toelke@in.tum.de>
Tue, 7 Sep 2010 13:37:28 +0000 (13:37 +0000)
committerPhilipp Tölke <toelke@in.tum.de>
Tue, 7 Sep 2010 13:37:28 +0000 (13:37 +0000)
src/vpn/Makefile.am
src/vpn/gnunet-daemon-vpn.c
src/vpn/gnunet-service-dns.c
src/vpn/gnunet-vpn-pretty-print.h

index 370528772729ec90b3e23ddfaf539c8d246942b9..ca8f6c1af765822b5a0125a03feecd5192ab61d6 100644 (file)
@@ -34,7 +34,8 @@ gnunet_helper_hijack_dns_SOURCES = \
  gnunet-helper-hijack-dns.c
 
 gnunet_daemon_vpn_SOURCES = \
- gnunet-daemon-vpn.c gnunet-vpn-pretty-print.c
+ gnunet-daemon-vpn.c \
+ gnunet-vpn-pretty-print.c
 gnunet_daemon_vpn_LDADD = \
   $(top_builddir)/src/core/libgnunetcore.la \
   $(top_builddir)/src/statistics/libgnunetstatistics.la \
@@ -42,7 +43,8 @@ gnunet_daemon_vpn_LDADD = \
   $(GN_LIBINTL)
 
 gnunet_service_dns_SOURCES = \
- gnunet-service-dns.c
+ gnunet-service-dns.c \
+ gnunet-vpn-pretty-print.c
 gnunet_service_dns_LDADD = \
   $(top_builddir)/src/core/libgnunetcore.la \
   $(top_builddir)/src/statistics/libgnunetstatistics.la \
index 6eb3ea9a0a1186cc137bd1e2574b356fdb248985..147983f5c60e66cc4b163ab8e1bc2621450b22a2 100644 (file)
@@ -149,7 +149,7 @@ static void message_token(void *cls, void *client, const struct GNUNET_MessageHe
                struct ip_pkt *pkt = (struct ip_pkt*) message;
                struct ip_udp *udp = (struct ip_udp*) message;
                if (pkt->ip_hdr.proto == 0x11 && udp->ip_hdr.dadr == 0x020a0a0a && ntohs(udp->udp_hdr.dpt) == 53 ) {
-                       size_t len = sizeof(struct query_packet*) + ntohs(udp->udp_hdr.len) - 7; /* 7 = 8 for the udp-header - 1 for the unsigned char data[1]; */
+                       size_t len = sizeof(struct query_packet) + ntohs(udp->udp_hdr.len) - 9; /* 7 = 8 for the udp-header + 1 for the unsigned char data[1]; */
                        struct query_packet* query = GNUNET_malloc(len);
                        query->hdr.type = htons(GNUNET_MESSAGE_TYPE_LOCAL_QUERY_DNS);
                        query->hdr.size = htons(len);
@@ -157,8 +157,11 @@ static void message_token(void *cls, void *client, const struct GNUNET_MessageHe
                        query->orig_from = pkt->ip_hdr.sadr;
                        query->src_port = udp->udp_hdr.spt;
                        memcpy(query->data, udp->data, ntohs(udp->udp_hdr.len) - 8);
-                       GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Queued sending\n");
-                       GNUNET_CLIENT_notify_transmit_ready(mycls.dns_connection, len, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_YES, &send_query, query);
+                       struct GNUNET_CLIENT_TransmitHandle* th = GNUNET_CLIENT_notify_transmit_ready(mycls.dns_connection, len, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_YES, &send_query, query);
+                       if (th != NULL)
+                               GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Queued sending of %d bytes.\n", len);
+                       else
+                               GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Already queued!\n");
                }
        }
 
index 90e789010e7ab0aa59ee9420b956033ac607db1e..c85ba00270ef2f33c7b81e0b768c46244e4b7c99 100644 (file)
@@ -29,6 +29,8 @@
 #include "gnunet_os_lib.h"
 #include "gnunet-service-dns-p.h"
 #include "gnunet_protocols.h"
+#include "gnunet-vpn-packet.h"
+#include "gnunet-vpn-pretty-print.h"
 
 struct dns_cls {
        struct GNUNET_SCHEDULER_Handle *sched;
@@ -58,6 +60,9 @@ void receive_query(void *cls, struct GNUNET_SERVER_Client *client, const struct
 {
        GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Received query!\n");
        struct query_packet* pkt = (struct query_packet*)message;
+       struct dns_pkt* dns = (struct dns_pkt*)pkt->data;
+
+       pkt_printf_dns(dns);
 
        GNUNET_SERVER_receive_done(client, GNUNET_OK);
 }
index 8e5ff66c27826c05e3b4885ec3557cb7944d5df5..26f651facba1810748f5db6ebe69b9bdc0d2f3ab 100644 (file)
@@ -7,6 +7,8 @@ extern void pp_write_header(char* dest, struct ip6_pkt* pkt);
 
 extern void pkt_printf(struct ip6_pkt* pkt);
 
+void pkt_printf_dns(struct dns_pkt* pkt);
+
 void pkt_printf_ip6tcp(struct ip6_tcp* pkt);
 void pkt_printf_ip6udp(struct ip6_udp* pkt);
 void pkt_printf_ip6dns(struct ip6_udp_dns* pkt);