int processOneEvent(unsigned int user_timeout, PyObject **res=0, ePyObject additional=ePyObject());
int retval;
int time_offset;
+ int m_is_idle;
pthread_mutex_t recalcLock;
int m_interrupt_requested;
#endif
eMainloop()
- :app_quit_now(0),loop_level(0),retval(0), m_interrupt_requested(0)
+ :app_quit_now(0),loop_level(0),retval(0), m_is_idle(0), m_interrupt_requested(0)
{
existing_loops.push_back(this);
pthread_mutex_init(&recalcLock, 0);
PyObject *poll(SWIG_PYOBJECT(ePyObject) dict, SWIG_PYOBJECT(ePyObject) timeout);
void interruptPoll();
void reset();
+
+ /* m_is_idle needs to be atomic, but it doesn't really matter much, as it's read-only from outside */
+ int isIdle() { return m_is_idle; }
};
/**
else
eDebug("RC thread created successfully");
#endif
+ m_spinner_enabled = 0;
}
DEFINE_REF(gRC);
}
#ifndef SYNC_PAINT
while(rp == wp)
- pthread_cond_wait(&cond, &mutex);
- pthread_mutex_unlock(&mutex);
+ {
+
+ /* when the main thread is non-idle for a too long time without any display output,
+ we want to display a spinner. */
+
+ struct timeval time;
+ struct timespec timeout;
+ gettimeofday(&time, NULL);
+ timeout.tv_sec = time.tv_sec;
+ timeout.tv_nsec = time.tv_usec * 1000;
+
+ if (m_spinner_enabled)
+ timeout.tv_nsec += 100*1000*1000;
+ else
+ timeout.tv_nsec += 500*1000*1000;
+
+ /* yes, this is required. */
+ if (timeout.tv_nsec > 1000*1000*1000)
+ {
+ timeout.tv_nsec -= 1000*1000*1000;
+ timeout.tv_sec++;
+ }
+
+ int idle = 1;
+
+ if (pthread_cond_timedwait(&cond, &mutex, &timeout) == ETIMEDOUT)
+ {
+ if (eApp && !eApp->isIdle())
+ idle = 0;
+ }
+
+ pthread_mutex_unlock(&mutex);
+
+ if (!idle)
+ {
+ enableSpinner();
+ eDebug("main thread is non-idle! display spinner!");
+ } else
+ disableSpinner();
+ }
#endif
}
}
return instance;
}
+void gRC::enableSpinner()
+{
+ if (!m_spinner_dc)
+ {
+ eDebug("no spinner DC!");
+ return;
+ }
+
+ m_spinner_enabled = 1;
+
+ gOpcode o;
+ o.opcode = m_spinner_enabled ? gOpcode::incrementSpinner : gOpcode::enableSpinner;
+ m_spinner_dc->exec(&o);
+}
+
+void gRC::disableSpinner()
+{
+ if (!m_spinner_enabled)
+ return;
+
+ if (!m_spinner_dc)
+ {
+ eDebug("no spinner DC!");
+ return;
+ }
+
+ m_spinner_enabled = 0;
+
+ gOpcode o;
+ o.opcode = gOpcode::disableSpinner;
+ m_spinner_dc->exec(&o);
+}
+
static int gPainter_instances;
gPainter::gPainter(gDC *dc, eRect rect): m_dc(dc), m_rc(gRC::getInstance())
break;
case gOpcode::flush:
break;
+ case gOpcode::enableSpinner:
+ break;
+ case gOpcode::disableSpinner:
+ break;
+ case gOpcode::incrementSpinner:
+ break;
default:
eFatal("illegal opcode %d. expect memory leak!", o->opcode);
}
flip,
notify,
+ enableSpinner, disableSpinner, incrementSpinner,
+
shutdown
} opcode;
eFixedMessagePump<int> m_notify_pump;
void recv_notify(const int &i);
+
+ ePtr<gDC> m_spinner_dc;
+ int m_spinner_enabled;
+
+ void enableSpinner();
+ void disableSpinner();
+
public:
gRC();
virtual ~gRC();
void submit(const gOpcode &o);
Signal0<void> notify;
-
+
+ void setSpinnerDC(gDC *dc) { m_spinner_dc = dc; }
+
static gRC *getInstance();
};