2 This file is part of GNUnet.
3 Copyright (C) 2012, 2017 GNUnet e.V.
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18 Boston, MA 02110-1301, USA.
21 * @file gnunet-gns-helper-service-w32.c
22 * @brief an intermediary service to access distributed GNS
23 * @author Christian Grothoff
27 #include <gnunet_util_lib.h>
28 #include <gnunet_identity_service.h>
29 #include <gnunet_dnsparser_lib.h>
30 #include <gnunet_namestore_service.h>
31 #include <gnunet_gns_service.h>
33 #include "gnunet_w32nsp_lib.h"
34 #include "w32resolver.h"
38 #define DEFINE_DNS_GUID(a,x) DEFINE_GUID(a, 0x00090035, 0x0000, x, 0xc0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x46)
39 DEFINE_DNS_GUID(SVCID_DNS_TYPE_A, 0x0001);
40 DEFINE_DNS_GUID(SVCID_DNS_TYPE_NS, 0x0002);
41 DEFINE_DNS_GUID(SVCID_DNS_TYPE_CNAME, 0x0005);
42 DEFINE_DNS_GUID(SVCID_DNS_TYPE_SOA, 0x0006);
43 DEFINE_DNS_GUID(SVCID_DNS_TYPE_PTR, 0x000c);
44 DEFINE_DNS_GUID(SVCID_DNS_TYPE_MX, 0x000f);
45 DEFINE_DNS_GUID(SVCID_DNS_TYPE_TEXT, 0x0010);
46 DEFINE_DNS_GUID(SVCID_DNS_TYPE_AAAA, 0x001c);
47 DEFINE_DNS_GUID(SVCID_DNS_TYPE_SRV, 0x0021);
48 DEFINE_GUID(SVCID_HOSTNAME, 0x0002a800, 0x0000, 0x0000, 0xc0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x46);
49 DEFINE_GUID(SVCID_INET_HOSTADDRBYNAME, 0x0002a803, 0x0000, 0x0000, 0xc0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x46);
55 * We keep these in a doubly-linked list (for cleanup).
60 * We keep these in a doubly-linked list (for cleanup).
65 * Client that issued the request
67 struct GNUNET_SERVICE_Client *client;
77 struct GNUNET_GNS_LookupRequest *lookup_request;
82 * Head of the doubly-linked list (for cleanup).
84 static struct request *rq_head;
87 * Tail of the doubly-linked list (for cleanup).
89 static struct request *rq_tail;
92 * Handle to GNS service.
94 static struct GNUNET_GNS_Handle *gns;
97 * Active operation on identity service.
99 static struct GNUNET_IDENTITY_Operation *id_op;
102 * Handle for identity service.
104 static struct GNUNET_IDENTITY_Handle *identity;
107 * Public key of the gns-master ego
109 static struct GNUNET_CRYPTO_EcdsaPublicKey gns_master_pubkey;
112 * Set to 1 once egos are obtained.
118 * Task run on shutdown. Cleans up everything.
123 do_shutdown (void *cls)
129 GNUNET_IDENTITY_cancel (id_op);
132 if (NULL != identity)
134 GNUNET_IDENTITY_disconnect (identity);
137 while (NULL != (rq = rq_head))
139 if (NULL != rq->lookup_request)
140 GNUNET_GNS_lookup_cancel (rq->lookup_request);
141 GNUNET_CONTAINER_DLL_remove (rq_head,
144 GNUNET_free_non_null (rq->name);
151 GNUNET_GNS_disconnect (gns);
158 * Transmit the given message to the client.
160 * @param client target of the message
161 * @param msg message to transmit, will be freed!
164 transmit (struct GNUNET_SERVICE_Client *client,
165 struct GNUNET_MessageHeader *msg)
167 struct GNUNET_MQ_Handle *mq = GNUNET_SERVICE_client_get_mq (client);
168 struct GNUNET_MQ_Envelope *env;
170 /* NOTE: small hack here, should have constructed and
171 passed an 'env' in the first place... */
172 env = GNUNET_MQ_msg_copy (msg);
178 #define MarshallPtr(ptr, base, type) \
180 ptr = (type *) ((char *) ptr - (char *) base)
184 MarshallWSAQUERYSETW (WSAQUERYSETW *qs, GUID *sc)
186 MarshallPtr (qs->lpszServiceInstanceName, qs, wchar_t);
187 MarshallPtr (qs->lpServiceClassId, qs, GUID);
188 MarshallPtr (qs->lpVersion, qs, WSAVERSION);
189 MarshallPtr (qs->lpNSProviderId, qs, GUID);
190 MarshallPtr (qs->lpszContext, qs, wchar_t);
191 MarshallPtr (qs->lpafpProtocols, qs, AFPROTOCOLS);
192 MarshallPtr (qs->lpszQueryString, qs, wchar_t);
193 for (int i = 0; i < qs->dwNumberOfCsAddrs; i++)
195 MarshallPtr (qs->lpcsaBuffer[i].LocalAddr.lpSockaddr, qs, SOCKADDR);
196 MarshallPtr (qs->lpcsaBuffer[i].RemoteAddr.lpSockaddr, qs, SOCKADDR);
198 MarshallPtr (qs->lpcsaBuffer, qs, CSADDR_INFO);
199 if (IsEqualGUID (&SVCID_INET_HOSTADDRBYNAME, sc) && qs->lpBlob != NULL && qs->lpBlob->pBlobData != NULL)
203 he = (struct hostent *) qs->lpBlob->pBlobData;
204 for (int i = 0; he->h_aliases[i] != NULL; i++)
205 MarshallPtr (he->h_aliases[i], he, char);
206 MarshallPtr (he->h_aliases, he, char *);
207 MarshallPtr (he->h_name, he, char);
208 for (int i = 0; he->h_addr_list[i] != NULL; i++)
209 MarshallPtr (he->h_addr_list[i], he, void);
210 MarshallPtr (he->h_addr_list, he, char *);
211 MarshallPtr (qs->lpBlob->pBlobData, qs, void);
213 MarshallPtr (qs->lpBlob, qs, BLOB);
218 process_lookup_result (void *cls,
220 const struct GNUNET_GNSRECORD_Data *rd)
222 struct request *rq = cls;
224 struct GNUNET_W32RESOLVER_GetMessage *msg;
225 struct GNUNET_MessageHeader *msgend;
231 size_t blobaddrcount = 0;
233 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
234 "Got lookup result with count %u for rq %p with client %p\n",
238 rq->lookup_request = NULL;
242 msg = GNUNET_new (struct GNUNET_MessageHeader);
243 msg->header.size = htons (sizeof (struct GNUNET_MessageHeader));
244 msg->header.type = htons (GNUNET_MESSAGE_TYPE_W32RESOLVER_RESPONSE);
245 transmit (rq->client,
247 GNUNET_CONTAINER_DLL_remove (rq_head,
250 GNUNET_free_non_null (rq->name);
257 size = sizeof (struct GNUNET_W32RESOLVER_GetMessage) + sizeof (WSAQUERYSETW);
258 size += (wcslen (rq->name) + 1) * sizeof (wchar_t);
259 size += sizeof (GUID);
260 /* lpszComment ? a TXT record? */
261 size += sizeof (GUID);
262 /* lpszContext ? Not sure what it is */
264 for (i = 0; i < rd_count; i++)
266 switch (rd[i].record_type)
268 case GNUNET_DNSPARSER_TYPE_A:
269 if (rd[i].data_size != sizeof (struct in_addr))
271 size += sizeof (CSADDR_INFO) + sizeof (struct sockaddr_in) * 2;
274 case GNUNET_DNSPARSER_TYPE_AAAA:
275 if (rd[i].data_size != sizeof (struct in6_addr))
277 size += sizeof (CSADDR_INFO) + sizeof (struct sockaddr_in6) * 2;
282 if (IsEqualGUID (&SVCID_INET_HOSTADDRBYNAME, &rq->sc))
284 size += sizeof (BLOB);
285 blobsize += sizeof (struct hostent);
286 blobsize += strlen (rq->u8name) + 1;
287 blobsize += sizeof (void *); /* For aliases */
288 blobsize += sizeof (void *); /* For addresses */
289 for (i = 0; i < rd_count; i++)
291 if ((rq->af == AF_INET || rq->af == AF_UNSPEC) && rd[i].record_type == GNUNET_DNSPARSER_TYPE_A)
293 blobsize += sizeof (void *);
294 blobsize += sizeof (struct in_addr);
297 else if (rq->af == AF_INET6 && rd[i].record_type == GNUNET_DNSPARSER_TYPE_AAAA)
299 blobsize += sizeof (void *);
300 blobsize += sizeof (struct in6_addr);
306 size_recalc = sizeof (struct GNUNET_W32RESOLVER_GetMessage) + sizeof (WSAQUERYSETW);
307 msg = GNUNET_malloc (size);
308 msg->header.size = htons (size - sizeof (struct GNUNET_MessageHeader));
309 msg->header.type = htons (GNUNET_MESSAGE_TYPE_W32RESOLVER_RESPONSE);
310 msg->af = htonl (rq->af);
311 msg->sc_data1 = htonl (rq->sc.Data1);
312 msg->sc_data2 = htons (rq->sc.Data2);
313 msg->sc_data3 = htons (rq->sc.Data3);
314 for (i = 0; i < 8; i++)
315 msg->sc_data4[i] = rq->sc.Data4[i];
316 qs = (WSAQUERYSETW *) &msg[1];
317 ptr = (char *) &qs[1];
318 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
319 qs->dwSize = sizeof (WSAQUERYSETW);
320 qs->lpszServiceInstanceName = (wchar_t *) ptr;
321 ptr += (wcslen (rq->name) + 1) * sizeof (wchar_t);
322 size_recalc += (wcslen (rq->name) + 1) * sizeof (wchar_t);
323 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
324 wcscpy (qs->lpszServiceInstanceName, rq->name);
325 qs->lpServiceClassId = (GUID *) ptr;
326 ptr += sizeof (GUID);
327 size_recalc += sizeof (GUID);
328 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
329 GNUNET_memcpy (qs->lpServiceClassId, &rq->sc, sizeof (GUID));
330 qs->lpVersion = NULL;
331 qs->dwNameSpace = NS_DNS;
332 qs->lpNSProviderId = (GUID *) ptr;
333 ptr += sizeof (GUID);
334 size_recalc += sizeof (GUID);
335 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
336 GNUNET_memcpy (qs->lpNSProviderId, &GNUNET_NAMESPACE_PROVIDER_DNS, sizeof (GUID));
337 qs->lpszContext = NULL;
338 qs->dwNumberOfProtocols = 0;
339 qs->lpafpProtocols = NULL;
340 /* Don't bother with this... */
341 qs->lpszQueryString = NULL;
342 qs->dwNumberOfCsAddrs = rd_count;
343 qs->lpcsaBuffer = (CSADDR_INFO *) ptr;
344 ptr += sizeof (CSADDR_INFO) * csanum;
346 for (i = 0; i < rd_count; i++)
348 switch (rd[i].record_type)
350 case GNUNET_DNSPARSER_TYPE_A:
351 if (rd[i].data_size != sizeof (struct in_addr))
353 qs->lpcsaBuffer[j].iSocketType = SOCK_STREAM;
354 qs->lpcsaBuffer[j].iProtocol = IPPROTO_TCP;
356 qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength = sizeof (struct sockaddr_in);
357 qs->lpcsaBuffer[j].LocalAddr.lpSockaddr = (SOCKADDR *) ptr;
358 ptr += qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength;
359 memset (qs->lpcsaBuffer[j].LocalAddr.lpSockaddr, 0, qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength);
360 ((struct sockaddr_in *)qs->lpcsaBuffer[j].LocalAddr.lpSockaddr)->sin_family = AF_INET;
362 qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength = sizeof (struct sockaddr_in);
363 qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr = (SOCKADDR *) ptr;
364 ptr += qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength;
365 memset (qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr, 0, qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength);
366 ((struct sockaddr_in *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin_family = AF_INET;
367 ((struct sockaddr_in *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin_port = htonl (53); /* Don't ask why it's 53 */
368 ((struct sockaddr_in *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin_addr = *(struct in_addr *) rd[i].data;
369 size_recalc += sizeof (CSADDR_INFO) + sizeof (struct sockaddr_in) * 2;
372 case GNUNET_DNSPARSER_TYPE_AAAA:
373 if (rd[i].data_size != sizeof (struct in6_addr))
375 qs->lpcsaBuffer[j].iSocketType = SOCK_STREAM;
376 qs->lpcsaBuffer[j].iProtocol = IPPROTO_TCP;
378 qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength = sizeof (struct sockaddr_in6);
379 qs->lpcsaBuffer[j].LocalAddr.lpSockaddr = (SOCKADDR *) ptr;
380 ptr += qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength;
381 memset (qs->lpcsaBuffer[j].LocalAddr.lpSockaddr, 0, qs->lpcsaBuffer[j].LocalAddr.iSockaddrLength);
382 ((struct sockaddr_in6 *)qs->lpcsaBuffer[j].LocalAddr.lpSockaddr)->sin6_family = AF_INET6;
384 qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength = sizeof (struct sockaddr_in6);
385 qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr = (SOCKADDR *) ptr;
386 ptr += qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength;
387 memset (qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr, 0, qs->lpcsaBuffer[j].RemoteAddr.iSockaddrLength);
388 ((struct sockaddr_in6 *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin6_family = AF_INET6;
389 ((struct sockaddr_in6 *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin6_port = htonl (53); /* Don't ask why it's 53 */
390 ((struct sockaddr_in6 *)qs->lpcsaBuffer[j].RemoteAddr.lpSockaddr)->sin6_addr = *(struct in6_addr *) rd[i].data;
391 size_recalc += sizeof (CSADDR_INFO) + sizeof (struct sockaddr_in6) * 2;
398 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
399 qs->dwOutputFlags = 0;
400 if (IsEqualGUID (&SVCID_INET_HOSTADDRBYNAME, &rq->sc))
403 qs->lpBlob = (BLOB *) ptr;
404 ptr += sizeof (BLOB);
406 size_recalc += sizeof (BLOB);
407 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
409 qs->lpBlob->cbSize = blobsize;
410 qs->lpBlob->pBlobData = (BYTE *) ptr;
411 ptr += sizeof (struct hostent);
413 size_recalc += sizeof (struct hostent);
414 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
416 he = (struct hostent *) qs->lpBlob->pBlobData;
417 he->h_name = (char *) ptr;
418 ptr += strlen (rq->u8name) + 1;
420 size_recalc += strlen (rq->u8name) + 1;
421 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
423 strcpy (he->h_name, rq->u8name);
424 he->h_aliases = (char **) ptr;
425 ptr += sizeof (void *);
427 size_recalc += sizeof (void *); /* For aliases */
428 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
430 he->h_aliases[0] = NULL;
431 he->h_addrtype = rq->af;
432 he->h_length = rq->af == AF_INET || rq->af == AF_UNSPEC ? sizeof (struct in_addr) : sizeof (struct in6_addr);
433 he->h_addr_list = (char **) ptr;
434 ptr += sizeof (void *) * (blobaddrcount + 1);
436 size_recalc += sizeof (void *) * (blobaddrcount + 1); /* For addresses */
437 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
440 for (i = 0; i < rd_count; i++)
442 if ((rq->af == AF_INET || rq->af == AF_UNSPEC) &&
443 rd[i].record_type == GNUNET_DNSPARSER_TYPE_A)
445 he->h_addr_list[j] = (char *) ptr;
446 ptr += sizeof (struct in_addr);
448 size_recalc += sizeof (struct in_addr);
449 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
451 GNUNET_memcpy (he->h_addr_list[j], rd[i].data, sizeof (struct in_addr));
454 else if (rq->af == AF_INET6 && rd[i].record_type == GNUNET_DNSPARSER_TYPE_AAAA)
456 he->h_addr_list[j] = (char *) ptr;
457 ptr += sizeof (struct in6_addr);
459 size_recalc += sizeof (struct in6_addr);
460 GNUNET_break (size_recalc == (size_t) ((char *) ptr - (char *) msg));
462 GNUNET_memcpy (he->h_addr_list[j], rd[i].data, sizeof (struct in6_addr));
466 he->h_addr_list[j] = NULL;
468 msgend = GNUNET_new (struct GNUNET_MessageHeader);
470 msgend->type = htons (GNUNET_MESSAGE_TYPE_W32RESOLVER_RESPONSE);
471 msgend->size = htons (sizeof (struct GNUNET_MessageHeader));
473 if ((char *) ptr - (char *) msg != size || size_recalc != size || size_recalc != ((char *) ptr - (char *) msg))
475 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
476 "Error in WSAQUERYSETW size calc: expected %u, got %lu (recalc %u)\n",
478 (unsigned long) ((char *) ptr - (char *) msg),
481 MarshallWSAQUERYSETW (qs, &rq->sc);
482 transmit (rq->client,
484 transmit (rq->client,
486 GNUNET_CONTAINER_DLL_remove (rq_head,
489 GNUNET_free_non_null (rq->name);
497 get_ip_from_hostname (struct GNUNET_SERVICE_Client *client,
508 if (IsEqualGUID (&SVCID_DNS_TYPE_A, &sc))
509 rtype = GNUNET_DNSPARSER_TYPE_A;
510 else if (IsEqualGUID (&SVCID_DNS_TYPE_NS, &sc))
511 rtype = GNUNET_DNSPARSER_TYPE_NS;
512 else if (IsEqualGUID (&SVCID_DNS_TYPE_CNAME, &sc))
513 rtype = GNUNET_DNSPARSER_TYPE_CNAME;
514 else if (IsEqualGUID (&SVCID_DNS_TYPE_SOA, &sc))
515 rtype = GNUNET_DNSPARSER_TYPE_SOA;
516 else if (IsEqualGUID (&SVCID_DNS_TYPE_PTR, &sc))
517 rtype = GNUNET_DNSPARSER_TYPE_PTR;
518 else if (IsEqualGUID (&SVCID_DNS_TYPE_MX, &sc))
519 rtype = GNUNET_DNSPARSER_TYPE_MX;
520 else if (IsEqualGUID (&SVCID_DNS_TYPE_TEXT, &sc))
521 rtype = GNUNET_DNSPARSER_TYPE_TXT;
522 else if (IsEqualGUID (&SVCID_DNS_TYPE_AAAA, &sc))
523 rtype = GNUNET_DNSPARSER_TYPE_AAAA;
524 else if (IsEqualGUID (&SVCID_DNS_TYPE_SRV, &sc))
525 rtype = GNUNET_DNSPARSER_TYPE_SRV;
526 else if (IsEqualGUID (&SVCID_INET_HOSTADDRBYNAME, &sc))
527 rtype = GNUNET_DNSPARSER_TYPE_A;
530 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
531 "Unknown GUID: %08lX-%04X-%04X-%02X-%02X-%02X-%02X-%02X-%02X-%02X-%02X\n",
543 GNUNET_SERVICE_client_drop (client);
548 namelen = wcslen (name);
552 hostname = (char *) u16_to_u8 (name, namelen + 1, NULL, &strl);
556 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
557 "W32 DNS resolver asked to look up %s for `%s'.\n",
558 af == AF_INET ? "IPv4" : af == AF_INET6 ? "IPv6" : "anything",
561 rq = GNUNET_new (struct request);
565 if (rq->af != AF_INET && rq->af != AF_INET6)
569 rq->name = GNUNET_malloc ((namelen + 1) * sizeof (wchar_t));
570 GNUNET_memcpy (rq->name,
572 (namelen + 1) * sizeof (wchar_t));
573 rq->u8name = hostname;
576 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
577 "Launching a lookup for client %p with rq %p\n",
580 rq->lookup_request = GNUNET_GNS_lookup (gns,
584 GNUNET_NO /* Use DHT */,
585 &process_lookup_result,
587 if (NULL != rq->lookup_request)
589 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
590 "Lookup launched, waiting for a reply\n");
591 GNUNET_SERVICE_client_continue (client);
592 GNUNET_CONTAINER_DLL_insert (rq_head,
598 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
599 "Lookup was not launched, disconnecting the client\n");
600 GNUNET_free_non_null (rq->name);
604 GNUNET_SERVICE_client_drop (client);
612 * @param cls identification of the client
613 * @param msg the actual message
614 * @return #GNUNET_OK if @a msg is well-formed
617 check_get (void *cls,
618 const struct GNUNET_W32RESOLVER_GetMessage *msg)
621 const wchar_t *hostname;
625 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
626 _("Not ready to process requests, lacking ego data\n"));
627 return GNUNET_SYSERR;
629 size = ntohs (msg->header.size) - sizeof (struct GNUNET_W32RESOLVER_GetMessage);
630 hostname = (const wchar_t *) &msg[1];
631 if (hostname[size / 2 - 1] != L'\0')
634 return GNUNET_SYSERR;
641 * Handle GET-message.
643 * @param cls identification of the client
644 * @param msg the actual message
647 handle_get (void *cls,
648 const struct GNUNET_W32RESOLVER_GetMessage *msg)
650 struct GNUNET_SERVICE_Client *client = cls;
653 const wchar_t *hostname;
656 size = ntohs (msg->header.size) - sizeof (struct GNUNET_W32RESOLVER_GetMessage);
657 af = ntohl (msg->af);
658 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
659 "Got NBO GUID: %08X-%04X-%04X-%02X-%02X-%02X-%02X-%02X-%02X-%02X-%02X\n",
671 sc.Data1 = ntohl (msg->sc_data1);
672 sc.Data2 = ntohs (msg->sc_data2);
673 sc.Data3 = ntohs (msg->sc_data3);
674 for (int i = 0; i < 8; i++)
675 sc.Data4[i] = msg->sc_data4[i];
676 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
677 "Got GUID: %08lX-%04X-%04X-%02X-%02X-%02X-%02X-%02X-%02X-%02X-%02X\n",
689 hostname = (const wchar_t *) &msg[1];
690 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
691 "Name of %u bytes (last word is 0x%0X): %*S\n",
693 hostname[size / 2 - 2],
696 get_ip_from_hostname (client,
704 * Method called to with the ego we are to use for the lookup,
705 * when the ego is the one for the default master zone.
707 * @param cls closure (NULL, unused)
708 * @param ego ego handle, NULL if not found
709 * @param ctx context for application to store data for this ego
710 * (during the lifetime of this process, initially NULL)
711 * @param name name assigned by the user for this ego,
712 * NULL if the user just deleted the ego and it
713 * must thus no longer be used
716 identity_master_cb (void *cls,
717 struct GNUNET_IDENTITY_Ego *ego,
724 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
725 _("Ego for `gns-master' not found, cannot perform lookup. Did you run gnunet-gns-import.sh?\n"));
726 GNUNET_SCHEDULER_shutdown ();
729 GNUNET_IDENTITY_ego_get_public_key (ego,
736 * Start up gns-helper-w32 service.
739 * @param cfg configuration to use
740 * @param service the initialized service
744 const struct GNUNET_CONFIGURATION_Handle *cfg,
745 struct GNUNET_SERVICE_Handle *service)
747 gns = GNUNET_GNS_connect (cfg);
751 _("Failed to connect to GNS\n"));
752 GNUNET_SCHEDULER_shutdown ();
755 GNUNET_SCHEDULER_add_shutdown (&do_shutdown,
757 identity = GNUNET_IDENTITY_connect (cfg,
760 if (NULL == identity)
763 _("Failed to connect to identity service\n"));
764 GNUNET_SCHEDULER_shutdown ();
767 id_op = GNUNET_IDENTITY_get (identity,
771 GNUNET_assert (NULL != id_op);
776 * Handle client connecting to the service.
779 * @param client the new client
780 * @param mq the message queue of @a client
784 client_connect_cb (void *cls,
785 struct GNUNET_SERVICE_Client *client,
786 struct GNUNET_MQ_Handle *mq)
793 * Callback called when a client disconnected from the service
795 * @param cls closure for the service
796 * @param c the client that disconnected
797 * @param internal_cls should be equal to @a c
800 client_disconnect_cb (void *cls,
801 struct GNUNET_SERVICE_Client *client,
804 GNUNET_assert (internal_cls == client);
809 * Define "main" method using service macro.
812 ("gns-helper-service-w32",
813 GNUNET_SERVICE_OPTION_NONE,
816 &client_disconnect_cb,
818 GNUNET_MQ_hd_var_size (get,
819 GNUNET_MESSAGE_TYPE_W32RESOLVER_REQUEST,
820 struct GNUNET_W32RESOLVER_GetMessage,
822 GNUNET_MQ_handler_end());
825 /* end of gnunet-gns-helper-service-w32.c */