aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-11-25 19:18:09 +0000
committerChristian Grothoff <christian@grothoff.org>2012-11-25 19:18:09 +0000
commit8bb9fe7704908d551be75cc8f169c109682d7a56 (patch)
treeeb69a0d6c99414d2fd34a28fb85b40e6ead12e94 /src/fs/gnunet-service-fs_pr.c
parentc633b8eb2291d0327cfd5960b5f31d0df7525f07 (diff)
downloadgnunet-8bb9fe7704908d551be75cc8f169c109682d7a56.tar.gz
gnunet-8bb9fe7704908d551be75cc8f169c109682d7a56.zip
-switch to hash map for replies to avoid linear scan, add timeout for inactive clients
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c
index ecd841808..2b235f9da 100644
--- a/src/fs/gnunet-service-fs_pr.c
+++ b/src/fs/gnunet-service-fs_pr.c
@@ -1181,7 +1181,11 @@ stream_reply_proc (void *cls,
1181 GNUNET_break (0 == data_size); 1181 GNUNET_break (0 == data_size);
1182 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 1182 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1183 "Error retrieiving block via stream\n"); 1183 "Error retrieiving block via stream\n");
1184 /* FIXME: should re-try a few times... */ 1184 /* FIXME: maybe we should re-try a few times; but then
1185 we MUST bound the number of re-tries to not keep
1186 asking indefinitely with fresh streams; this should
1187 be implemented if/when the stream code gets its
1188 timeout/parallel-session limits */
1185 return; 1189 return;
1186 } 1190 }
1187 if (GNUNET_YES != 1191 if (GNUNET_YES !=