#ifndef SYNCHRO_H
#define SYNCHRO_H
-#include <xbt/synchro.h>
+#include <xbt/synchro_core.h>
class mutex_t {
public:
void broadcast() { xbt_cond_broadcast(cond); }
void signal() { xbt_cond_signal(cond); }
void wait(mutex_t& mutex) { xbt_cond_wait(cond, mutex.mutex); }
- void timedwait(mutex_t& mutex, double delay) {
- xbt_cond_timedwait(cond, mutex.mutex, delay);
+ bool timedwait(mutex_t& mutex, double delay) {
+ xbt_ex_t e;
+ TRY {
+ xbt_cond_timedwait(cond, mutex.mutex, delay);
+ }
+ CATCH (e) {
+ if (e.category != timeout_error)
+ RETHROW;
+ xbt_ex_free(e);
+ mutex.acquire();
+ return false; // got a timeout
+ }
+ return true;
}
private: