aboutsummaryrefslogtreecommitdiff
path: root/src/lockmanager/lockmanager_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/lockmanager/lockmanager_api.c')
-rw-r--r--src/lockmanager/lockmanager_api.c22
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)
208void 213void
209GNUNET_LOCKMANAGER_disconnect (struct GNUNET_LOCKMANAGER_Handle *handle) 214GNUNET_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
288GNUNET_LOCKMANAGER_cancel_request (struct GNUNET_LOCKMANAGER_LockingRequest 296GNUNET_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}