}
lm.unlock ();
- dcpomatic_sleep (_period);
+ dcpomatic_sleep_seconds (_period);
}
}
/** @param s Number of seconds to sleep for */
void
-dcpomatic_sleep (int s)
+dcpomatic_sleep_seconds (int s)
{
#ifdef DCPOMATIC_POSIX
sleep (s);
class Log;
struct AVIOContext;
-void dcpomatic_sleep (int);
+void dcpomatic_sleep_seconds (int);
extern std::string cpu_info ();
extern void run_ffprobe (boost::filesystem::path, boost::filesystem::path);
extern std::list<std::pair<std::string, std::string> > mount_info ();
bool error = false;
while (true) {
- dcpomatic_sleep (5);
+ dcpomatic_sleep_seconds (5);
list<shared_ptr<Job> > jobs = JobManager::instance()->get();
start (wx_to_std (wxStandardPaths::Get().GetExecutablePath()));
}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
return true;
}
}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
for (int i = 0; i < N; ++i) {
cout << "\033[1A\033[2K";
if (keep_going) {
while (true) {
- dcpomatic_sleep (3600);
+ dcpomatic_sleep_seconds (3600);
}
}
}
while (jm->work_to_do ()) {
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
while (signal_manager->ui_idle() > 0) {}
JobManager* jm = JobManager::instance ();
while (jm->work_to_do ()) {
while (signal_manager->ui_idle ()) {}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
DCPOMATIC_ASSERT (!jm->errors());
}
return;
}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
/* Add content from successful jobs and report errors */
bool ok = true;
while (jm->work_to_do()) {
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
if (!progress.Pulse()) {
/* user pressed cancel */
BOOST_FOREACH (shared_ptr<Job> i, jm->get()) {
thread* server_thread = new thread (boost::bind (&EncodeServer::run, server));
/* Let the server get itself ready */
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
/* "localhost" rather than "127.0.0.1" here fails on docker; go figure */
EncodeServerDescription description ("127.0.0.1", 1, SERVER_LINK_VERSION);
thread* server_thread = new thread (boost::bind (&EncodeServer::run, server));
/* Let the server get itself ready */
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
/* "localhost" rather than "127.0.0.1" here fails on docker; go figure */
EncodeServerDescription description ("127.0.0.1", 2, SERVER_LINK_VERSION);
thread* server_thread = new thread (boost::bind (&EncodeServer::run, server));
/* Let the server get itself ready */
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
/* "localhost" rather than "127.0.0.1" here fails on docker; go figure */
EncodeServerDescription description ("127.0.0.1", 2, SERVER_LINK_VERSION);
film->make_dcp ();
- dcpomatic_sleep (10);
+ dcpomatic_sleep_seconds (10);
JobManager::drop ();
}
shared_ptr<TestJob> a (new TestJob (film));
JobManager::instance()->add (a);
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
BOOST_CHECK_EQUAL (a->running (), true);
a->set_finished_ok ();
- dcpomatic_sleep (2);
+ dcpomatic_sleep_seconds (2);
BOOST_CHECK_EQUAL (a->finished_ok(), true);
}
shared_ptr<Butler> butler (new Butler(player, AudioMapping(), 6, bind(&PlayerVideo::force, _1, AV_PIX_FMT_RGB24), false, true));
/* Wait for the butler to fill */
- dcpomatic_sleep (5);
+ dcpomatic_sleep_seconds (5);
boon->set_trim_start (ContentTime::from_seconds(5));
butler->seek (DCPTime(), true);
/* Wait for the butler to refill */
- dcpomatic_sleep (5);
+ dcpomatic_sleep_seconds (5);
butler->rethrow ();
}
JobManager* jm = JobManager::instance ();
while (jm->work_to_do ()) {
while (signal_manager->ui_idle ()) {}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
if (jm->errors ()) {
JobManager* jm = JobManager::instance ();
while (jm->work_to_do ()) {
while (signal_manager->ui_idle()) {}
- dcpomatic_sleep (1);
+ dcpomatic_sleep_seconds (1);
}
while (signal_manager->ui_idle ()) {}