Changeset 11045

Timestamp:

06/16/11 21:27:59 (13 years ago)

Author:

tbretz

Message:

Added possibility to block execution until the state machine has reached a given state.

Location:

trunk/FACT++/src

Files:

• LocalControl.h (modified) (2 diffs)
• RemoteControl.h (modified) (2 diffs)

trunk/FACT++/src/LocalControl.h

@@ -57 +57 @@
         lout << " " << kUnderline << "Specific commands:" << endl;
         lout << kBold << "   st,states    " << kReset << "Display a list of the available states with description." << endl;
+        lout << kBold << "   .s           " << kReset << "Wait for the state-machine to change to the given state." << endl;
+        lout <<          "                "              "     .s <state> [<timeout>]" << endl;
+        lout <<          "                "              "<state>   The state id (see 'states') for which to wait (e.g. 3)" << endl;
+        lout <<          "                "              "<imeout>  A timeout in millisenconds how long to wait (e.g. 500)" << endl;
         lout << endl;
         return true;
@@ -83 +87 @@
             if (fStateMachine)
                 fStateMachine->PrintListOfStates(lout);
+            return true;
+        }
+
+        if (str.substr(0, 3)==".s ")
+        {
+            istringstream in(str.substr(3));
+
+            int state=-100, ms=0;
+            in >> state >> ms;
+
+            if (state==-100)
+                return true;
+
+            const Time timeout = Time()+boost::posix_time::millisec(ms);
+
+            const int target = atoi(str.c_str()+3);
+            while (fStateMachine->GetCurrentState()!=target && timeout>Time())
+                usleep(1);
             return true;
         }

trunk/FACT++/src/RemoteControl.h

@@ -130 +130 @@
         lout << kBold << "   svc,services " << kReset << "List all services in the network." << endl;
         lout << kBold << "   st,states    " << kReset << "List all states in the network." << endl;
+        lout << kBold << "   .s           " << kReset << "Wait for the state-machine to change to the given state." << endl;
+        lout <<          "                "              "     .s <server> <state> [<timeout>]" << endl;
+        lout <<          "                "              "<server>  The server for which state to wait (e.g. FTM_CONTROL)" << endl;
+        lout <<          "                "              "<state>   The state id (see 'states') for which to wait (e.g. 3)" << endl;
+        lout <<          "                "              "<imeout>  A timeout in millisenconds how long to wait (e.g. 500)" << endl;
         lout << endl;
         return true;
@@ -168 +173 @@
         }
 
+        if (str.substr(0, 3)==".s ")
+        {
+            istringstream in(str.substr(3));
+
+            int state=-100, ms=0;
+            string server;
+
+            in >> server >> state >> ms;
+            if (state==-100)
+                return true;
+
+            const ClientList::const_iterator l = fClientList.find(server);
+            if (l==fClientList.end())
+                return true;
+
+            const Time timeout = Time()+boost::posix_time::millisec(ms);
+
+            while (l->second->GetState()!=state && timeout>Time())
+                usleep(1);
+
+            return true;
+        }
+
         if (ReadlineColor::Process(lout, str))
             return true;