Changeset 95 for vtcross/trunk/CR_engines

Timestamp:

02/09/09 16:51:58 (15 years ago)

Author:

trnewman

Message:

Cleaned up the code and put in the hooks for optimization request messages

Files:

• vtcross/trunk/CR_engines/CBR/src/main_cognitive_engine.c (modified) (4 diffs)

vtcross/trunk/CR_engines/CBR/src/main_cognitive_engine.c

@@ -285 +285 @@
     strcpy(buffer, "xml received");
     SendMessage(sockfd, buffer);
-    printf("xml reception done\n");
+    //printf("xml reception done\n");
     
     return 1;
@@ -306 +306 @@
 }
 
+int GetRequest(int sockfd)
+{
+    char buffer[256];
+
+        bzero(buffer,256);
+        ReadMessage(sockfd,buffer);
+
+    return 1;
+}
 
 int GetExperience(int sockfd, int num_rows, int num_cols, 
@@ -536 +545 @@
     // get xml info from server
     GetXMLFromServer(sockfd, uList, pList, oList, &ce_info);
-    print_current_config(uList, pList, oList, &ce_info); 
-
+    printf("Received Radio Operation Profile from Server Successfully.\n\n");
+    //print_current_config(uList, pList, oList, &ce_info); 
+    
+    
     // get experience size from server
     int num_rows, num_cols;
     GetExperienceSize(sockfd, &num_rows, &num_cols);
+    
     // get experience
     int i, j;
-    /*float **past_exp;
-    past_exp = (float **)malloc(sizeof(float)*num_rows);
-    for (i = 0; i< 1; i++){
-        past_exp[i] = (float*)malloc(sizeof(float)*num_cols);
-    }*/
     float past_exp[num_rows][num_cols];
     GetExperience(sockfd, num_rows, num_cols, past_exp);
-    for (i = 0; i < num_rows; i++){
-        printf("experience #%d:\n", i+1);
-        for (j = 0; j < num_cols; j++){
-        printf(" %f", past_exp[i][j]);
-        }
-        printf("\n");
-    }
-   
+    printf("Received Previous Radio Experience from Server Successfully.\n\n");
+    
     // calculate utility
-    
 
     // cbr operation
@@ -567 +567 @@
     num_cols = num_cols + ce_info.numObservables;
     num_cols = num_cols + 1;    // overall utility
-    printf("number of rows: %d, number of columns: %d\n",
-            num_rows, num_cols);
-    RunCBREngine(uList, pList, oList, &ce_info, num_cols, num_rows, 
+   
+    //while(1) {
+        
+        // Wait until request is received from server to perform optimization 
+        //printf("Waiting for Request for optimization from Server\n\n");
+        //GetRequest(sockfd);
+        //printf("Received optimization request from server\n\n");
+        RunCBREngine(uList, pList, oList, &ce_info, num_cols, num_rows, 
             past_exp);    
-    // print out results
-    //int i;
-    printf("search result: ");
-    for (i=0;i<ce_info.numUtilities; i++)
-        printf("%f, ",uList[i].value);
-    for (i=0;i<ce_info.numParameters; i++)
-        printf("%f, ",pList[i].value);
-    for (i=0;i<ce_info.numObservables; i++)
-        printf("%f, ",oList[i].value);
-    printf("\n");
-    
-    // send results back to server
-    SendCEResults(sockfd, uList, pList, oList, &ce_info);
-
-
-  return 0;
-}
+   
+        printf("Sending optimization results to server.\n\n");
+        // send results back to server
+        SendCEResults(sockfd, uList, pList, oList, &ce_info);
+    //}
+    
+    return 0;
+}