(unsigned long long) off,
sr);
sr->remaining_probe_time =
- GNUNET_TIME_relative_multiply (sr->h->avg_block_latency,
- 2 * (1 + sr->availability_trials));
+ GNUNET_TIME_relative_saturating_multiply (sr->h->avg_block_latency,
+ 2 * (1 + sr->availability_trials));
sr->probe_ctx =
GNUNET_FS_download_start (sr->h, sr->uri, sr->meta, NULL, NULL, off,
len, sr->anonymity,
&build_result_set,
&mbc);
search_request_map_offset += todo;
- GNUNET_assert (0 == mbc.put_cnt);
+ GNUNET_assert (0 == mbc.put_cnt); /* #4608 reports this fails? */
GNUNET_assert (total_seen_results >= search_request_map_offset);
if (total_seen_results != search_request_map_offset)
{
static void
do_reconnect (void *cls)
{
- GNUNET_MQ_hd_var_size (result,
- GNUNET_MESSAGE_TYPE_FS_PUT,
- struct ClientPutMessage);
struct GNUNET_FS_SearchContext *sc = cls;
struct GNUNET_MQ_MessageHandler handlers[] = {
- make_result_handler (sc),
+ GNUNET_MQ_hd_var_size (result,
+ GNUNET_MESSAGE_TYPE_FS_PUT,
+ struct ClientPutMessage,
+ sc),
GNUNET_MQ_handler_end ()
};
sc->task = NULL;
- sc->mq = GNUNET_CLIENT_connecT (sc->h->cfg,
+ sc->mq = GNUNET_CLIENT_connect (sc->h->cfg,
"fs",
handlers,
&search_mq_error_handler,