@@ -392,7 +392,7 @@ function stream(source, res) {
392
392
work . finishQueueCallback = false
393
393
util . writeLockFile ( streamdir , work , function ( success ) {
394
394
if ( ! success ) {
395
- log . logres ( "Could not lock streamdir." , work . options , "stream" )
395
+ log . logres ( "Could not write lock " + streamdir , work . options , "stream" )
396
396
return
397
397
}
398
398
util . writeLockFile ( streamfilepart , work , function ( success ) {
@@ -429,7 +429,7 @@ function stream(source, res) {
429
429
430
430
var files = fs . readdirSync ( streamdir )
431
431
432
- log . logres ( "Found " + files . length + " files " , res . options , "stream" )
432
+ log . logres ( "Found " + files . length + " file(s) " , res . options , "stream" )
433
433
434
434
if ( files . length != N ) {
435
435
log . logres ( "Not creating concatenated gzip stream file."
@@ -474,6 +474,7 @@ function stream(source, res) {
474
474
function ( exists ) {
475
475
if ( exists ) {
476
476
log . logres ( "Symlink from single stream part to cat file exists. Not re-creating" , work . options , "stream" )
477
+ util . writeUnlockFile ( streamdir , work , function ( ) { } )
477
478
return
478
479
}
479
480
@@ -493,7 +494,7 @@ function stream(source, res) {
493
494
}
494
495
if ( stderr ) {
495
496
log . logc ( stderr , 160 )
496
- }
497
+ }
497
498
util . writeUnlockFile ( streamdir , work , function ( ) { } )
498
499
} )
499
500
}
0 commit comments