aboutsummaryrefslogtreecommitdiff
path: root/src/dht/test_dht_api.c
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-03-18 21:19:10 +0000
committerNathan S. Evans <evans@in.tum.de>2010-03-18 21:19:10 +0000
commit72a844be131e93002257213893e4e377993f3cd8 (patch)
tree3b6ed2d9c968ee9e48b6a7ff7ad2aa8e6526fa70 /src/dht/test_dht_api.c
parent40ff2323130e2cbe383f9b00fdb5ddfef995d347 (diff)
downloadgnunet-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.c15
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);