Skip to content

Commit 4405d12

Browse files
committed
update server errors
1 parent 3138615 commit 4405d12

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

src/sdam/topology_description.ts

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -401,7 +401,9 @@ function updateRsFromPrimary(
401401
serverDescriptions.set(
402402
serverDescription.address,
403403
new ServerDescription(serverDescription.address, undefined, {
404-
error: new MongoError('stale')
404+
error: new MongoError(
405+
`primary marked stale due to electionId/setVersion mismatch: server setVersion: ${serverDescription.setVersion}, server electionId: ${serverDescription.electionId}, topology setVersion: ${maxSetVersion}, topology electionId: ${maxElectionId}`
406+
)
405407
})
406408
);
407409

@@ -419,7 +421,9 @@ function updateRsFromPrimary(
419421
serverDescriptions.set(
420422
serverDescription.address,
421423
new ServerDescription(serverDescription.address, undefined, {
422-
error: new MongoError('stale')
424+
error: new MongoError(
425+
`primary marked stale due to electionId/setVersion mismatch: server setVersion: ${serverDescription.setVersion}, server electionId: ${serverDescription.electionId}, topology setVersion: ${maxSetVersion}, topology electionId: ${maxElectionId}`
426+
)
423427
})
424428
);
425429

@@ -444,7 +448,11 @@ function updateRsFromPrimary(
444448
// Reset old primary's type to Unknown.
445449
serverDescriptions.set(
446450
address,
447-
new ServerDescription(server.address, undefined, { error: new MongoError('stale') })
451+
new ServerDescription(server.address, undefined, {
452+
error: new MongoError(
453+
`primary marked stale due to electionId/setVersion mismatch: server setVersion: ${server.setVersion}, server electionId: ${server.electionId}, topology setVersion: ${maxSetVersion}, topology electionId: ${maxElectionId}`
454+
)
455+
})
448456
);
449457

450458
// There can only be one primary

0 commit comments

Comments
 (0)