Changeset 307 in flair-src for trunk/lib/FlairCore

Timestamp:

Mar 8, 2019, 10:30:25 AM (6 years ago)

Author:

Sanahuja Guillaume

Message:

resove bug in times

Location:

trunk/lib/FlairCore

Files:

• . (modified) (1 prop)
• src/Thread.cpp (modified) (3 diffs)
• src/Thread_impl.cpp (modified) (3 diffs)

trunk/lib/FlairCore/src/Thread.cpp

@@ -98 +98 @@
 #else
   Time current = GetTime();
+
   if (current < time) {
     //usleep((time - current) / 1000);
+    Time tmp=time - current;
     struct timespec req;
-    req.tv_nsec = time - current;
-    req.tv_sec = req.tv_nsec / 1000000000;
-    req.tv_nsec %= 1000000000;
+    req.tv_sec = tmp / (Time)1000000000;
+    req.tv_nsec = tmp%(Time)1000000000;
     struct timespec rem;
     if(nanosleep(&req,&rem)!=0) Err("error in nanosleep\n");//todo, handle EINTR
@@ -113 +114 @@
 
 void Thread::SleepMS(uint32_t time) const {
-#ifdef __XENO__
-  int status = rt_task_sleep(time * 1000 * 1000);
-  if (status != 0) {
-                char errorMsg[256];
-    Err("erreur rt_task_sleep (%s)\n", strerror_r(-status, errorMsg, sizeof(errorMsg)));
-        }
-#else
-  //usleep(time * 1000);
-  struct timespec req;
-  req.tv_nsec = time * 1000000;
-  req.tv_sec = req.tv_nsec / 1000000000;
-  req.tv_nsec %= 1000000000;
-  struct timespec rem;
-  if(nanosleep(&req,&rem)!=0) Err("error in nanosleep\n");//todo, handle EINTR
-#endif
+    SleepUS(time*1000);
 }
 
@@ -140 +127 @@
   //usleep(time);
   struct timespec req;
-  req.tv_nsec = time * 1000;
-  req.tv_sec = req.tv_nsec / 1000000000;
-  req.tv_nsec %= 1000000000;
+  req.tv_sec = (Time)time / (Time)1000;
+  req.tv_nsec = (Time)time%(Time)1000;
   struct timespec rem;
   if(nanosleep(&req,&rem)!=0) Err("error in nanosleep\n");//todo, handle EINTR

trunk/lib/FlairCore/src/Thread_impl.cpp

@@ -174 +174 @@
 
 #ifdef __XENO__
-  int status = rt_task_set_periodic(&task_rt, TM_NOW, period * 1000);
+  int status = rt_task_set_periodic(&task_rt, TM_NOW, (Time)period * (Time)1000);
   if (status != 0) {
                 char errorMsg[256];
@@ -181 +181 @@
 #else
   if (period_set) {
-    next_time -= period;
-    next_time += period * 1000;
-  } else next_time=GetTime()+period*1000;
-#endif
-  this->period = period * 1000;
+    next_time -= (Time)period;
+    next_time += (Time)period * (Time)1000;
+  } else next_time=GetTime()+(Time)period*(Time)1000;
+#endif
+  this->period = (Time)period * (Time)1000;
   period_set = true;
 }
@@ -192 +192 @@
 
 void Thread_impl::SetPeriodMS(uint32_t period) {
-  if (period == 0) {
-    self->Err("Period must be>0\n");
-    return;
-  }
-
-#ifdef __XENO__
-  int status = rt_task_set_periodic(&task_rt, TM_NOW, period * 1000 * 1000);
-  if (status != 0) {
-                char errorMsg[256];
-    self->Err("Error rt_task_set_periodic %s\n", strerror_r(-status, errorMsg, sizeof(errorMsg)));
-        }
-#else
-  if (period_set) {
-    next_time -= period;
-    next_time += period * 1000 * 1000;
-  } else next_time=GetTime()+period*1000*1000;
-#endif
-  this->period = period * 1000 * 1000;
-  period_set = true;
+  SetPeriodUS(period*1000);
 }