function (err) {
if (err) {
logger.error('Cannot insert the remote video with many retries.', { error: err })
- return finalCallback(err)
}
- return finalCallback()
+ // Do not return the error, continue the process
+ return finalCallback(null)
}
)
}
t.commit().asCallback(function (err) {
if (err) return finalCallback(err)
- logger.info('Remote video %s inserted.', videoToCreateData.videoToCreateData.name)
+ logger.info('Remote video %s inserted.', videoToCreateData.name)
return finalCallback(null)
})
})
function (err) {
if (err) {
logger.error('Cannot update the remote video with many retries.', { error: err })
- return finalCallback(err)
}
- return finalCallback()
+ // Do not return the error, continue the process
+ return finalCallback(null)
}
)
}
function removeRemoteVideo (videoToRemoveData, fromPod, callback) {
// We need the instance because we have to remove some other stuffs (thumbnail etc)
fetchVideo(fromPod.host, videoToRemoveData.remoteId, function (err, video) {
- if (err) return callback(err)
+ // Do not return the error, continue the process
+ if (err) return callback(null)
logger.debug('Removing remote video %s.', video.remoteId)
- video.destroy().asCallback(callback)
+ video.destroy().asCallback(function (err) {
+ // Do not return the error, continue the process
+ if (err) {
+ logger.error('Cannot remove remote video with id %s.', videoToRemoveData.remoteId, { error: err })
+ }
+
+ return callback(null)
+ })
})
}
if (!err) err = new Error('video not found')
logger.error('Cannot load video from id.', { error: err, id: reportData.videoRemoteId })
- return callback(err)
+ // Do not return the error, continue the process
+ return callback(null)
}
logger.debug('Reporting remote abuse for video %s.', video.id)
videoId: video.id
}
- db.VideoAbuse.create(videoAbuseData).asCallback(callback)
+ db.VideoAbuse.create(videoAbuseData).asCallback(function (err) {
+ if (err) {
+ logger.error('Cannot create remote abuse video.', { error: err })
+ }
+
+ return callback(null)
+ })
})
}
// Wait requests between pods
const baseRequestInterval = integrityInterval < constants.REQUESTS_INTERVAL ? integrityInterval : constants.REQUESTS_INTERVAL
const requestsMaxPerInterval = baseRequestInterval / actionInterval
-const intervalsToMakeAllRequests = Math.ceil(requestsMaxPerInterval / constants.REQUESTS_LIMIT)
+const intervalsToMakeAllRequests = Math.ceil(requestsMaxPerInterval / (constants.REQUESTS_LIMIT_PER_POD * numberOfPods))
const waitForBeforeIntegrityCheck = (intervalsToMakeAllRequests * constants.REQUESTS_INTERVAL) + 1000
console.log('Create weight: %d, remove weight: %d.', createWeight, removeWeight)