dht.h

   1 /*
   2  * Copyright (c) 2016 Mohamed Aslan <maslan@sce.carleton.ca>
   3  *
   4  * Permission to use, copy, modify, and distribute this software for any
   5  * purpose with or without fee is hereby granted, provided that the above
   6  * copyright notice and this permission notice appear in all copies.
   7  *
   8  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
   9  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  10  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  11  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  12  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  13  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  14  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  15  */
  16
  17 #ifndef DHT_H
  18 #define DHT_H
  19
  20 #include <sys/socket.h>
  21
  22 #define DHT_USEUDP      (1 << 0)
  23
  24
  25 struct dht_node {
  26         uint64_t id;
  27         int port;
  28         int socket;
  29         int ev_queue;
  30         int n_replica;
  31         int def_r;
  32         int def_w;
  33         uint8_t ready;
  34         uint32_t flags;
  35         struct sockaddr_storage saddr;
  36         struct dht_options *opts;
  37         void *ht;
  38 };
  39
  40 struct dht_peer {
  41         uint64_t id;
  42         int sock;
  43         time_t last_recv;
  44         struct sockaddr_storage s_addr;
  45 };
  46
  47 struct dht_options {
  48         uint64_t (*partitioner)(const char *);
  49         int (*ht_init)(void *);
  50         int (*ht_put)(void *, const char *, const char *);
  51         int (*ht_get)(void *, const char *, char **);
  52         int (*ht_del)(void *, const char *);
  53 };
  54
  55 int dht_init(struct dht_node *, int, int, uint32_t, struct dht_options *);
  56 void dht_event_loop(struct dht_node *);
  57 void dht_add_peer(struct dht_node *, const char *, int);
  58 int dht_put_tunable(int, const char *, int);
  59 int dht_get_tunable(int, const char *, char **, int);
  60 int dht_put(int, const char *);
  61 int dht_get(int, const char *, char **);
  62
  63 #endif
  64