diff options
author | 2020-11-18 23:26:45 +0100 | |
---|---|---|
committer | 2020-11-18 23:26:45 +0100 | |
commit | 81ddf9b700bc48a1f8e472209f080f9c1d9a9b09 (patch) | |
tree | 8b959d50c5a614cbf9fcb346ed556140374d4b6d /node_modules/mongodb/lib/error.js | |
parent | 1870f3fdf43707a15fda0f609a021f516f45eb63 (diff) | |
download | website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.gz website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.bz2 website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.zip |
rm node_modules
Diffstat (limited to 'node_modules/mongodb/lib/error.js')
-rw-r--r-- | node_modules/mongodb/lib/error.js | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/node_modules/mongodb/lib/error.js b/node_modules/mongodb/lib/error.js deleted file mode 100644 index b2d026c..0000000 --- a/node_modules/mongodb/lib/error.js +++ /dev/null @@ -1,43 +0,0 @@ -'use strict'; - -const MongoNetworkError = require('./core').MongoNetworkError; - -// From spec@https://github.com/mongodb/specifications/blob/f93d78191f3db2898a59013a7ed5650352ef6da8/source/change-streams/change-streams.rst#resumable-error -const GET_MORE_RESUMABLE_CODES = new Set([ - 6, // HostUnreachable - 7, // HostNotFound - 89, // NetworkTimeout - 91, // ShutdownInProgress - 189, // PrimarySteppedDown - 262, // ExceededTimeLimit - 9001, // SocketException - 10107, // NotMaster - 11600, // InterruptedAtShutdown - 11602, // InterruptedDueToReplStateChange - 13435, // NotMasterNoSlaveOk - 13436, // NotMasterOrSecondary - 63, // StaleShardVersion - 150, // StaleEpoch - 13388, // StaleConfig - 234, // RetryChangeStream - 133, // FailedToSatisfyReadPreference - 43 // CursorNotFound -]); - -function isResumableError(error, wireVersion) { - if (error instanceof MongoNetworkError) { - return true; - } - - if (wireVersion >= 9) { - // DRIVERS-1308: For 4.4 drivers running against 4.4 servers, drivers will add a special case to treat the CursorNotFound error code as resumable - if (error.code === 43) { - return true; - } - return error.hasErrorLabel('ResumableChangeStreamError'); - } - - return GET_MORE_RESUMABLE_CODES.has(error.code); -} - -module.exports = { GET_MORE_RESUMABLE_CODES, isResumableError }; |