30#include <condition_variable>
37 _arguments{std::make_shared<std::list<std::string>>(arguments)},
40 _createTime{std::chrono::system_clock::now()},
41 _logs{std::make_shared<std::list<std::shared_ptr<
ffmpegkit::
Log>>>()},
44 _logRedirectionStrategy{logRedirectionStrategy} {
49 std::unique_lock<std::mutex> lock(mutex);
50 std::condition_variable condition_variable;
51 const std::chrono::time_point<std::chrono::system_clock> expireTime = std::chrono::system_clock::now() + std::chrono::milliseconds(timeout);
53 while (this->thereAreAsynchronousMessagesInTransmit() && (std::chrono::system_clock::now() < expireTime)) {
54 condition_variable.wait_for(lock, std::chrono::milliseconds(100));
79 const std::chrono::time_point<std::chrono::system_clock> startTime = _startTime;
80 const std::chrono::time_point<std::chrono::system_clock> endTime = _endTime;
82 if (startTime.time_since_epoch() != std::chrono::microseconds(0) && endTime.time_since_epoch() != std::chrono::microseconds(0)) {
83 return std::chrono::duration_cast<std::chrono::milliseconds>(endTime - startTime).count();
98 this->waitForAsynchronousMessagesInTransmit(waitTimeout);
100 if (this->thereAreAsynchronousMessagesInTransmit()) {
101 std::cout <<
"getAllLogsWithTimeout was called to return all logs but there are still logs being transmitted for session id " << _sessionId <<
"." << std::endl;
104 return this->getLogs();
115 this->waitForAsynchronousMessagesInTransmit(waitTimeout);
117 if (this->thereAreAsynchronousMessagesInTransmit()) {
118 std::cout <<
"getAllLogsAsStringWithTimeout was called to return all logs but there are still logs being transmitted for session id " << _sessionId <<
"." << std::endl;
121 return this->getLogsAsString();
129 std::string concatenatedString;
131 std::for_each(_logs->cbegin(), _logs->cend(), [&](std::shared_ptr<ffmpegkit::Log> log) {
132 concatenatedString.append(log->getMessage());
135 return concatenatedString;
139 return this->getAllLogsAsString();
151 return _failStackTrace;
155 return _logRedirectionStrategy;
163 _logs->push_back(log);
168 _startTime = std::chrono::system_clock::now();
172 _returnCode = returnCode;
174 _endTime = std::chrono::system_clock::now();
178 _failStackTrace = error;
180 _endTime = std::chrono::system_clock::now();
static std::atomic< long > sessionIdGenerator(1)
void addSessionToSessionHistory(const std::shared_ptr< ffmpegkit::Session > session)
static ffmpegkit::LogCallback logCallback
void fail(const char *error) override
virtual bool isFFmpeg() const override
void addLog(const std::shared_ptr< ffmpegkit::Log > log) override
std::string getLogsAsString() const override
long getDuration() const override
long getSessionId() const override
std::chrono::time_point< std::chrono::system_clock > getEndTime() const override
std::string getAllLogsAsString() const override
std::string getOutput() const override
ffmpegkit::LogCallback getLogCallback() const override
std::chrono::time_point< std::chrono::system_clock > getCreateTime() const override
AbstractSession(const std::list< std::string > &arguments, const ffmpegkit::LogCallback logCallback, const LogRedirectionStrategy logRedirectionStrategy)
std::shared_ptr< ffmpegkit::ReturnCode > getReturnCode() const override
void waitForAsynchronousMessagesInTransmit(const int timeout) const
std::shared_ptr< std::list< std::shared_ptr< ffmpegkit::Log > > > getAllLogsWithTimeout(const int waitTimeout) const override
void startRunning() override
void complete(const std::shared_ptr< ffmpegkit::ReturnCode > returnCode) override
std::shared_ptr< std::list< std::shared_ptr< ffmpegkit::Log > > > getAllLogs() const override
std::chrono::time_point< std::chrono::system_clock > getStartTime() const override
std::string getFailStackTrace() const override
std::string getCommand() const override
ffmpegkit::SessionState getState() const override
bool thereAreAsynchronousMessagesInTransmit() const override
std::shared_ptr< std::list< std::string > > getArguments() const override
std::shared_ptr< std::list< std::shared_ptr< ffmpegkit::Log > > > getLogs() const override
std::string getAllLogsAsStringWithTimeout(const int waitTimeout) const override
ffmpegkit::LogRedirectionStrategy getLogRedirectionStrategy() const override
virtual bool isMediaInformation() const override
static constexpr int DefaultTimeoutForAsynchronousMessagesInTransmit
virtual bool isFFprobe() const override
static int messagesInTransmit(const long sessionId)
static std::string argumentsToString(std::shared_ptr< std::list< std::string > > arguments)
std::function< void(const std::shared_ptr< ffmpegkit::Log > log)> LogCallback