mirror of
https://github.com/sockspls/badfish
synced 2025-07-12 03:59:15 +00:00
Use new Time class in timed_wait()
And simplify the code. No functional change. Signed-off-by: Marco Costalba <mcostalba@gmail.com>
This commit is contained in:
parent
19540c9ee8
commit
482b5b7ece
3 changed files with 11 additions and 19 deletions
16
src/misc.cpp
16
src/misc.cpp
|
@ -138,19 +138,11 @@ void timed_wait(WaitCondition& sleepCond, Lock& sleepLock, int msec) {
|
||||||
#if defined(_WIN32) || defined(_WIN64)
|
#if defined(_WIN32) || defined(_WIN64)
|
||||||
int tm = msec;
|
int tm = msec;
|
||||||
#else
|
#else
|
||||||
struct timeval t;
|
timespec ts, *tm = &ts;
|
||||||
struct timespec abstime, *tm = &abstime;
|
uint64_t ms = Time::current_time().msec() + msec;
|
||||||
|
|
||||||
gettimeofday(&t, NULL);
|
ts.tv_sec = ms / 1000;
|
||||||
|
ts.tv_nsec = (ms % 1000) * 1000000LL;
|
||||||
abstime.tv_sec = t.tv_sec + (msec / 1000);
|
|
||||||
abstime.tv_nsec = (t.tv_usec + (msec % 1000) * 1000) * 1000;
|
|
||||||
|
|
||||||
if (abstime.tv_nsec > 1000000000LL)
|
|
||||||
{
|
|
||||||
abstime.tv_sec += 1;
|
|
||||||
abstime.tv_nsec -= 1000000000LL;
|
|
||||||
}
|
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
cond_timedwait(sleepCond, sleepLock, tm);
|
cond_timedwait(sleepCond, sleepLock, tm);
|
||||||
|
|
|
@ -57,7 +57,7 @@ public:
|
||||||
static Time current_time() { Time t; t.restart(); return t; }
|
static Time current_time() { Time t; t.restart(); return t; }
|
||||||
|
|
||||||
private:
|
private:
|
||||||
my_time_t t;
|
sys_time_t t;
|
||||||
};
|
};
|
||||||
|
|
||||||
#endif // !defined(MISC_H_INCLUDED)
|
#endif // !defined(MISC_H_INCLUDED)
|
||||||
|
|
12
src/types.h
12
src/types.h
|
@ -62,16 +62,16 @@ typedef unsigned __int64 uint64_t;
|
||||||
|
|
||||||
#if defined(_WIN32) || defined(_WIN64)
|
#if defined(_WIN32) || defined(_WIN64)
|
||||||
# include <sys/timeb.h>
|
# include <sys/timeb.h>
|
||||||
typedef _timeb my_time_t;
|
typedef _timeb sys_time_t;
|
||||||
|
|
||||||
inline void system_time(my_time_t* t) { _ftime(t); }
|
inline void system_time(sys_time_t* t) { _ftime(t); }
|
||||||
inline uint64_t time_to_msec(const my_time_t& t) { return t.time * 1000 + t.millitm; }
|
inline uint64_t time_to_msec(const sys_time_t& t) { return t.time * 1000 + t.millitm; }
|
||||||
#else
|
#else
|
||||||
# include <sys/time.h>
|
# include <sys/time.h>
|
||||||
typedef timeval my_time_t;
|
typedef timeval sys_time_t;
|
||||||
|
|
||||||
inline void system_time(my_time_t* t) { gettimeofday(t, NULL); }
|
inline void system_time(sys_time_t* t) { gettimeofday(t, NULL); }
|
||||||
inline uint64_t time_to_msec(const my_time_t& t) { return t.tv_sec * 1000 + t.tv_usec / 1000; }
|
inline uint64_t time_to_msec(const sys_time_t& t) { return t.tv_sec * 1000 + t.tv_usec / 1000; }
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if defined(_WIN64)
|
#if defined(_WIN64)
|
||||||
|
|
Loading…
Add table
Reference in a new issue