mirror of https://github.com/ppy/osu
Use variable for web request concurrency for clarity
This commit is contained in:
parent
b79fdfc12f
commit
e4bad93b66
|
@ -424,7 +424,9 @@ private class BeatmapUpdateQueue
|
||||||
{
|
{
|
||||||
private readonly IAPIProvider api;
|
private readonly IAPIProvider api;
|
||||||
|
|
||||||
private readonly ThreadedTaskScheduler updateScheduler = new ThreadedTaskScheduler(4);
|
private const int update_queue_request_concurrency = 4;
|
||||||
|
|
||||||
|
private readonly ThreadedTaskScheduler updateScheduler = new ThreadedTaskScheduler(update_queue_request_concurrency);
|
||||||
|
|
||||||
public BeatmapUpdateQueue(IAPIProvider api)
|
public BeatmapUpdateQueue(IAPIProvider api)
|
||||||
{
|
{
|
||||||
|
@ -455,10 +457,7 @@ private void perform(BeatmapInfo beatmap, CancellationToken cancellation)
|
||||||
beatmap.OnlineBeatmapID = res.OnlineBeatmapID;
|
beatmap.OnlineBeatmapID = res.OnlineBeatmapID;
|
||||||
};
|
};
|
||||||
|
|
||||||
req.Failure += e =>
|
req.Failure += e => { Logger.Log($"Failed ({e})", LoggingTarget.Database); };
|
||||||
{
|
|
||||||
Logger.Log($"Failed ({e})", LoggingTarget.Database);
|
|
||||||
};
|
|
||||||
|
|
||||||
// intentionally blocking to limit web request concurrency
|
// intentionally blocking to limit web request concurrency
|
||||||
req.Perform(api);
|
req.Perform(api);
|
||||||
|
|
Loading…
Reference in New Issue