src/regex/regex_internal_dht.c

   1 /*
   2      This file is part of GNUnet
   3      (C) 2012 Christian Grothoff (and other contributing authors)
   4
   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.
   9
  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.
  14
  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., 59 Temple Place - Suite 330,
  18      Boston, MA 02111-1307, USA.
  19 */
  20 /**
  21  * @file src/regex/regex_internal_dht.c
  22  * @brief library to announce regexes in the network and match strings
  23  * against published regexes.
  24  * @author Bartlomiej Polot
  25  */
  26 #include "platform.h"
  27 #include "regex_internal_lib.h"
  28 #include "regex_block_lib.h"
  29 #include "gnunet_dht_service.h"
  30 #include "gnunet_statistics_service.h"
  31 #include "gnunet_constants.h"
  32 #include "gnunet_signatures.h"
  33
  34
  35 #define LOG(kind,...) GNUNET_log_from (kind,"regex-dht",__VA_ARGS__)
  36
  37 /* FIXME: OPTION (API, CONFIG) */
  38 #define DHT_REPLICATION 5
  39 #define DHT_TTL         GNUNET_TIME_UNIT_HOURS
  40 #define DEBUG_DHT       GNUNET_NO
  41
  42 #if DEBUG_DHT
  43 #define DHT_OPT         GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE | GNUNET_DHT_RO_RECORD_ROUTE
  44 #else
  45 #define DHT_OPT         GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE
  46 #endif
  47
  48
  49 /**
  50  * Handle to store cached data about a regex announce.
  51  */
  52 struct REGEX_INTERNAL_Announcement
  53 {
  54   /**
  55    * DHT handle to use, must be initialized externally.
  56    */
  57   struct GNUNET_DHT_Handle *dht;
  58
  59   /**
  60    * Regular expression.
  61    */
  62   const char *regex;
  63
  64   /**
  65    * Automaton representation of the regex (expensive to build).
  66    */
  67   struct REGEX_INTERNAL_Automaton* dfa;
  68
  69   /**
  70    * Our private key.
  71    */
  72   const struct GNUNET_CRYPTO_EccPrivateKey *priv;
  73
  74   /**
  75    * Optional statistics handle to report usage. Can be NULL.
  76    */
  77   struct GNUNET_STATISTICS_Handle *stats;
  78 };
  79
  80
  81 /**
  82  * Regex callback iterator to store own service description in the DHT.
  83  *
  84  * @param cls closure.
  85  * @param key hash for current state.
  86  * @param proof proof for current state.
  87  * @param accepting GNUNET_YES if this is an accepting state, GNUNET_NO if not.
  88  * @param num_edges number of edges leaving current state.
  89  * @param edges edges leaving current state.
  90  */
  91 static void
  92 regex_iterator (void *cls,
  93                 const struct GNUNET_HashCode *key,
  94                 const char *proof,
  95                 int accepting,
  96                 unsigned int num_edges,
  97                 const struct REGEX_BLOCK_Edge *edges)
  98 {
  99   struct REGEX_INTERNAL_Announcement *h = cls;
 100   struct RegexBlock *block;
 101   size_t size;
 102
 103   LOG (GNUNET_ERROR_TYPE_DEBUG,
 104        "DHT PUT for state %s with proof `%s' and %u edges\n",
 105        GNUNET_h2s (key),
 106        proof,
 107        num_edges);
 108   if (GNUNET_YES == accepting)
 109   {
 110     struct RegexAcceptBlock block;
 111
 112     LOG (GNUNET_ERROR_TYPE_DEBUG,
 113          "State %s is accepting, putting own id\n",
 114          GNUNET_h2s(key));
 115     size = sizeof (block);
 116     block.purpose.size = sizeof (struct GNUNET_CRYPTO_EccSignaturePurpose) +
 117       sizeof (struct GNUNET_TIME_AbsoluteNBO) +
 118       sizeof (struct GNUNET_HashCode);
 119     block.purpose.purpose = ntohl (GNUNET_SIGNATURE_PURPOSE_REGEX_ACCEPT);
 120     block.expiration_time = GNUNET_TIME_absolute_hton (GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_DHT_MAX_EXPIRATION));
 121     block.key = *key;
 122     GNUNET_CRYPTO_ecc_key_get_public (h->priv,
 123                                       &block.public_key);
 124     GNUNET_assert (GNUNET_OK ==
 125                    GNUNET_CRYPTO_ecc_sign (h->priv,
 126                                            &block.purpose,
 127                                            &block.signature));
 128
 129     GNUNET_STATISTICS_update (h->stats, "# regex accepting blocks stored",
 130                               1, GNUNET_NO);
 131     GNUNET_STATISTICS_update (h->stats, "# regex accepting block bytes stored",
 132                               sizeof (block), GNUNET_NO);
 133     (void)
 134     GNUNET_DHT_put (h->dht, key,
 135                     DHT_REPLICATION,
 136                     DHT_OPT | GNUNET_DHT_RO_RECORD_ROUTE,
 137                     GNUNET_BLOCK_TYPE_REGEX_ACCEPT,
 138                     size,
 139                     &block,
 140                     GNUNET_TIME_relative_to_absolute (DHT_TTL),
 141                     DHT_TTL,
 142                     NULL, NULL);
 143   }
 144   block = REGEX_BLOCK_create (proof,
 145                               num_edges, edges,
 146                               accepting,
 147                               &size);
 148   (void)
 149   GNUNET_DHT_put (h->dht, key,
 150                   DHT_REPLICATION,
 151                   DHT_OPT,
 152                   GNUNET_BLOCK_TYPE_REGEX,
 153                   size, block,
 154                   GNUNET_TIME_relative_to_absolute (DHT_TTL),
 155                   DHT_TTL,
 156                   NULL, NULL);
 157   GNUNET_STATISTICS_update (h->stats, "# regex blocks stored",
 158                             1, GNUNET_NO);
 159   GNUNET_STATISTICS_update (h->stats, "# regex block bytes stored",
 160                             size, GNUNET_NO);
 161   GNUNET_free (block);
 162 }
 163
 164
 165 /**
 166  * Announce a regular expression: put all states of the automaton in the DHT.
 167  * Does not free resources, must call REGEX_INTERNAL_announce_cancel for that.
 168  *
 169  * @param dht An existing and valid DHT service handle. CANNOT be NULL.
 170  * @param priv our private key, must remain valid until the announcement is cancelled
 171  * @param regex Regular expression to announce.
 172  * @param compression How many characters per edge can we squeeze?
 173  * @param stats Optional statistics handle to report usage. Can be NULL.
 174  *
 175  * @return Handle to reuse o free cached resources.
 176  *         Must be freed by calling REGEX_INTERNAL_announce_cancel.
 177  */
 178 struct REGEX_INTERNAL_Announcement *
 179 REGEX_INTERNAL_announce (struct GNUNET_DHT_Handle *dht,
 180                          const struct GNUNET_CRYPTO_EccPrivateKey *priv,
 181                          const char *regex,
 182                          uint16_t compression,
 183                          struct GNUNET_STATISTICS_Handle *stats)
 184 {
 185   struct REGEX_INTERNAL_Announcement *h;
 186
 187   GNUNET_assert (NULL != dht);
 188   h = GNUNET_malloc (sizeof (struct REGEX_INTERNAL_Announcement));
 189   h->regex = regex;
 190   h->dht = dht;
 191   h->stats = stats;
 192   h->priv = priv;
 193   h->dfa = REGEX_INTERNAL_construct_dfa (regex,
 194                                        strlen (regex),
 195                                        compression);
 196   REGEX_INTERNAL_reannounce (h);
 197   return h;
 198 }
 199
 200
 201 /**
 202  * Announce again a regular expression previously announced.
 203  * Does use caching to speed up process.
 204  *
 205  * @param h Handle returned by a previous REGEX_INTERNAL_announce call.
 206  */
 207 void
 208 REGEX_INTERNAL_reannounce (struct REGEX_INTERNAL_Announcement *h)
 209 {
 210   GNUNET_assert (NULL != h->dfa); /* make sure to call announce first */
 211   LOG (GNUNET_ERROR_TYPE_INFO, "REGEX_INTERNAL_reannounce: %.60s\n", h->regex);
 212   LOG (GNUNET_ERROR_TYPE_DEBUG, "  full: %s\n", h->regex);
 213   REGEX_INTERNAL_iterate_all_edges (h->dfa, &regex_iterator, h);
 214 }
 215
 216
 217
 218 /**
 219  * Clear all cached data used by a regex announce.
 220  * Does not close DHT connection.
 221  *
 222  * @param h Handle returned by a previous REGEX_INTERNAL_announce call.
 223  */
 224 void
 225 REGEX_INTERNAL_announce_cancel (struct REGEX_INTERNAL_Announcement *h)
 226 {
 227   REGEX_INTERNAL_automaton_destroy (h->dfa);
 228   GNUNET_free (h);
 229 }
 230
 231
 232 /******************************************************************************/
 233
 234
 235 /**
 236  * Struct to keep state of running searches that have consumed a part of
 237  * the inital string.
 238  */
 239 struct RegexSearchContext
 240 {
 241   /**
 242    * Part of the description already consumed by
 243    * this particular search branch.
 244    */
 245   size_t position;
 246
 247   /**
 248    * Information about the search.
 249    */
 250   struct REGEX_INTERNAL_Search *info;
 251
 252   /**
 253    * We just want to look for one edge, the longer the better.
 254    * Keep its length.
 255    */
 256   unsigned int longest_match;
 257
 258   /**
 259    * Destination hash of the longest match.
 260    */
 261   struct GNUNET_HashCode hash;
 262 };
 263
 264
 265 /**
 266  * Struct to keep information of searches of services described by a regex
 267  * using a user-provided string service description.
 268  */
 269 struct REGEX_INTERNAL_Search
 270 {
 271     /**
 272      * DHT handle to use, must be initialized externally.
 273      */
 274   struct GNUNET_DHT_Handle *dht;
 275
 276     /**
 277      * Optional statistics handle to report usage. Can be NULL.
 278      */
 279   struct GNUNET_STATISTICS_Handle *stats;
 280
 281     /**
 282      * User provided description of the searched service.
 283      */
 284   char *description;
 285
 286     /**
 287      * Running DHT GETs.
 288      */
 289   struct GNUNET_CONTAINER_MultiHashMap *dht_get_handles;
 290
 291     /**
 292      * Results from running DHT GETs.
 293      */
 294   struct GNUNET_CONTAINER_MultiHashMap *dht_get_results;
 295
 296     /**
 297      * Contexts, for each running DHT GET. Free all on end of search.
 298      */
 299   struct RegexSearchContext **contexts;
 300
 301     /**
 302      * Number of contexts (branches/steps in search).
 303      */
 304   unsigned int n_contexts;
 305
 306   /**
 307    * @param callback Callback for found peers.
 308    */
 309   REGEX_INTERNAL_Found callback;
 310
 311   /**
 312    * @param callback_cls Closure for @c callback.
 313    */
 314   void *callback_cls;
 315 };
 316
 317
 318
 319 /**
 320  * Jump to the next edge, with the longest matching token.
 321  *
 322  * @param block Block found in the DHT.
 323  * @param size Size of the block.
 324  * @param ctx Context of the search.
 325  *
 326  * @return GNUNET_YES if should keep iterating, GNUNET_NO otherwise.
 327  */
 328 static void
 329 regex_next_edge (const struct RegexBlock *block,
 330                  size_t size,
 331                  struct RegexSearchContext *ctx);
 332
 333
 334 /**
 335  * Function to process DHT string to regex matching.
 336  * Called on each result obtained for the DHT search.
 337  *
 338  * @param cls Closure (search context).
 339  * @param exp When will this value expire.
 340  * @param key Key of the result.
 341  * @param get_path Path of the get request.
 342  * @param get_path_length Lenght of get_path.
 343  * @param put_path Path of the put request.
 344  * @param put_path_length Length of the put_path.
 345  * @param type Type of the result.
 346  * @param size Number of bytes in data.
 347  * @param data Pointer to the result data.
 348  */
 349 static void
 350 dht_get_string_accept_handler (void *cls, struct GNUNET_TIME_Absolute exp,
 351                                const struct GNUNET_HashCode *key,
 352                                const struct GNUNET_PeerIdentity *get_path,
 353                                unsigned int get_path_length,
 354                                const struct GNUNET_PeerIdentity *put_path,
 355                                unsigned int put_path_length,
 356                                enum GNUNET_BLOCK_Type type,
 357                                size_t size, const void *data)
 358 {
 359   const struct RegexAcceptBlock *block = data;
 360   struct RegexSearchContext *ctx = cls;
 361   struct REGEX_INTERNAL_Search *info = ctx->info;
 362   struct GNUNET_PeerIdentity pid;
 363
 364   LOG (GNUNET_ERROR_TYPE_DEBUG, "Got regex results from DHT!\n");
 365   LOG (GNUNET_ERROR_TYPE_INFO, "   accept for %s (key %s)\n",
 366        info->description, GNUNET_h2s(key));
 367
 368   GNUNET_STATISTICS_update (info->stats, "# regex accepting blocks found",
 369                             1, GNUNET_NO);
 370   GNUNET_STATISTICS_update (info->stats, "# regex accepting block bytes found",
 371                             size, GNUNET_NO);
 372   GNUNET_CRYPTO_hash (&block->public_key,
 373                       sizeof (struct GNUNET_CRYPTO_EccPublicKeyBinaryEncoded),
 374                       &pid.hashPubKey);
 375   info->callback (info->callback_cls,
 376                   &pid,
 377                   get_path, get_path_length,
 378                   put_path, put_path_length);
 379 }
 380
 381
 382 /**
 383  * Find a path to a peer that offers a regex servcie compatible
 384  * with a given string.
 385  *
 386  * @param key The key of the accepting state.
 387  * @param ctx Context containing info about the string, tunnel, etc.
 388  */
 389 static void
 390 regex_find_path (const struct GNUNET_HashCode *key,
 391                  struct RegexSearchContext *ctx)
 392 {
 393   struct GNUNET_DHT_GetHandle *get_h;
 394
 395   LOG (GNUNET_ERROR_TYPE_DEBUG, "Found peer by service\n");
 396   LOG (GNUNET_ERROR_TYPE_INFO, "   find accept for %s\n", GNUNET_h2s (key));
 397   get_h = GNUNET_DHT_get_start (ctx->info->dht,    /* handle */
 398                                 GNUNET_BLOCK_TYPE_REGEX_ACCEPT, /* type */
 399                                 key,     /* key to search */
 400                                 DHT_REPLICATION, /* replication level */
 401                                 DHT_OPT | GNUNET_DHT_RO_RECORD_ROUTE,
 402                                 NULL,       /* xquery */ // FIXME BLOOMFILTER
 403                                 0,     /* xquery bits */ // FIXME BLOOMFILTER SIZE
 404                                 &dht_get_string_accept_handler, ctx);
 405   GNUNET_break (GNUNET_OK ==
 406                 GNUNET_CONTAINER_multihashmap_put(ctx->info->dht_get_handles,
 407                                                   key,
 408                                                   get_h,
 409                                                   GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
 410 }
 411
 412
 413 /**
 414  * Function to process DHT string to regex matching.
 415  * Called on each result obtained for the DHT search.
 416  *
 417  * @param cls closure (search context)
 418  * @param exp when will this value expire
 419  * @param key key of the result
 420  * @param get_path path of the get request (not used)
 421  * @param get_path_length lenght of get_path (not used)
 422  * @param put_path path of the put request (not used)
 423  * @param put_path_length length of the put_path (not used)
 424  * @param type type of the result
 425  * @param size number of bytes in data
 426  * @param data pointer to the result data
 427  *
 428  * TODO: re-issue the request after certain time? cancel after X results?
 429  */
 430 static void
 431 dht_get_string_handler (void *cls, struct GNUNET_TIME_Absolute exp,
 432                         const struct GNUNET_HashCode *key,
 433                         const struct GNUNET_PeerIdentity *get_path,
 434                         unsigned int get_path_length,
 435                         const struct GNUNET_PeerIdentity *put_path,
 436                         unsigned int put_path_length,
 437                         enum GNUNET_BLOCK_Type type,
 438                         size_t size, const void *data)
 439 {
 440   const struct RegexBlock *block = data;
 441   struct RegexSearchContext *ctx = cls;
 442   struct REGEX_INTERNAL_Search *info = ctx->info;
 443   void *copy;
 444   size_t len;
 445   char *datastore;
 446
 447 #if DEBUG_DHT
 448   if ( (NULL != put_path) &&
 449        (0 != put_path_length) )
 450   {
 451     datastore = GNUNET_strdup (GNUNET_i2s (&put_path[put_path_length - 1]));
 452   }
 453   else
 454   {
 455     GNUNET_asprintf (&datastore, "?? %u/%u", put_path_length, get_path_length);
 456   }
 457 #else
 458   datastore = GNUNET_strdup ("N/A");
 459 #endif
 460
 461   LOG (GNUNET_ERROR_TYPE_INFO, " DHT GET result for %s (%s) at %s\n",
 462        GNUNET_h2s (key), ctx->info->description, datastore);
 463   GNUNET_free (datastore);
 464
 465   copy = GNUNET_malloc (size);
 466   memcpy (copy, data, size);
 467   GNUNET_break (
 468     GNUNET_OK ==
 469     GNUNET_CONTAINER_multihashmap_put (info->dht_get_results,
 470                                        key, copy,
 471                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE)
 472                );
 473   len = strlen (info->description);
 474   if (len == ctx->position) // String processed
 475   {
 476     if (GNUNET_YES == ntohs (block->is_accepting))
 477     {
 478       regex_find_path (key, ctx);
 479     }
 480     else
 481     {
 482       LOG (GNUNET_ERROR_TYPE_INFO, "block not accepting!\n");
 483       /* FIXME REGEX this block not successful, wait for more? start timeout? */
 484     }
 485     return;
 486   }
 487   regex_next_edge (block, size, ctx);
 488 }
 489
 490
 491 /**
 492  * Iterator over found existing mesh regex blocks that match an ongoing search.
 493  *
 494  * @param cls Closure (current context)-
 495  * @param key Current key code (key for cached block).
 496  * @param value Value in the hash map (cached RegexBlock).
 497  * @return GNUNET_YES: we should always continue to iterate.
 498  */
 499 static int
 500 regex_result_iterator (void *cls,
 501                        const struct GNUNET_HashCode * key,
 502                        void *value)
 503 {
 504   struct RegexBlock *block = value;
 505   struct RegexSearchContext *ctx = cls;
 506
 507   if (GNUNET_YES == ntohs (block->is_accepting) &&
 508       ctx->position == strlen (ctx->info->description))
 509   {
 510     LOG (GNUNET_ERROR_TYPE_INFO, " * Found accepting known block\n");
 511     regex_find_path (key, ctx);
 512     return GNUNET_YES; // We found an accept state!
 513   }
 514   LOG (GNUNET_ERROR_TYPE_DEBUG, "* %u, %u, [%u]\n",
 515        ctx->position, strlen(ctx->info->description),
 516        ntohs (block->is_accepting));
 517
 518   regex_next_edge (block, SIZE_MAX, ctx);
 519
 520   GNUNET_STATISTICS_update (ctx->info->stats, "# regex mesh blocks iterated",
 521                             1, GNUNET_NO);
 522
 523   return GNUNET_YES;
 524 }
 525
 526
 527 /**
 528  * Iterator over edges in a regex block retrieved from the DHT.
 529  *
 530  * @param cls Closure (context of the search).
 531  * @param token Token that follows to next state.
 532  * @param len Lenght of token.
 533  * @param key Hash of next state.
 534  *
 535  * @return GNUNET_YES if should keep iterating, GNUNET_NO otherwise.
 536  */
 537 static int
 538 regex_edge_iterator (void *cls,
 539                      const char *token,
 540                      size_t len,
 541                      const struct GNUNET_HashCode *key)
 542 {
 543   struct RegexSearchContext *ctx = cls;
 544   struct REGEX_INTERNAL_Search *info = ctx->info;
 545   const char *current;
 546   size_t current_len;
 547
 548   GNUNET_STATISTICS_update (info->stats, "# regex edges iterated",
 549                             1, GNUNET_NO);
 550
 551   LOG (GNUNET_ERROR_TYPE_DEBUG, "*    Start of regex edge iterator\n");
 552   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     descr : %s\n", info->description);
 553   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     posit : %u\n", ctx->position);
 554   current = &info->description[ctx->position];
 555   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     currt : %s\n", current);
 556   current_len = strlen (info->description) - ctx->position;
 557   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     ctlen : %u\n", current_len);
 558   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     tklen : %u\n", len);
 559   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     token : %.*s\n", len, token);
 560   LOG (GNUNET_ERROR_TYPE_DEBUG, "*     nextk : %s\n", GNUNET_h2s(key));
 561   if (len > current_len)
 562   {
 563     LOG (GNUNET_ERROR_TYPE_DEBUG, "*     Token too long, END\n");
 564     return GNUNET_YES; // Token too long, wont match
 565   }
 566   if (0 != strncmp (current, token, len))
 567   {
 568     LOG (GNUNET_ERROR_TYPE_DEBUG, "*     Token doesn't match, END\n");
 569     return GNUNET_YES; // Token doesn't match
 570   }
 571
 572   if (len > ctx->longest_match)
 573   {
 574     LOG (GNUNET_ERROR_TYPE_DEBUG, "*     Token is longer, KEEP\n");
 575     ctx->longest_match = len;
 576     ctx->hash = *key;
 577   }
 578   else
 579   {
 580     LOG (GNUNET_ERROR_TYPE_DEBUG, "*     Token is not longer, IGNORE\n");
 581   }
 582
 583   LOG (GNUNET_ERROR_TYPE_DEBUG, "*    End of regex edge iterator\n");
 584   return GNUNET_YES;
 585 }
 586
 587
 588 /**
 589  * Jump to the next edge, with the longest matching token.
 590  *
 591  * @param block Block found in the DHT.
 592  * @param size Size of the block.
 593  * @param ctx Context of the search.
 594  *
 595  * @return GNUNET_YES if should keep iterating, GNUNET_NO otherwise.
 596  */
 597 static void
 598 regex_next_edge (const struct RegexBlock *block,
 599                  size_t size,
 600                  struct RegexSearchContext *ctx)
 601 {
 602   struct RegexSearchContext *new_ctx;
 603   struct REGEX_INTERNAL_Search *info = ctx->info;
 604   struct GNUNET_DHT_GetHandle *get_h;
 605   struct GNUNET_HashCode *hash;
 606   const char *rest;
 607   int result;
 608
 609   /* Find the longest match for the current string position,
 610    * among tokens in the given block */
 611   ctx->longest_match = 0;
 612   result = REGEX_BLOCK_iterate (block, size,
 613                                        &regex_edge_iterator, ctx);
 614   GNUNET_break (GNUNET_OK == result);
 615
 616   /* Did anything match? */
 617   if (0 == ctx->longest_match)
 618   {
 619     LOG (GNUNET_ERROR_TYPE_DEBUG, "  no match in block\n");
 620     return;
 621   }
 622
 623   hash = &ctx->hash;
 624   new_ctx = GNUNET_malloc (sizeof (struct RegexSearchContext));
 625   new_ctx->info = info;
 626   new_ctx->position = ctx->position + ctx->longest_match;
 627   GNUNET_array_append (info->contexts, info->n_contexts, new_ctx);
 628
 629   /* Check whether we already have a DHT GET running for it */
 630   if (GNUNET_YES ==
 631       GNUNET_CONTAINER_multihashmap_contains (info->dht_get_handles, hash))
 632   {
 633     LOG (GNUNET_ERROR_TYPE_DEBUG, "*     GET for %s running, END\n",
 634          GNUNET_h2s (hash));
 635     GNUNET_CONTAINER_multihashmap_get_multiple (info->dht_get_results,
 636                                                 hash,
 637                                                 &regex_result_iterator,
 638                                                 new_ctx);
 639     return; /* We are already looking for it */
 640   }
 641
 642   GNUNET_STATISTICS_update (info->stats, "# regex nodes traversed",
 643                             1, GNUNET_NO);
 644
 645   /* Start search in DHT */
 646   LOG (GNUNET_ERROR_TYPE_INFO, "   looking for %s\n", GNUNET_h2s (hash));
 647   rest = &new_ctx->info->description[new_ctx->position];
 648   get_h =
 649       GNUNET_DHT_get_start (info->dht,    /* handle */
 650                             GNUNET_BLOCK_TYPE_REGEX, /* type */
 651                             hash,     /* key to search */
 652                             DHT_REPLICATION, /* replication level */
 653                             DHT_OPT,
 654                             rest, /* xquery */
 655                             // FIXME add BLOOMFILTER to exclude filtered peers
 656                             strlen(rest) + 1,     /* xquery bits */
 657                             // FIXME add BLOOMFILTER SIZE
 658                             &dht_get_string_handler, new_ctx);
 659   if (GNUNET_OK !=
 660       GNUNET_CONTAINER_multihashmap_put(info->dht_get_handles,
 661                                         hash,
 662                                         get_h,
 663                                         GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
 664   {
 665     GNUNET_break (0);
 666     return;
 667   }
 668 }
 669
 670
 671 struct REGEX_INTERNAL_Search *
 672 REGEX_INTERNAL_search (struct GNUNET_DHT_Handle *dht,
 673                      const char *string,
 674                      REGEX_INTERNAL_Found callback,
 675                      void *callback_cls,
 676                      struct GNUNET_STATISTICS_Handle *stats)
 677 {
 678   struct REGEX_INTERNAL_Search *h;
 679   struct GNUNET_DHT_GetHandle *get_h;
 680   struct RegexSearchContext *ctx;
 681   struct GNUNET_HashCode key;
 682   size_t size;
 683   size_t len;
 684
 685   /* Initialize handle */
 686   LOG (GNUNET_ERROR_TYPE_INFO, "REGEX_INTERNAL_search: %s\n", string);
 687   GNUNET_assert (NULL != dht);
 688   GNUNET_assert (NULL != callback);
 689   h = GNUNET_malloc (sizeof (struct REGEX_INTERNAL_Search));
 690   h->dht = dht;
 691   h->description = GNUNET_strdup (string);
 692   h->callback = callback;
 693   h->callback_cls = callback_cls;
 694   h->stats = stats;
 695   h->dht_get_handles = GNUNET_CONTAINER_multihashmap_create (32, GNUNET_NO);
 696   h->dht_get_results = GNUNET_CONTAINER_multihashmap_create (32, GNUNET_NO);
 697
 698   /* Initialize context */
 699   len = strlen (string);
 700   size = REGEX_INTERNAL_get_first_key (string, len, &key);
 701   ctx = GNUNET_malloc (sizeof (struct RegexSearchContext));
 702   ctx->position = size;
 703   ctx->info = h;
 704   GNUNET_array_append (h->contexts, h->n_contexts, ctx);
 705   LOG (GNUNET_ERROR_TYPE_DEBUG, "  consumed %u bits out of %u\n", size, len);
 706   LOG (GNUNET_ERROR_TYPE_INFO, "   looking for %s\n", GNUNET_h2s (&key));
 707
 708   /* Start search in DHT */
 709   get_h = GNUNET_DHT_get_start (h->dht,    /* handle */
 710                                 GNUNET_BLOCK_TYPE_REGEX, /* type */
 711                                 &key,     /* key to search */
 712                                 DHT_REPLICATION, /* replication level */
 713                                 DHT_OPT,
 714                                 &h->description[size],           /* xquery */
 715                                 // FIXME add BLOOMFILTER to exclude filtered peers
 716                                 len + 1 - size,                /* xquery bits */
 717                                 // FIXME add BLOOMFILTER SIZE
 718                                 &dht_get_string_handler, ctx);
 719   GNUNET_break (
 720     GNUNET_OK ==
 721     GNUNET_CONTAINER_multihashmap_put (h->dht_get_handles,
 722                                        &key,
 723                                        get_h,
 724                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)
 725                );
 726
 727   return h;
 728 }
 729
 730
 731 /**
 732  * Iterator over hash map entries to cancel DHT GET requests after a
 733  * successful connect_by_string.
 734  *
 735  * @param cls Closure (unused).
 736  * @param key Current key code (unused).
 737  * @param value Value in the hash map (get handle).
 738  * @return GNUNET_YES if we should continue to iterate,
 739  *         GNUNET_NO if not.
 740  */
 741 static int
 742 regex_cancel_dht_get (void *cls,
 743                       const struct GNUNET_HashCode * key,
 744                       void *value)
 745 {
 746   struct GNUNET_DHT_GetHandle *h = value;
 747
 748   GNUNET_DHT_get_stop (h);
 749   return GNUNET_YES;
 750 }
 751
 752
 753 /**
 754  * Iterator over hash map entries to free MeshRegexBlocks stored during the
 755  * search for connect_by_string.
 756  *
 757  * @param cls Closure (unused).
 758  * @param key Current key code (unused).
 759  * @param value MeshRegexBlock in the hash map.
 760  * @return GNUNET_YES if we should continue to iterate,
 761  *         GNUNET_NO if not.
 762  */
 763 static int
 764 regex_free_result (void *cls,
 765                    const struct GNUNET_HashCode * key,
 766                    void *value)
 767 {
 768   GNUNET_free (value);
 769   return GNUNET_YES;
 770 }
 771
 772
 773 /**
 774  * Cancel an ongoing regex search in the DHT and free all resources.
 775  *
 776  * @param h the search context.
 777  */
 778 void
 779 REGEX_INTERNAL_search_cancel (struct REGEX_INTERNAL_Search *h)
 780 {
 781   unsigned int i;
 782
 783   GNUNET_free (h->description);
 784   GNUNET_CONTAINER_multihashmap_iterate (h->dht_get_handles,
 785                                          &regex_cancel_dht_get, NULL);
 786   GNUNET_CONTAINER_multihashmap_iterate (h->dht_get_results,
 787                                          &regex_free_result, NULL);
 788   GNUNET_CONTAINER_multihashmap_destroy (h->dht_get_results);
 789   GNUNET_CONTAINER_multihashmap_destroy (h->dht_get_handles);
 790   if (0 < h->n_contexts)
 791   {
 792     for (i = 0; i < h->n_contexts; i++)
 793       GNUNET_free (h->contexts[i]);
 794     GNUNET_free (h->contexts);
 795   }
 796   GNUNET_free (h);
 797 }
 798
 799
 800 /* end of regex_internal_dht.c */