Changeset 218

Timestamp:

03/26/09 20:37:35 (15 years ago)

Author:

trnewman

Message:

Addec CE c++ report.

Location:

vtcross/trunk/src

Files:

• cognitive_engines/CognitiveEngine.cpp (added)
• cognitive_engines/Makefile.am (modified) (1 diff)
• cognitive_engines/cbr_demo.c (modified) (1 diff)
• cognitive_engines/cbr_demo.cpp (added)
• shell/CognitiveRadioShell.cpp (modified) (2 diffs)

vtcross/trunk/src/cognitive_engines/Makefile.am

@@ -1 +1 @@
 INCLUDES = -I$(top_srcdir)/src/include
 
-AM_CFLAGS = -Wall -g
+AM_CXXFLAGS = -Wall -g
 
 bin_PROGRAMS = cbr_demo
 
-cbr_demo_SOURCES = cbr.c cbr_demo.c
-cbr_demo_LDADD = -lsqlite3
+cbr_demo_SOURCES = CognitiveEngine.cpp cbr_demo.cpp
+cbr_demo_LDADD = -lsqlite3 ../lib/socketcomm/libsocketcomm.a
 
-

vtcross/trunk/src/cognitive_engines/cbr_demo.c

@@ -540 +540 @@
     SendMessage(sockfd, "register_engine_cognitive");
     return 1;
-    
-    
-    
-    return 1;
 }
 

vtcross/trunk/src/shell/CognitiveRadioShell.cpp

@@ -111 +111 @@
 
 
-void
-CognitiveRadioShell::SendRadioConfiguration(int32_t socketFD)
+bool
+CognitiveRadioShell::SendRadioConfiguration(int32_t socketfd)
 {
     LOG("Cognitive Radio Shell:: Sending radio configuration to Cognitive Engine.\n");
-}
-
-
-void
+    uint32_t i,j;
+    char counter[55];
+    char var[50];
+
+    // utilities
+    // Send number of utilities
+    sprintf(counter,"%d",radio_info->numUtilities);
+    SendMessage(socketfd,counter);
+    // send utility     
+    for(i = 0; i < radio_info->numUtilities; i++) {
+        SendMessage(socketfd, u[i].name.c_str());
+        SendMessage(socketfd, u[i].units.c_str());
+        SendMessage(socketfd, u[i].goal.c_str());
+        sprintf(var,"%f", u[i].target);
+        SendMessage(socketfd,var);
+    }
+
+    // parameters
+    sprintf(counter,"%i",radio_info->numParameters);
+    SendMessage(socketfd,counter);
+    for(i = 0; i < radio_info->numParameters; i++) {
+        SendMessage(socketfd,p[i].name.c_str());
+        SendMessage(socketfd,p[i].units.c_str());
+        sprintf(var,"%f",p[i].min);
+        SendMessage(socketfd,var);
+        sprintf(var,"%f",p[i].max);
+        SendMessage(socketfd,var);
+        sprintf(var,"%f",p[i].step);
+        SendMessage(socketfd,var);
+
+        sprintf(counter,"%i",p[i].numAffects); 
+        SendMessage(socketfd,counter);
+        for(j = 0; j < p[i].numAffects; j++) {
+            SendMessage(socketfd,p[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd,p[i].affection_list[j].relation.c_str());
+        }
+    }
+
+    // observables
+    sprintf(counter,"%i",radio_info->numObservables);
+    SendMessage(socketfd,counter);
+    for(i = 0; i < radio_info->numObservables; i++) {
+        SendMessage(socketfd,o[i].name.c_str());
+                
+        sprintf(counter,"%i",o[i].numAffects); 
+        SendMessage(socketfd,counter);
+        for(j = 0; j < o[i].numAffects; j++) {
+            SendMessage(socketfd,o[i].affection_list[j].u->name.c_str());
+            SendMessage(socketfd,o[i].affection_list[j].relation.c_str());
+        }
+    }
+        
+    // Receive ACK for utils
+    char buffer[256];
+    memset(buffer, 0, 256); 
+    ReadMessage(socketfd, buffer);
+
+    if(strcmp(buffer, "receive_config_ack") != 0) {
+        LOG("Cognitive Radio Shell:: Unexpected response: %s\n",buffer);
+        return 0;
+    }
+    return 1;
+
+}
+
+bool
 CognitiveRadioShell::SendRadioExperience(int32_t socketFD)
 {
 
     LOG("Cognitive Radio Shell:: Sending radio experience to Cognitive Engine.\n");
+    int32_t numberExp = 4;
+    
+    std::string numberExpString = numberExp;
+    SendMessage(socketFD, numberExp); 
+
+    char buffer[256];
+    memset(buffer, 0, 256); 
+    ReadMessage(socketFD, buffer);
+    if(strcmp(buffer, "receive_exp_ack") != 0) {
+        LOG("Cognitive Radio Shell:: Unexpected response: %s\n",buffer);
+        return 0;
+    }
+    return 1;
 }
 
@@ -214 +289 @@
     size_t item_count = 0;
     size_t affect_count = 0;
-    int32_t attribute_count = 0;
+    uint32_t attribute_count = 0;
     bool match_found = false;