Rev 974 | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed
| Rev 974 | Rev 976 | ||
|---|---|---|---|
| Line 33... | Line 33... | ||
| 33 | 33 | ||
| 34 | int broadcast() { return pthread_cond_broadcast(&myCondition); }; |
34 | int broadcast() { return pthread_cond_broadcast(&myCondition); }; |
| 35 | int wait() { return pthread_cond_wait(&myCondition, &myMutex); }; |
35 | int wait() { return pthread_cond_wait(&myCondition, &myMutex); }; |
| 36 | int wait(int timeout) // Returns ETIMEDOUT on timeout |
36 | int wait(int timeout) // Returns ETIMEDOUT on timeout |
| 37 | { |
37 | { |
| - | 38 | struct timeval timeval; |
|
| - | 39 | ||
| 38 | gettimeofday(& |
40 | gettimeofday(&timeval, NULL); |
| 39 | 41 | ||
| 40 | /* Convert from timeval to timespec */ |
42 | /* Convert from timeval to timespec */ |
| 41 | myTimespec.tv_sec = |
43 | myTimespec.tv_sec = timeval.tv_sec; |
| 42 | myTimespec.tv_nsec = |
44 | myTimespec.tv_nsec = timeval.tv_usec * 1000; |
| 43 | myTimespec.tv_sec += timeout; |
45 | myTimespec.tv_sec += timeout; |
| 44 | 46 | ||
| 45 | return pthread_cond_timedwait(&myCondition, &myMutex, &myTimespec); |
47 | return pthread_cond_timedwait(&myCondition, &myMutex, &myTimespec); |
| 46 | } |
48 | } |
| 47 | 49 | ||
| 48 | protected: |
50 | protected: |
| 49 | pthread_cond_t myCondition; |
51 | pthread_cond_t myCondition; |
| 50 | struct timespec myTimespec; |
52 | struct timespec myTimespec; |
| 51 | struct timeval myTimeval; |
- | |
| - | 53 | ||
| 52 | }; |
54 | }; |
| 53 | 55 | ||
| 54 | 56 | ||
| 55 | #endif /* _SEMAPHORE_H */ |
57 | #endif /* _SEMAPHORE_H */ |
| 56 | 58 | ||