diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-03-18 21:19:10 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-03-18 21:19:10 +0000 |
commit | 72a844be131e93002257213893e4e377993f3cd8 (patch) | |
tree | 3b6ed2d9c968ee9e48b6a7ff7ad2aa8e6526fa70 /src/dht/test_dht_api.c | |
parent | 40ff2323130e2cbe383f9b00fdb5ddfef995d347 (diff) | |
download | gnunet-72a844be131e93002257213893e4e377993f3cd8.tar.gz gnunet-72a844be131e93002257213893e4e377993f3cd8.zip |
basic api to service communication has been hammered out, as well as service confirmations going back. still needs work, many things not finished.
Diffstat (limited to 'src/dht/test_dht_api.c')
-rw-r--r-- | src/dht/test_dht_api.c | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/dht/test_dht_api.c b/src/dht/test_dht_api.c index 8092d7b2e..578af5aef 100644 --- a/src/dht/test_dht_api.c +++ b/src/dht/test_dht_api.c | |||
@@ -51,8 +51,8 @@ struct PeerContext | |||
51 | struct GNUNET_CONFIGURATION_Handle *cfg; | 51 | struct GNUNET_CONFIGURATION_Handle *cfg; |
52 | struct GNUNET_DHT_Handle *dht_handle; | 52 | struct GNUNET_DHT_Handle *dht_handle; |
53 | struct GNUNET_PeerIdentity id; | 53 | struct GNUNET_PeerIdentity id; |
54 | struct GNUNET_DHT_GetHandle *get_handle; | 54 | struct GNUNET_DHT_RouteHandle *get_handle; |
55 | struct GNUNET_DHT_GetHandle *find_peer_handle; | 55 | struct GNUNET_DHT_RouteHandle *find_peer_handle; |
56 | 56 | ||
57 | #if START_ARM | 57 | #if START_ARM |
58 | pid_t arm_pid; | 58 | pid_t arm_pid; |
@@ -133,7 +133,7 @@ void test_put (void *cls, | |||
133 | 133 | ||
134 | GNUNET_assert (peer->dht_handle != NULL); | 134 | GNUNET_assert (peer->dht_handle != NULL); |
135 | 135 | ||
136 | GNUNET_DHT_put(peer->dht_handle, &hash, 0, data_size, data, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 360), NULL, NULL); | 136 | GNUNET_DHT_put(peer->dht_handle, &hash, 0, data_size, data, GNUNET_TIME_relative_to_absolute(GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 360)) ,GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 360), NULL, NULL); |
137 | 137 | ||
138 | //GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), &test_put, &p1); | 138 | //GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), &test_put, &p1); |
139 | 139 | ||
@@ -155,9 +155,10 @@ void test_get_stop (void *cls, | |||
155 | 155 | ||
156 | GNUNET_assert (peer->dht_handle != NULL); | 156 | GNUNET_assert (peer->dht_handle != NULL); |
157 | 157 | ||
158 | GNUNET_DHT_get_stop(peer->dht_handle, peer->get_handle); | 158 | GNUNET_DHT_get_stop(peer->get_handle); |
159 | 159 | ||
160 | GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), &test_put, &p1); | 160 | //GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), &test_put, &p1); |
161 | GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1), &end, &p1); | ||
161 | 162 | ||
162 | } | 163 | } |
163 | 164 | ||
@@ -174,10 +175,10 @@ void test_get (void *cls, | |||
174 | GNUNET_HashCode hash; | 175 | GNUNET_HashCode hash; |
175 | memset(&hash, 42, sizeof(GNUNET_HashCode)); | 176 | memset(&hash, 42, sizeof(GNUNET_HashCode)); |
176 | 177 | ||
177 | peer->dht_handle = GNUNET_DHT_connect (sched, peer->cfg); | 178 | peer->dht_handle = GNUNET_DHT_connect (sched, peer->cfg, 100); |
178 | GNUNET_assert (peer->dht_handle != NULL); | 179 | GNUNET_assert (peer->dht_handle != NULL); |
179 | 180 | ||
180 | peer->get_handle = GNUNET_DHT_get_start(peer->dht_handle, 42, &hash, NULL, NULL); | 181 | peer->get_handle = GNUNET_DHT_get_start(peer->dht_handle, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 100), 42, &hash, NULL, NULL); |
181 | 182 | ||
182 | if (peer->get_handle == NULL) | 183 | if (peer->get_handle == NULL) |
183 | GNUNET_SCHEDULER_add_now(sched, &end_badly, &p1); | 184 | GNUNET_SCHEDULER_add_now(sched, &end_badly, &p1); |