diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_cadet_server.c')
-rw-r--r-- | src/fs/gnunet-service-fs_cadet_server.c | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/src/fs/gnunet-service-fs_cadet_server.c b/src/fs/gnunet-service-fs_cadet_server.c index adbce1154..f8619b812 100644 --- a/src/fs/gnunet-service-fs_cadet_server.c +++ b/src/fs/gnunet-service-fs_cadet_server.c | |||
@@ -289,7 +289,7 @@ handle_datastore_reply (void *cls, | |||
289 | } | 289 | } |
290 | return; | 290 | return; |
291 | } | 291 | } |
292 | if (msize > GNUNET_SERVER_MAX_MESSAGE_SIZE) | 292 | if (msize > GNUNET_MAX_MESSAGE_SIZE) |
293 | { | 293 | { |
294 | GNUNET_break (0); | 294 | GNUNET_break (0); |
295 | continue_writing (sc); | 295 | continue_writing (sc); |
@@ -345,12 +345,13 @@ handle_request (void *cls, | |||
345 | GNUNET_NO); | 345 | GNUNET_NO); |
346 | refresh_timeout_task (sc); | 346 | refresh_timeout_task (sc); |
347 | sc->qe = GNUNET_DATASTORE_get_key (GSF_dsh, | 347 | sc->qe = GNUNET_DATASTORE_get_key (GSF_dsh, |
348 | 0, | 348 | 0 /* next_uid */, |
349 | &sqm->query, | 349 | false /* random */, |
350 | ntohl (sqm->type), | 350 | &sqm->query, |
351 | 0 /* priority */, | 351 | ntohl (sqm->type), |
352 | GSF_datastore_queue_size, | 352 | 0 /* priority */, |
353 | &handle_datastore_reply, | 353 | GSF_datastore_queue_size, |
354 | &handle_datastore_reply, | ||
354 | sc); | 355 | sc); |
355 | if (NULL == sc->qe) | 356 | if (NULL == sc->qe) |
356 | { | 357 | { |
@@ -499,12 +500,12 @@ GSF_cadet_start_server () | |||
499 | "Initializing cadet FS server with a limit of %llu connections\n", | 500 | "Initializing cadet FS server with a limit of %llu connections\n", |
500 | sc_count_max); | 501 | sc_count_max); |
501 | cadet_map = GNUNET_CONTAINER_multipeermap_create (16, GNUNET_YES); | 502 | cadet_map = GNUNET_CONTAINER_multipeermap_create (16, GNUNET_YES); |
502 | cadet_handle = GNUNET_CADET_connecT (GSF_cfg); | 503 | cadet_handle = GNUNET_CADET_connect (GSF_cfg); |
503 | GNUNET_assert (NULL != cadet_handle); | 504 | GNUNET_assert (NULL != cadet_handle); |
504 | GNUNET_CRYPTO_hash (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER, | 505 | GNUNET_CRYPTO_hash (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER, |
505 | strlen (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER), | 506 | strlen (GNUNET_APPLICATION_PORT_FS_BLOCK_TRANSFER), |
506 | &port); | 507 | &port); |
507 | cadet_port = GNUNET_CADET_open_porT (cadet_handle, | 508 | cadet_port = GNUNET_CADET_open_port (cadet_handle, |
508 | &port, | 509 | &port, |
509 | &connect_cb, | 510 | &connect_cb, |
510 | NULL, | 511 | NULL, |