X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=lib%2Fbase%2Febase.h;h=cb676d0be915236e2dfc579f042880c68f238647;hp=f14d07accdbdae7ebcff45d753fcbcfe01332287;hb=10e7e45ae92d4fe06f70126ed256b87896dbc432;hpb=5518d56f51a8951cc7cea96ee1782ba470380ddc diff --git a/lib/base/ebase.h b/lib/base/ebase.h index f14d07a..cb676d0 100644 --- a/lib/base/ebase.h +++ b/lib/base/ebase.h @@ -21,119 +21,117 @@ extern eApplication* eApp; #ifndef SWIG /* TODO: remove these inlines. */ -static inline bool operator<( const timeval &t1, const timeval &t2 ) +static inline bool operator<( const timespec &t1, const timespec &t2 ) { - return t1.tv_sec < t2.tv_sec || (t1.tv_sec == t2.tv_sec && t1.tv_usec < t2.tv_usec); + return t1.tv_sec < t2.tv_sec || (t1.tv_sec == t2.tv_sec && t1.tv_nsec < t2.tv_nsec); } -static inline bool operator<=( const timeval &t1, const timeval &t2 ) +static inline bool operator<=( const timespec &t1, const timespec &t2 ) { - return t1.tv_sec < t2.tv_sec || (t1.tv_sec == t2.tv_sec && t1.tv_usec <= t2.tv_usec); + return t1.tv_sec < t2.tv_sec || (t1.tv_sec == t2.tv_sec && t1.tv_nsec <= t2.tv_nsec); } -static inline timeval &operator+=( timeval &t1, const timeval &t2 ) +static inline timespec &operator+=( timespec &t1, const timespec &t2 ) { t1.tv_sec += t2.tv_sec; - if ( (t1.tv_usec += t2.tv_usec) >= 1000000 ) + if ( (t1.tv_nsec += t2.tv_nsec) >= 1000000000 ) { t1.tv_sec++; - t1.tv_usec -= 1000000; + t1.tv_nsec -= 1000000000; } return t1; } -static inline timeval operator+( const timeval &t1, const timeval &t2 ) +static inline timespec operator+( const timespec &t1, const timespec &t2 ) { - timeval tmp; + timespec tmp; tmp.tv_sec = t1.tv_sec + t2.tv_sec; - if ( (tmp.tv_usec = t1.tv_usec + t2.tv_usec) >= 1000000 ) + if ( (tmp.tv_nsec = t1.tv_nsec + t2.tv_nsec) >= 1000000000 ) { tmp.tv_sec++; - tmp.tv_usec -= 1000000; + tmp.tv_nsec -= 1000000000; } return tmp; } -static inline timeval operator-( const timeval &t1, const timeval &t2 ) +static inline timespec operator-( const timespec &t1, const timespec &t2 ) { - timeval tmp; + timespec tmp; tmp.tv_sec = t1.tv_sec - t2.tv_sec; - if ( (tmp.tv_usec = t1.tv_usec - t2.tv_usec) < 0 ) + if ( (tmp.tv_nsec = t1.tv_nsec - t2.tv_nsec) < 0 ) { tmp.tv_sec--; - tmp.tv_usec += 1000000; + tmp.tv_nsec += 1000000000; } return tmp; } -static inline timeval operator-=( timeval &t1, const timeval &t2 ) +static inline timespec operator-=( timespec &t1, const timespec &t2 ) { t1.tv_sec -= t2.tv_sec; - if ( (t1.tv_usec -= t2.tv_usec) < 0 ) + if ( (t1.tv_nsec -= t2.tv_nsec) < 0 ) { t1.tv_sec--; - t1.tv_usec += 1000000; + t1.tv_nsec += 1000000000; } return t1; } -static inline timeval &operator+=( timeval &t1, const long msek ) +static inline timespec &operator+=( timespec &t1, const long msek ) { t1.tv_sec += msek / 1000; - if ( (t1.tv_usec += (msek % 1000) * 1000) >= 1000000 ) + if ( (t1.tv_nsec += (msek % 1000) * 1000000) >= 1000000000 ) { t1.tv_sec++; - t1.tv_usec -= 1000000; + t1.tv_nsec -= 1000000000; } return t1; } -static inline timeval operator+( const timeval &t1, const long msek ) +static inline timespec operator+( const timespec &t1, const long msek ) { - timeval tmp; + timespec tmp; tmp.tv_sec = t1.tv_sec + msek / 1000; - if ( (tmp.tv_usec = t1.tv_usec + (msek % 1000) * 1000) >= 1000000 ) + if ( (tmp.tv_nsec = t1.tv_nsec + (msek % 1000) * 1000000) >= 1000000000 ) { tmp.tv_sec++; - tmp.tv_usec -= 1000000; + tmp.tv_nsec -= 1000000; } return tmp; } -static inline timeval operator-( const timeval &t1, const long msek ) +static inline timespec operator-( const timespec &t1, const long msek ) { - timeval tmp; + timespec tmp; tmp.tv_sec = t1.tv_sec - msek / 1000; - if ( (tmp.tv_usec = t1.tv_usec - (msek % 1000)*1000) < 0 ) + if ( (tmp.tv_nsec = t1.tv_nsec - (msek % 1000)*1000000) < 0 ) { tmp.tv_sec--; - tmp.tv_usec += 1000000; + tmp.tv_nsec += 1000000000; } return tmp; } -static inline timeval operator-=( timeval &t1, const long msek ) +static inline timespec operator-=( timespec &t1, const long msek ) { t1.tv_sec -= msek / 1000; - if ( (t1.tv_usec -= (msek % 1000) * 1000) < 0 ) + if ( (t1.tv_nsec -= (msek % 1000) * 1000000) < 0 ) { t1.tv_sec--; - t1.tv_usec += 1000000; + t1.tv_nsec += 1000000000; } return t1; } -static inline long timeout_usec ( const timeval & orig ) +static inline long timeout_usec ( const timespec & orig ) { - timeval now; - gettimeofday(&now,0); + timespec now; + clock_gettime(CLOCK_MONOTONIC, &now); if ( (orig-now).tv_sec > 2000 ) return 2000*1000*1000; - return (orig-now).tv_sec*1000000 + (orig-now).tv_usec; + return (orig-now).tv_sec*1000000 + (orig-now).tv_nsec/1000; } -#endif - class eMainloop; // die beiden signalquellen: SocketNotifier... @@ -144,8 +142,9 @@ class eMainloop; * This class emits the signal \c eSocketNotifier::activate whenever the * event specified by \c req is available. */ -class eSocketNotifier +class eSocketNotifier: iObject { + DECLARE_REF(eSocketNotifier); friend class eMainloop; public: enum { Read=POLLIN, Write=POLLOUT, Priority=POLLPRI, Error=POLLERR, Hungup=POLLHUP }; @@ -154,6 +153,8 @@ private: int fd; int state; int requested; // requested events (POLLIN, ...) + void activate(int what) { /*emit*/ activated(what); } + eSocketNotifier(eMainloop *context, int fd, int req, bool startnow); public: /** * \brief Constructs a eSocketNotifier. @@ -162,11 +163,10 @@ public: * \param req The events to watch to, normally either \c Read or \c Write. You can specify any events that \c poll supports. * \param startnow Specifies if the socketnotifier should start immediately. */ - eSocketNotifier(eMainloop *context, int fd, int req, bool startnow=true); + static eSocketNotifier* create(eMainloop *context, int fd, int req, bool startnow=true) { return new eSocketNotifier(context, fd, req, startnow); } ~eSocketNotifier(); PSignal1 activated; - void activate(int what) { /*emit*/ activated(what); } void start(); void stop(); @@ -175,8 +175,12 @@ public: int getFD() { return fd; } int getRequested() { return requested; } void setRequested(int req) { requested=req; } + + eSmartPtrList m_clients; }; +#endif + class eTimer; // werden in einer mainloop verarbeitet @@ -190,37 +194,27 @@ class eMainloop int loop_level; int processOneEvent(unsigned int user_timeout, PyObject **res=0, ePyObject additional=ePyObject()); int retval; - int time_offset; - pthread_mutex_t recalcLock; - + int m_is_idle; + int m_interrupt_requested; - timeval m_twisted_timer; // twisted timer - + timespec m_twisted_timer; // twisted timer + void addSocketNotifier(eSocketNotifier *sn); void removeSocketNotifier(eSocketNotifier *sn); void addTimer(eTimer* e); void removeTimer(eTimer* e); - void applyTimeOffset(); public: - static void addTimeOffset(int offset); - void addInstanceTimeOffset(int offset); - int getTimeOffset() { return time_offset; } - #ifndef SWIG static ePtrList existing_loops; #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); - } - ~eMainloop() - { - existing_loops.remove(this); - pthread_mutex_destroy(&recalcLock); } + virtual ~eMainloop(); + int looplevel() { return loop_level; } #ifndef SWIG @@ -237,11 +231,14 @@ public: /* run will iterate endlessly until the app is quit, and return the exit code */ int runLoop(); - + /* our new shared polling interface. */ 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; } }; /** @@ -264,6 +261,7 @@ public: } }; +#ifndef SWIG // ... und Timer /** * \brief Gives a callback after a specified timeout. @@ -274,11 +272,11 @@ class eTimer { friend class eMainloop; eMainloop &context; - timeval nextActivation; + timespec nextActivation; long interval; bool bSingleShot; bool bActive; - void addTimeOffset(int); + void activate(); public: /** * \brief Constructs a timer. @@ -290,17 +288,17 @@ public: ~eTimer() { if (bActive) stop(); } PSignal0 timeout; - void activate(); bool isActive() { return bActive; } - timeval &getNextActivation() { return nextActivation; } + + timespec &getNextActivation() { return nextActivation; } void start(long msec, bool b=false); void stop(); void changeInterval(long msek); -#ifndef SWIG - bool operator<(const eTimer& t) const { return nextActivation < t.nextActivation; } -#endif void startLongTimer( int seconds ); + bool operator<(const eTimer& t) const { return nextActivation < t.nextActivation; } }; +#endif // SWIG + #endif