Changeset 213 in flair-src for trunk/lib/FlairCore/src/Thread_impl.cpp

Timestamp:

Jan 30, 2018, 5:47:12 PM (7 years ago)

Author:

Sanahuja Guillaume

Message:

thread stack size rework
add Matrix class

File:

• trunk/lib/FlairCore/src/Thread_impl.cpp (modified) (8 diffs)

trunk/lib/FlairCore/src/Thread_impl.cpp

@@ -36 +36 @@
 using namespace flair::core;
 
-Thread_impl::Thread_impl(Thread *self, uint8_t priority) {
+Thread_impl::Thread_impl(Thread *self, uint8_t priority,uint32_t stackSize) {
   isRunning = false;
   tobestopped = false;
   is_suspended = false;
   period_set = false;
+  this->stackSize = stackSize;
 
   this->self = self;
@@ -78 +79 @@
 void Thread_impl::Start(void) {
   int status;
-        char errorMsg[256];
-
   isRunning = true;
   tobestopped = false;
   is_suspended = false;
 
+ Printf("Starting thread %s (priority=%i, stack size=%i bytes)\n",self->ObjectName().c_str(), priority,stackSize);
 #ifdef __XENO__
   string th_name =TH_NAME;
 
-#ifdef RT_STACK_SIZE
-  status = rt_task_create(&task_rt, th_name.c_str(), RT_STACK_SIZE,
+  status = rt_task_create(&task_rt, th_name.c_str(), stackSize,
                           (int)priority, T_JOINABLE);
-#else
-  status =
-      rt_task_create(&task_rt, th_name.c_str(), 0, (int)priority, T_JOINABLE);
-#endif // RT_STACK_SIZE
-  if (status != 0) {
+
+  if (status != 0) {
+    char errorMsg[256];
     self->Err("rt_task_create error (%s)\n", strerror_r(-status, errorMsg, sizeof(errorMsg)));
   } else {
@@ -102 +99 @@
   status = rt_task_start(&task_rt, &main_rt, (void *)this);
   if (status != 0) {
+    char errorMsg[256];
     self->Err("rt_task_start error (%s)\n", strerror_r(-status, errorMsg, sizeof(errorMsg)));
   } else {
@@ -115 +113 @@
   }
 
-#ifdef NRT_STACK_SIZE
-  if (pthread_attr_setstacksize(&attr, NRT_STACK_SIZE) != 0) {
+  if (pthread_attr_setstacksize(&attr, stackSize) != 0) {
     self->Err("Error pthread_attr_setstacksize\n");
   }
-#endif // NRT_STACK_SIZE
 
   if (pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED) != 0) {
@@ -320 +316 @@
 
 void Thread_impl::PrintStats(void) {
+  Printf("Stopping thread %s\n", self->ObjectName().c_str()); 
 #ifdef __XENO__
   RT_TASK_INFO info;
@@ -333 +330 @@
   if(last!=0)
 #endif
-    { Printf("Thread::%s :\n", self->ObjectName().c_str()); 
+    {
     if(period_set) {Printf("    period (ns): %lld\n", period);}}
 #ifdef __XENO__
@@ -365 +362 @@
   if (isRunning == true) {
     int status;
-                char errorMsg[256];
-
+  
 #ifdef __XENO__
     status = rt_task_join(&task_rt);
@@ -372 +368 @@
     status = pthread_join(task_nrt, NULL);
 #endif
-    if (status != 0)
+    if (status != 0) {
+      char errorMsg[256];
       self->Err("error %s\n", strerror_r(-status, errorMsg, sizeof(errorMsg)));
+    }
     isRunning = false;
   }