Changeset 230 for vtcross/trunk/src/libvtcross/libvtcross.cpp

Timestamp:

04/03/09 13:05:41 (15 years ago)

Author:

trnewman

Message:

Added a loop in the demo to actually adapt.

Added simple adaptation functionality and proper db querying in the CE.

Files:

• vtcross/trunk/src/libvtcross/libvtcross.cpp (modified) (2 diffs)

vtcross/trunk/src/libvtcross/libvtcross.cpp

@@ -25 +25 @@
     
     return socket;
+}
+
+uint32_t
+GetNumObservables()
+{
+        uint32_t socketfd, numObservables;
+    char buffer[256];
+
+    socketfd = ConnectToRemoteComponent();
+    SendMessage(socketfd,"get_number_observables");
+    
+    memset(buffer, 0, 256);
+    ReadMessage(socketfd, buffer);
+    numObservables = atoi(buffer);
+        
+        return numObservables; 
+}
+
+uint32_t
+GetNumUtilities()
+{
+        uint32_t socketfd, numUtilities;
+    char buffer[256];
+
+    socketfd = ConnectToRemoteComponent();
+    SendMessage(socketfd,"get_number_utilities");
+    
+    memset(buffer, 0, 256);
+    ReadMessage(socketfd, buffer);
+    numUtilities = atoi(buffer);
+        
+        return numUtilities; 
 }
 
@@ -106 +138 @@
 }
 
+bool
+UpdateParameterPerformance(Parameter *p, uint32_t numParameters, Observable *o,
+                uint32_t numObservables)
+{
+        char counter[55];
+    char var[50];
+
+    uint32_t socketFD = ConnectToRemoteComponent();
+    SendMessage(socketFD, "update_performance");
+    
+    // Send Parameters 
+    memset(counter, 0, 55);
+    sprintf(counter, "%i", numParameters);
+    SendMessage(socketFD, counter);
+        
+        for(size_t i = 0; i < numParameters; i++) {
+        SendMessage(socketFD,p[i].name.c_str());
+        sprintf(var,"%f",p[i].value);
+        SendMessage(socketFD,var);      
+    }
+    
+        // Send Observables
+    sprintf(counter, "%i", numObservables);
+    SendMessage(socketFD, counter);
+    for(size_t i = 0; i < numObservables; i++) {
+        SendMessage(socketFD, o[i].name.c_str());
+        sprintf(var, "%f", o[i].value);
+        SendMessage(socketFD, var);     
+    }
+}