diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-11-25 19:18:09 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-11-25 19:18:09 +0000 |
commit | 8bb9fe7704908d551be75cc8f169c109682d7a56 (patch) | |
tree | eb69a0d6c99414d2fd34a28fb85b40e6ead12e94 /src/fs/gnunet-service-fs_pr.c | |
parent | c633b8eb2291d0327cfd5960b5f31d0df7525f07 (diff) | |
download | gnunet-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.c | 6 |
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 != |