daenamnu/discordeno
1
0
Fork 0
mirror of https://github.com/discordeno/discordeno.git synced 2026-06-01 08:20:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: delay each shard by 5 seconds

Browse Source
This commit is contained in:
Skillz4Killz
2021-04-14 18:06:41 +00:00
committed by GitHub
parent 70a4a1f955
commit dc27bc3da1
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/ws/spawn_shards.ts
View File

@@ -1,4 +1,5 @@
import { Collection } from "../util/collection.ts";
import { delay } from "../util/utils.ts";
import { ws } from "./ws.ts";
/** Begin spawning shards. */
@@ -46,6 +47,7 @@ export function spawnShards(firstShardId = 0) {
}
}
console.log("BUCKETS", buckets);
// SPREAD THIS OUT TO DIFFERENT CLUSTERS TO BEGIN STARTING UP
buckets.forEach(async (bucket, bucketId) => {
ws.log(
@@ -61,6 +63,12 @@ export function spawnShards(firstShardId = 0) {
while (shardId !== undefined) {
ws.log("DEBUG", "Running while loop in getMembers function.");
if (!ws.createNextShard) {
await delay(100);
continue;
}
ws.createNextShard = false;
await ws.tellClusterToIdentify(clusterId as number, shardId, bucketId);
shardId = queue.shift();
}