nodemailer/wildduck
1
1
Fork 0
mirror of https://github.com/nodemailer/wildduck.git synced 2025-11-17 22:42:09 +08:00
Code Issues Projects Releases Packages Wiki Activity

allow 5000ms for message cursors

Browse source
This commit is contained in:
Andris Reinman 2019-01-24 09:17:44 +02:00
parent bce3d32240
commit 1f222e4abc
7 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/handlers/on-copy.js
View file

@ -55,7 +55,7 @@ module.exports = (server, messageHandler) => (mailbox, update, session, callback
uid: tools.checkRangeQuery(update.messages)
}) // no projection as we need to copy the entire message
.sort([['uid', 1]])
.maxTimeMS(500);
.maxTimeMS(5000);
let copiedMessages = 0;
let copiedStorage = 0;

2
lib/handlers/on-expunge.js
View file

@ -80,7 +80,7 @@ module.exports = (server, messageHandler) => (mailbox, update, session, callback
.collection('messages')
.find(query)
.sort([['uid', 1]])
.maxTimeMS(500);
.maxTimeMS(5000);
let processNext = () => {
cursor.next((err, messageData) => {

2
lib/handlers/on-fetch.js
View file

@ -125,7 +125,7 @@ module.exports = (server, messageHandler, userCache) => (mailbox, options, sessi
.find(query)
.project(projection)
.sort([['uid', 1]])
.maxTimeMS(500);
.maxTimeMS(5000);
let rowCount = 0;
let totalBytes = 0;

2
lib/handlers/on-open.js
View file

@ -38,7 +38,7 @@ module.exports = server => (path, session, callback) => {
uid: true
})
//.sort([['uid', 1]])
.maxTimeMS(500)
.maxTimeMS(5000)
.toArray((err, messages) => {
if (err) {
return callback(err);

2
lib/handlers/on-search.js
View file

@ -359,7 +359,7 @@ module.exports = server => (mailbox, options, session, callback) => {
uid: true,
modseq: true
})
.maxTimeMS(500);
.maxTimeMS(5000);
let highestModseq = 0;
let uidList = [];

4
lib/handlers/on-status.js
View file

@ -39,7 +39,7 @@ module.exports = server => (path, session, callback) => {
$lt: mailboxData.uidNext
}
})
.maxTimeMS(500)
.maxTimeMS(5000)
.count((err, total) => {
if (err) {
return callback(err);
@ -55,7 +55,7 @@ module.exports = server => (path, session, callback) => {
$lt: mailboxData.uidNext
}
})
.maxTimeMS(500)
.maxTimeMS(5000)
.count((err, unseen) => {
if (err) {
return callback(err);

2
lib/handlers/on-store.js
View file

@ -96,7 +96,7 @@ module.exports = server => (mailbox, update, session, callback) => {
flags: true,
modseq: true
})
.maxTimeMS(500)
.maxTimeMS(5000)
.sort([['uid', 1]]);
let shouldExpunge = false;