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

fix: use meisters brilliant worker id formula

Browse Source
This commit is contained in:
Skillz
2023-03-16 12:47:19 -05:00
parent cffd2ece16
commit ae40e69e99
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
packages/gateway/src/manager.ts
View File

@@ -64,18 +64,10 @@ export function createGatewayManager(options: CreateGatewayManagerOptions): Gate
)
},
calculateWorkerId(shardId) {
// Ignore decimal numbers.
let workerId = Math.floor(shardId / gateway.shardsPerWorker)
// If the workerId overflows the maximal allowed workers we by default just use to last worker.
if (workerId >= gateway.totalWorkers) {
// The Id of the last available worker is total -1
workerId = gateway.totalWorkers - 1
}
const workerId = shardId % gateway.shardsPerWorker
logger.debug(
`[Gateway] Calculating workerId: Shard: ${shardId} -> Worker: ${workerId} -> Per Worker: ${gateway.shardsPerWorker} -> Total: ${gateway.totalWorkers}`,
)
return workerId
},
prepareBuckets() {
@@ -165,7 +157,7 @@ export function createGatewayManager(options: CreateGatewayManagerOptions): Gate
},
events: options.events,
requestIdentify: async () => {
await gateway.identify(shardId);
await gateway.identify(shardId)
},
shardIsReady: async () => {
logger.debug(`[Shard] Shard #${shardId} is ready`)