More logging
This commit is contained in:
parent
ce657bf1d8
commit
5c80d8bf65
@ -1,6 +1,9 @@
|
|||||||
package no.iktdev.streamit.content.common.dto.reader.work
|
package no.iktdev.streamit.content.common.dto.reader.work
|
||||||
|
|
||||||
|
import java.util.*
|
||||||
|
|
||||||
data class ConvertWork(
|
data class ConvertWork(
|
||||||
|
override val workId: String = UUID.randomUUID().toString(),
|
||||||
override val collection: String,
|
override val collection: String,
|
||||||
val language: String,
|
val language: String,
|
||||||
override val inFile: String,
|
override val inFile: String,
|
||||||
|
|||||||
@ -1,6 +1,9 @@
|
|||||||
package no.iktdev.streamit.content.common.dto.reader.work
|
package no.iktdev.streamit.content.common.dto.reader.work
|
||||||
|
|
||||||
|
import java.util.*
|
||||||
|
|
||||||
data class EncodeWork(
|
data class EncodeWork(
|
||||||
|
override val workId: String = UUID.randomUUID().toString(),
|
||||||
override val collection: String,
|
override val collection: String,
|
||||||
override val inFile: String,
|
override val inFile: String,
|
||||||
override val outFile: String,
|
override val outFile: String,
|
||||||
|
|||||||
@ -1,6 +1,9 @@
|
|||||||
package no.iktdev.streamit.content.common.dto.reader.work
|
package no.iktdev.streamit.content.common.dto.reader.work
|
||||||
|
|
||||||
|
import java.util.*
|
||||||
|
|
||||||
data class ExtractWork(
|
data class ExtractWork(
|
||||||
|
override val workId: String = UUID.randomUUID().toString(),
|
||||||
override val collection: String,
|
override val collection: String,
|
||||||
val language: String,
|
val language: String,
|
||||||
override val inFile: String,
|
override val inFile: String,
|
||||||
|
|||||||
@ -3,7 +3,7 @@ package no.iktdev.streamit.content.common.dto.reader.work
|
|||||||
import java.util.UUID
|
import java.util.UUID
|
||||||
|
|
||||||
abstract class WorkBase(
|
abstract class WorkBase(
|
||||||
val workId: String = UUID.randomUUID().toString(),
|
@Transient open val workId: String = UUID.randomUUID().toString(),
|
||||||
@Transient open val collection: String,
|
@Transient open val collection: String,
|
||||||
@Transient open val inFile: String,
|
@Transient open val inFile: String,
|
||||||
@Transient open val outFile: String
|
@Transient open val outFile: String
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
package no.iktdev.streamit.content.encode.runner
|
package no.iktdev.streamit.content.encode.runner
|
||||||
|
|
||||||
|
import mu.KotlinLogging
|
||||||
import no.iktdev.streamit.content.encode.EncodeEnv
|
import no.iktdev.streamit.content.encode.EncodeEnv
|
||||||
import no.iktdev.exfl.observable.ObservableList
|
import no.iktdev.exfl.observable.ObservableList
|
||||||
import no.iktdev.exfl.observable.observableListOf
|
import no.iktdev.exfl.observable.observableListOf
|
||||||
@ -10,6 +11,8 @@ import no.iktdev.streamit.content.encode.progress.Progress
|
|||||||
import no.iktdev.streamit.content.encode.progress.ProgressDecoder
|
import no.iktdev.streamit.content.encode.progress.ProgressDecoder
|
||||||
import java.io.File
|
import java.io.File
|
||||||
|
|
||||||
|
private val logger = KotlinLogging.logger {}
|
||||||
|
|
||||||
class EncodeDaemon(val referenceId: String, val work: EncodeWork, val daemonInterface: IEncodeListener): IDaemon {
|
class EncodeDaemon(val referenceId: String, val work: EncodeWork, val daemonInterface: IEncodeListener): IDaemon {
|
||||||
var outputCache = observableListOf<String>()
|
var outputCache = observableListOf<String>()
|
||||||
private val decoder = ProgressDecoder()
|
private val decoder = ProgressDecoder()
|
||||||
@ -41,6 +44,7 @@ class EncodeDaemon(val referenceId: String, val work: EncodeWork, val daemonInte
|
|||||||
"-hide_banner", "-i", work.inFile, *work.arguments.toTypedArray(), work.outFile,
|
"-hide_banner", "-i", work.inFile, *work.arguments.toTypedArray(), work.outFile,
|
||||||
"-progress", "pipe:1"
|
"-progress", "pipe:1"
|
||||||
) + if (EncodeEnv.allowOverwrite) listOf("-y") else emptyList()
|
) + if (EncodeEnv.allowOverwrite) listOf("-y") else emptyList()
|
||||||
|
logger.info { "$referenceId @ ${work.workId} ${adjustedArgs.joinToString(" ")}" }
|
||||||
return Daemon(EncodeEnv.ffmpeg, this).run(adjustedArgs)
|
return Daemon(EncodeEnv.ffmpeg, this).run(adjustedArgs)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
package no.iktdev.streamit.content.encode.runner
|
package no.iktdev.streamit.content.encode.runner
|
||||||
|
|
||||||
|
import mu.KotlinLogging
|
||||||
import no.iktdev.streamit.content.encode.EncodeEnv
|
import no.iktdev.streamit.content.encode.EncodeEnv
|
||||||
import no.iktdev.exfl.observable.observableListOf
|
import no.iktdev.exfl.observable.observableListOf
|
||||||
import no.iktdev.streamit.content.common.deamon.Daemon
|
import no.iktdev.streamit.content.common.deamon.Daemon
|
||||||
@ -7,6 +8,7 @@ import no.iktdev.streamit.content.common.deamon.IDaemon
|
|||||||
import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork
|
import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork
|
||||||
import no.iktdev.streamit.content.encode.progress.Progress
|
import no.iktdev.streamit.content.encode.progress.Progress
|
||||||
import java.io.File
|
import java.io.File
|
||||||
|
private val logger = KotlinLogging.logger {}
|
||||||
|
|
||||||
class ExtractDaemon(val referenceId: String, val work: ExtractWork, val daemonInterface: IExtractListener): IDaemon {
|
class ExtractDaemon(val referenceId: String, val work: ExtractWork, val daemonInterface: IExtractListener): IDaemon {
|
||||||
var outputCache = observableListOf<String>()
|
var outputCache = observableListOf<String>()
|
||||||
@ -20,6 +22,7 @@ class ExtractDaemon(val referenceId: String, val work: ExtractWork, val daemonIn
|
|||||||
"-hide_banner", "-i", work.inFile, *work.arguments.toTypedArray(), work.outFile,
|
"-hide_banner", "-i", work.inFile, *work.arguments.toTypedArray(), work.outFile,
|
||||||
"-progress", "pipe:1"
|
"-progress", "pipe:1"
|
||||||
) + if (EncodeEnv.allowOverwrite) listOf("-y") else emptyList()
|
) + if (EncodeEnv.allowOverwrite) listOf("-y") else emptyList()
|
||||||
|
logger.info { "$referenceId @ ${work.workId} ${adjustedArgs.joinToString(" ")}" }
|
||||||
return Daemon(EncodeEnv.ffmpeg, this).run(adjustedArgs)
|
return Daemon(EncodeEnv.ffmpeg, this).run(adjustedArgs)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user