diff options
Diffstat (limited to 'src/lockmanager/lockmanager_api.c')
-rw-r--r-- | src/lockmanager/lockmanager_api.c | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/src/lockmanager/lockmanager_api.c b/src/lockmanager/lockmanager_api.c index 311f43b0f..bfd06275c 100644 --- a/src/lockmanager/lockmanager_api.c +++ b/src/lockmanager/lockmanager_api.c | |||
@@ -130,7 +130,7 @@ handle_server_crash (void *cls, | |||
130 | const struct GNUNET_MessageHeader *msg) | 130 | const struct GNUNET_MessageHeader *msg) |
131 | { | 131 | { |
132 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 132 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
133 | "Lockmanger service went down\n"); | 133 | "Lockmanager service not available or went down\n"); |
134 | 134 | ||
135 | } | 135 | } |
136 | 136 | ||
@@ -179,11 +179,13 @@ GNUNET_LOCKMANAGER_connect (const struct GNUNET_CONFIGURATION_Handle *cfg) | |||
179 | { | 179 | { |
180 | struct GNUNET_LOCKMANAGER_Handle *h; | 180 | struct GNUNET_LOCKMANAGER_Handle *h; |
181 | 181 | ||
182 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s()\n", __func__); | ||
182 | h = GNUNET_malloc (sizeof (struct GNUNET_LOCKMANAGER_Handle)); | 183 | h = GNUNET_malloc (sizeof (struct GNUNET_LOCKMANAGER_Handle)); |
183 | h->conn = GNUNET_CLIENT_connect ("lockmanager", cfg); | 184 | h->conn = GNUNET_CLIENT_connect ("lockmanager", cfg); |
184 | if (NULL == h->conn) | 185 | if (NULL == h->conn) |
185 | { | 186 | { |
186 | GNUNET_free (h); | 187 | GNUNET_free (h); |
188 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__); | ||
187 | return NULL; | 189 | return NULL; |
188 | } | 190 | } |
189 | 191 | ||
@@ -192,10 +194,13 @@ GNUNET_LOCKMANAGER_connect (const struct GNUNET_CONFIGURATION_Handle *cfg) | |||
192 | NULL, | 194 | NULL, |
193 | GNUNET_TIME_UNIT_FOREVER_REL); | 195 | GNUNET_TIME_UNIT_FOREVER_REL); |
194 | 196 | ||
195 | GNUNET_CLIENT_receive (h->conn, | 197 | /* FIXME: Assertions fail in client.c if trying to receive multiple messages */ |
196 | &handle_success, | 198 | /* GNUNET_CLIENT_receive (h->conn, */ |
197 | h, | 199 | /* &handle_success, */ |
198 | GNUNET_TIME_UNIT_FOREVER_REL); | 200 | /* h, */ |
201 | /* GNUNET_TIME_UNIT_FOREVER_REL); */ | ||
202 | |||
203 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__); | ||
199 | return h; | 204 | return h; |
200 | } | 205 | } |
201 | 206 | ||
@@ -208,8 +213,10 @@ GNUNET_LOCKMANAGER_connect (const struct GNUNET_CONFIGURATION_Handle *cfg) | |||
208 | void | 213 | void |
209 | GNUNET_LOCKMANAGER_disconnect (struct GNUNET_LOCKMANAGER_Handle *handle) | 214 | GNUNET_LOCKMANAGER_disconnect (struct GNUNET_LOCKMANAGER_Handle *handle) |
210 | { | 215 | { |
216 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s()\n", __func__); | ||
211 | GNUNET_CLIENT_disconnect (handle->conn); | 217 | GNUNET_CLIENT_disconnect (handle->conn); |
212 | GNUNET_free (handle); | 218 | GNUNET_free (handle); |
219 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__); | ||
213 | } | 220 | } |
214 | 221 | ||
215 | 222 | ||
@@ -249,7 +256,7 @@ GNUNET_LOCKMANAGER_acquire_lock (struct GNUNET_LOCKMANAGER_Handle *handle, | |||
249 | struct GNUNET_LOCKMANAGER_Message *msg; | 256 | struct GNUNET_LOCKMANAGER_Message *msg; |
250 | uint16_t msg_size; | 257 | uint16_t msg_size; |
251 | 258 | ||
252 | 259 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s()\n", __func__); | |
253 | r = GNUNET_malloc (sizeof (struct GNUNET_LOCKMANAGER_LockingRequest)); | 260 | r = GNUNET_malloc (sizeof (struct GNUNET_LOCKMANAGER_LockingRequest)); |
254 | r->domain_name_length = strlen (domain_name) + 1; | 261 | r->domain_name_length = strlen (domain_name) + 1; |
255 | r->handle = handle; | 262 | r->handle = handle; |
@@ -271,6 +278,7 @@ GNUNET_LOCKMANAGER_acquire_lock (struct GNUNET_LOCKMANAGER_Handle *handle, | |||
271 | GNUNET_NO, | 278 | GNUNET_NO, |
272 | *transmit_notify, | 279 | *transmit_notify, |
273 | msg); | 280 | msg); |
281 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__); | ||
274 | return r; | 282 | return r; |
275 | } | 283 | } |
276 | 284 | ||
@@ -288,6 +296,7 @@ void | |||
288 | GNUNET_LOCKMANAGER_cancel_request (struct GNUNET_LOCKMANAGER_LockingRequest | 296 | GNUNET_LOCKMANAGER_cancel_request (struct GNUNET_LOCKMANAGER_LockingRequest |
289 | *request) | 297 | *request) |
290 | { | 298 | { |
299 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s()\n", __func__); | ||
291 | /* FIXME: Stop ACQUIRE retransmissions */ | 300 | /* FIXME: Stop ACQUIRE retransmissions */ |
292 | if (GNUNET_LOCKMANAGER_SUCCESS == request->status) | 301 | if (GNUNET_LOCKMANAGER_SUCCESS == request->status) |
293 | { | 302 | { |
@@ -309,5 +318,6 @@ GNUNET_LOCKMANAGER_cancel_request (struct GNUNET_LOCKMANAGER_LockingRequest | |||
309 | &transmit_notify, | 318 | &transmit_notify, |
310 | msg); | 319 | msg); |
311 | } | 320 | } |
321 | LOG (GNUNET_ERROR_TYPE_DEBUG, "%s() END\n", __func__); | ||
312 | GNUNET_free (request); | 322 | GNUNET_free (request); |
313 | } | 323 | } |