Show
Ignore:
Timestamp:
06/16/09 11:03:58 (15 years ago)
Author:
wrodgers
Message:

Updating SML functionality

Files:
1 modified

Legend:

Unmodified
Added
Removed

  • vtcross/branches/wrodgers/src/service_management_layer/sml_demo.cpp

    r200 r277  
    1 /* Virginia Tech Cognitive Radio Open Source Systems 
    2  * Virginia Tech, 2009 
    3  * 
    4  * TODO LICENSE INFORMATION GOES HERE 
    5  */ 
    6  
    7 /* TODO DESCRIPTION OF FILE. 
    8  * 
    9  * This file is a temporary demo of a service management layer using some of  
    10  * our socket communication functions. This is *not* an actual implementation  
    11  * of our defined ServiceManagement class. 
    12  */ 
    13  
    14  
    151#include <cstdlib> 
    162#include <cstring> 
    173#include <stdint.h> 
     4#include <string> 
     5#include <stdlib.h>  
     6 
     7#include <arpa/inet.h> 
     8#include <iostream> 
     9#include <netinet/in.h> 
     10#include <netdb.h> 
     11#include <fcntl.h> 
     12#include <sys/ioctl.h> 
     13#include <sys/mman.h> 
     14#include <sys/socket.h> 
     15#include <sys/types.h> 
     16#include <sys/wait.h> 
     17 
     18#include "sqlite3.h" 
     19 
     20 
     21 
     22//#include "tinyxml.h" 
     23//#include "tinyxml.cpp" 
     24//#include "tinystr.h" 
    1825 
    1926#include "vtcross/common.h" 
    … …  
    2532 
    2633 
    27 int32_t  
    28 main(int32_t argc, char *argv[]) 
    29 { 
    30     if(argc < 3) 
    31        ERROR(1, "Usage: %s hostname port\n", argv[0]); 
     34 
     35/*#include <stdio.h> 
     36#include <sys/types.h> 
     37#include <sys/socket.h> 
     38#include <netinet/in.h> 
     39#include <netdb.h> 
     40//#include <iostream> 
     41#include <stdlib.h> 
     42#include <string.h> 
     43#include <sqlite3.h> 
     44#include <sqlite3ext.h>*/ 
     45 
     46//#include "common.h" 
     47 
     48//using namespace std; 
     49 
     50 
     51int main(int argc, char *argv[]) 
     52{    
     53    int shell = CreateTCPServerSocket(1979); 
     54    //sleep(2); 
     55    int temp = AcceptTCPConnection(shell);  
     56   // SendMessage(temp, "list_services"); 
     57    sleep(1); 
     58    int FD = ClientSocket("127.0.0.1", "2036");  
     59    SendMessage(FD, "register_engine_cognitive");    
     60    SendMessage(FD, "register_service"); 
     61    SendMessage(FD, "test_srv");  
     62    SendMessage(FD, "list_services"); 
     63    int FD2 = ClientSocket("127.0.0.1", "2036");  
     64    SendMessage(FD2, "register_engine_cognitive");    
     65    SendMessage(FD2, "register_service"); 
     66    SendMessage(FD2, "test_srv1");  
     67    SendMessage(FD2, "register_service"); 
     68    SendMessage(FD2, "test_srv2"); 
     69    SendMessage(FD2, "list_services"); 
     70    sleep(1); 
     71    printf("preread1\n"); 
     72 
     73    char buffer[256]; 
     74    memset(buffer, 0, 256); 
     75 
     76    SendMessage(temp, "set_active_mission"); 
     77    SendMessage(temp, "0");  
     78    SendMessage(temp, "request_optimization"); 
     79    SendMessage(temp, "params"); 
     80    ReadMessage(FD, buffer); 
     81    printf("preread2\n"); 
     82    printf("-----buffer1= %s-------\n", buffer); 
     83    ReadMessage(FD, buffer); 
     84    printf("-----buffer2= %s-------\n", buffer); 
     85    memset(buffer, 0, 256); 
     86    ReadMessage(FD, buffer); 
     87    printf("-----buffer3= %s-------\n", buffer); 
     88    SendMessage(FD, "ACK"); 
     89    SendMessage(FD, "temp"); 
     90    SendMessage(FD, "raw_data"); 
     91    ReadMessage(FD2, buffer); 
     92    printf("-----buffer4= %s-------\n", buffer); 
     93    ReadMessage(FD2, buffer); 
     94    printf("-----buffer5= %s-------\n", buffer); 
     95    ReadMessage(FD2, buffer); 
     96    printf("-----buffer6= %s-------\n", buffer); 
     97    SendMessage(FD2, "ACK"); 
     98    ReadMessage(FD2, buffer); 
     99    printf("-----buffer7= %s-------\n", buffer); 
     100    ReadMessage(FD2, buffer); 
     101    printf("-----buffer8= %s-------\n", buffer); 
     102    ReadMessage(FD2, buffer); 
     103    printf("-----buffer9= %s-------\n", buffer); 
     104    SendMessage(FD2, "ACK"); 
     105    SendMessage(FD2, "trans"); 
     106    ReadMessage(temp, buffer); 
     107    printf("-----buffer10= %s-------\n", buffer); 
     108    SendMessage(temp, "ACK"); 
     109    /*ReadMessage(FD, buffer); 
     110    printf("-----buffer1= %s-------\n", buffer); 
     111    ReadMessage(FD, buffer); 
     112    printf("-----buffer2= %s-------\n", buffer); 
     113    memset(buffer, 0, 256); 
     114    ReadMessage(FD, buffer); 
     115    printf("-----buffer3= %s-------\n", buffer); 
     116    SendMessage(FD, "ACK"); 
     117    SendMessage(FD, "true"); 
     118    SendMessage(FD, "data"); 
     119    ReadMessage(FD2, buffer); 
     120    printf("-----buffer4= %s-------\n", buffer); 
     121    ReadMessage(FD2, buffer); 
     122    printf("-----buffer5= %s-------\n", buffer); 
     123    memset(buffer, 0, 256); 
     124    ReadMessage(FD2, buffer); 
     125    printf("-----buffer6= %s-------\n", buffer); 
     126    SendMessage(FD2, "ACK"); 
     127    SendMessage(FD2, "trans"); 
     128    ReadMessage(temp, buffer); 
     129    printf("-----buffer7= %s-------\n", buffer); 
     130    SendMessage(temp, "ACK");*/ 
     131    
    32132     
    33     ServiceManagementLayer sml; 
    34133 
    35     LOG("Waiting for signal...\n"); 
    36     while(1) { 
    37 //        policyEngine.WaitForSignal(); 
    38     } 
    39  
    40     return 0; 
     134    //SendMessage(temp, "list_services");   
     135    while(true){    
     136    char buffer[256]; 
     137    memset(buffer, 0, 256); 
     138    ReadMessage(temp, buffer); 
     139    printf("------%s------\n", buffer);} 
     140   /*memset(buffer, 0, 256); 
     141    ReadMessage(temp, buffer); 
     142    printf("------%s------\n", buffer);*/ 
    41143} 
    42