aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/controllers/api
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2017-01-11 18:41:40 +0100
committerChocobozzz <florian.bigard@gmail.com>2017-01-11 18:41:40 +0100
commitedc5e86006bf5e4a2819c380bb65734fe9caa87e (patch)
tree39ae1dfd73772c416ed877698fbd08f88be5367e /server/controllers/api
parentf2cdb86675c3783ee903640b5b6f794fa09cdff2 (diff)
downloadPeerTube-edc5e86006bf5e4a2819c380bb65734fe9caa87e.tar.gz
PeerTube-edc5e86006bf5e4a2819c380bb65734fe9caa87e.tar.zst
PeerTube-edc5e86006bf5e4a2819c380bb65734fe9caa87e.zip
Server: transaction serializable for videos
Diffstat (limited to 'server/controllers/api')
-rw-r--r--server/controllers/api/remote/videos.js2
-rw-r--r--server/controllers/api/videos.js2
2 files changed, 2 insertions, 2 deletions
diff --git a/server/controllers/api/remote/videos.js b/server/controllers/api/remote/videos.js
index b9494f602..c45a86dbb 100644
--- a/server/controllers/api/remote/videos.js
+++ b/server/controllers/api/remote/videos.js
@@ -203,7 +203,7 @@ function updateRemoteVideo (videoAttributesToUpdate, fromPod, finalCallback) {
203 waterfall([ 203 waterfall([
204 204
205 function startTransaction (callback) { 205 function startTransaction (callback) {
206 db.sequelize.transaction().asCallback(function (err, t) { 206 db.sequelize.transaction({ isolationLevel: 'SERIALIZABLE' }).asCallback(function (err, t) {
207 return callback(err, t) 207 return callback(err, t)
208 }) 208 })
209 }, 209 },
diff --git a/server/controllers/api/videos.js b/server/controllers/api/videos.js
index df068f961..55d671f5b 100644
--- a/server/controllers/api/videos.js
+++ b/server/controllers/api/videos.js
@@ -264,7 +264,7 @@ function updateVideo (req, res, finalCallback) {
264 waterfall([ 264 waterfall([
265 265
266 function startTransaction (callback) { 266 function startTransaction (callback) {
267 db.sequelize.transaction().asCallback(function (err, t) { 267 db.sequelize.transaction({ isolationLevel: 'SERIALIZABLE' }).asCallback(function (err, t) {
268 return callback(err, t) 268 return callback(err, t)
269 }) 269 })
270 }, 270 },