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

Timestamp:

03/30/09 21:38:53 (15 years ago)

Author:

trnewman

Message:

Added libvtcross functionality. Made socketcomm a little more robust. Added libvtcross demo application to illustrate how to use the lib.

Files:

• vtcross/trunk/src/libvtcross/libvtcross.cpp (modified) (1 diff)

vtcross/trunk/src/libvtcross/libvtcross.cpp

@@ -13 +13 @@
 #include "vtcross/libvtcross.h"
 #include "vtcross/common.h"
+#include "vtcross/debug.h"
 
+uint32_t
+ConnectToRemoteComponent()
+{
+        uint32_t socket; 
+    socket = ClientSocket("localhost", "40000");
+    
+    return socket;
+}
+
+/* Given a certain set of observables, ask the radio to find the optimum radio
+ * parameters and return them. 
+ *
+ * TODO I'm a little confused about this function... why would anyone need to
+ * use this?  Shouldn't this be internal to the radio operation? 
+ */
+Parameter* GetOptimalParameters(Observable *radioObservables, uint32_t numObservables) {
+    uint32_t i,socketfd,numParameters;
+    char var[50];
+    char counter[55];
+        char buffer[256];
+
+    socketfd = ConnectToRemoteComponent();
+    SendMessage(socketfd,"request_optimization");
+
+    /* Get number of observables to send.  This information needs to be 
+     * sent to the Cognitive Radio Shell also.   
+     */
+
+    // Send Observables
+    sprintf(counter,"%i",numObservables);
+    SendMessage(socketfd,counter);
+    for(i = 0; i < numObservables; i++) {
+        SendMessage(socketfd,radioObservables[i].name.c_str());
+        sprintf(var,"%f",radioObservables[i].value);
+        SendMessage(socketfd,var);      
+    }
+
+    /* Receive Set of Parameters */
+    memset(buffer, 0, 256);
+    ReadMessage(socketfd, buffer);
+    numParameters = atoi(buffer);
+    Parameter * pList = new Parameter[numParameters];
+    
+    for(size_t i = 0; i < numParameters; i++) {
+        memset(buffer, 0, 256);
+        ReadMessage(socketfd, buffer);
+        pList[i].name = std::string(buffer);
+        
+                memset(buffer, 0, 256);
+        ReadMessage(socketfd, buffer);
+        pList[i].value = atof(buffer);
+    }   
+
+    return pList;
+}