|
|
@@ -2,18 +2,55 @@
|
|
|
#define __COMPAT_H__
|
|
|
|
|
|
#ifdef WIN32
|
|
|
+#include <errno.h>
|
|
|
#include <time.h>
|
|
|
#include <pthread.h>
|
|
|
+#include <sys/time.h>
|
|
|
|
|
|
#include <windows.h>
|
|
|
|
|
|
-static inline void nanosleep(struct timespec *rgtp, void *__unused)
|
|
|
+#include "miner.h" // for timersub
|
|
|
+
|
|
|
+static inline int nanosleep(const struct timespec *req, struct timespec *rem)
|
|
|
{
|
|
|
- Sleep(rgtp->tv_nsec / 1000000);
|
|
|
+ struct timeval tstart;
|
|
|
+ DWORD msecs;
|
|
|
+
|
|
|
+ gettimeofday(&tstart, NULL);
|
|
|
+ msecs = (req->tv_sec * 1000) + ((999999 + req->tv_nsec) / 1000000);
|
|
|
+
|
|
|
+ if (SleepEx(msecs, true) == WAIT_IO_COMPLETION) {
|
|
|
+ if (rem) {
|
|
|
+ struct timeval tdone, tnow, tleft;
|
|
|
+ tdone.tv_sec = tstart.tv_sec + req->tv_sec;
|
|
|
+ tdone.tv_usec = tstart.tv_usec + ((999 + req->tv_nsec) / 1000);
|
|
|
+ if (tdone.tv_usec > 1000000) {
|
|
|
+ tdone.tv_usec -= 1000000;
|
|
|
+ ++tdone.tv_sec;
|
|
|
+ }
|
|
|
+
|
|
|
+ gettimeofday(&tnow, NULL);
|
|
|
+ if (timercmp(&tnow, &tdone, >))
|
|
|
+ return 0;
|
|
|
+ timersub(&tdone, &tnow, &tleft);
|
|
|
+
|
|
|
+ rem->tv_sec = tleft.tv_sec;
|
|
|
+ rem->tv_nsec = tleft.tv_usec * 1000;
|
|
|
+ }
|
|
|
+ errno = EINTR;
|
|
|
+ return -1;
|
|
|
+ }
|
|
|
+ return 0;
|
|
|
}
|
|
|
-static inline void sleep(unsigned int secs)
|
|
|
+
|
|
|
+static inline int sleep(unsigned int secs)
|
|
|
{
|
|
|
- Sleep(secs * 1000);
|
|
|
+ struct timespec req, rem;
|
|
|
+ req.tv_sec = secs;
|
|
|
+ req.tv_nsec = 0;
|
|
|
+ if (!nanosleep(&req, &rem))
|
|
|
+ return 0;
|
|
|
+ return rem.tv_sec + (rem.tv_nsec ? 1 : 0);
|
|
|
}
|
|
|
|
|
|
enum {
|