Changeset 264 for hvcontrol/src/ProcessIO.cc

Timestamp:

07/27/10 07:27:04 (14 years ago)

Author:

ogrimm

Message:

Removed mutex locking in hvcontrol, use lockf() in Communicate()

File:

• hvcontrol/src/ProcessIO.cc (modified) (8 diffs)

hvcontrol/src/ProcessIO.cc

@@ -30 +30 @@
         {"rate", &ProcessIO::cmd_rate, 1, "<rate>", "Set status refresh rate in Hz"},
         {"timeout", &ProcessIO::cmd_timeout, 1, "<time>", "Set timeout to return from read in seconds"},
-        {"reset", &ProcessIO::cmd_reset, 0, "", "Reset active bias board"},
+        {"reset", &ProcessIO::cmd_reset, 0, "", "Reset active bias boards"},
         {"start", &ProcessIO::cmd_start, 0, "", "Start bias status monitor"},
         {"stop", &ProcessIO::cmd_stop, 0, "", "Stop bias status monitor"},
@@ -53 +53 @@
   FirstBoard  = 0;
   LastBoard   = -1;
-
-  // Initialize mutex for thread synchronisation
-  if (pthread_mutex_init(&Mutex, NULL) != 0) {
-    Message(FATAL, "pthread_mutex_init() failed");
-  }
 
   // DIM console service used in PrintMessage()
@@ -109 +104 @@
   delete calib;
   delete ConsoleOut;    
-  free(ConsoleText);
-  
-  // Destroy mutex
-  if (pthread_mutex_destroy(&Mutex) != 0) Message(ERROR, "pthread_mutex_destroy() failed");
+  free(ConsoleText);  
 }
 
@@ -370 +362 @@
 void ProcessIO::cmd_reset() {
 
-  for (int i=FirstBoard; i<=LastBoard; i++) ResetBoard(i);
+  for (int i=FirstBoard; i<=LastBoard; i++) {
+        if (fHVBoard[i]->Reset() == 1) {
+          PrintMessage("Reset of board %d\n", fHVBoard[i]->GetBoardNumber());
+          PrintBoardStatus(i);
+        }
+        else PrintMessage("Error: Could not reset board %d\n",fHVBoard[i]->GetBoardNumber());
+  }
 }
 
@@ -527 +525 @@
 
   static bool Warned = false;
-  int Ret;
-
-  // Lock because command execution runs in different thread
-  if ((Ret = pthread_mutex_lock(&Mutex)) != 0) {
-        Message(FATAL, "pthread_mutex_lock() failed in commandHandler() (%s)", strerror(Ret));
-  }
 
   for (int i=0; i<NumHVBoards; i++) {
@@ -549 +541 @@
     if (fHVBoard[i]->ResetButton) {
       Message(INFO, "Manual reset of board %d", fHVBoard[i]->GetBoardNumber());
-      ResetBoard(i);
+          fHVBoard[i]->Reset();
     }
     
@@ -558 +550 @@
     for (int j=0; j<NUM_CHAINS; j++) {
       if (fHVBoard[i]->Overcurrent[j]) {
-                Message(WARN, "Warning: Overcurrent in chain %d of board %d",j,fHVBoard[i]->GetBoardNumber());
-                ResetBoard(i);
+                Message(WARN, "Warning: Overcurrent in chain %d of board %d, resetting board",j,fHVBoard[i]->GetBoardNumber());
+                fHVBoard[i]->Reset();
       }
     }
-  }
-  
-  // Unlock
-  if ((Ret = pthread_mutex_unlock(&Mutex)) != 0) {
-        Message(FATAL, "pthread_mutex_lock() failed in commandHandler() (%s)", strerror(Ret));
-  }
-
-}
-
-
-// Send reset to board and clear voltage arrays
-void ProcessIO::ResetBoard(int i) {
-    
-  if (fHVBoard[i]->Reset() == 1) {
-    PrintMessage("Reset of board %d\n", fHVBoard[i]->GetBoardNumber());
-    PrintBoardStatus(i);
-  }
-  else PrintMessage("Error: Could not reset board %d\n",fHVBoard[i]->GetBoardNumber());
-}
+  }  
+}
+
 
 
@@ -597 +573 @@
 
 
-// Command handling (mutex needed because of monitor thread)
+// Command handling
 void ProcessIO::commandHandler() {
 
-  int Ret;
-
-  if ((Ret = pthread_mutex_lock(&Mutex)) != 0) {
-        Message(FATAL, "pthread_mutex_lock() failed in commandHandler() (%s)", strerror(Ret));
-  }
-
   if ((getCommand()==Command) && (*(Command->getString()+Command->getSize()-1)=='\0')) {
-        SendToLog("Command '%s' from %s (ID %d)", Command->getString(), getClientName(), getClientId());
         CommandControl(Command->getString());
-  }
-
-  if ((Ret = pthread_mutex_unlock(&Mutex)) != 0) {
-        Message(FATAL, "pthread_mutex_unlock() failed in commandHandler() (%s)", strerror(Ret));
   }
 }