src/ssb.ebt.c

@@ -412,7 +412,7 @@ void tf_ssb_ebt_get_progress(tf_ssb_ebt_t* ebt, int* in_pending, int* in_total,
 {
 	uv_mutex_lock(&ebt->mutex);
 	_ebt_count_messages(ebt, in_pending, out_pending);
-	*in_total = tf_max(*in_pending, ebt->max_in);
+	*in_total = ebt->max_in;
-	*out_total = tf_max(*out_pending, ebt->max_out);
+	*out_total = ebt->max_out;
 	uv_mutex_unlock(&ebt->mutex);
 }

src/ssb.rpc.c

@@ -1009,7 +1009,9 @@ static void _tf_ssb_connection_send_history_stream(
 			.end_request = end_request,
 		};
 		snprintf(async->author, sizeof(async->author), "%s", author);
-		tf_ssb_connection_schedule_idle(connection, author, _tf_ssb_connection_send_history_stream_callback, async);
+		char key[128];
+		snprintf(key, sizeof(key), "%s:%" PRId64, author, sequence);
+		tf_ssb_connection_schedule_idle(connection, key, _tf_ssb_connection_send_history_stream_callback, async);
 	}
 }