#include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "sqlite3.h" //#include "tinyxml.h" //#include "tinyxml.cpp" //#include "tinystr.h" /*#include "../vtcornet/vtcross/trunk/src/include/vtcross/common.h"*/ #include "../vtcornet/vtcross/trunk/src/include/vtcross/components.h" #include "../vtcornet/vtcross/trunk/src/include/vtcross/containers.h" /*#include "../vtcornet/vtcross/trunk/src/include/vtcross/debug.h" #include "../vtcornet/vtcross/trunk/src/include/vtcross/error.h" #include "../vtcornet/vtcross/trunk/src/include/vtcross/socketcomm.h"*/ //#include "../vtcornet/vtcross/branches/wrodgers/ServiceManagementLayer.cpp" /*#include #include #include #include #include //#include #include #include #include #include */ //#include "common.h" //using namespace std; int main(int argc, char *argv[]) { int shell = CreateTCPServerSocket(1979); //sleep(2); int temp = AcceptTCPConnection(shell); // SendMessage(temp, "list_services"); sleep(1); int FD = ClientSocket("127.0.0.1", "2036"); SendMessage(FD, "register_engine_cognitive"); SendMessage(FD, "register_service"); SendMessage(FD, "test_srv"); SendMessage(FD, "list_services"); int FD2 = ClientSocket("127.0.0.1", "2036"); SendMessage(FD2, "register_engine_cognitive"); SendMessage(FD2, "register_service"); SendMessage(FD2, "test_srv1"); SendMessage(FD2, "register_service"); SendMessage(FD2, "test_srv2"); SendMessage(FD2, "list_services"); sleep(1); printf("preread1\n"); char buffer[256]; memset(buffer, 0, 256); SendMessage(temp, "set_active_mission"); SendMessage(temp, "0"); SendMessage(temp, "request_optimization"); SendMessage(temp, "params"); ReadMessage(FD, buffer); printf("preread2\n"); printf("-----buffer1= %s-------\n", buffer); ReadMessage(FD, buffer); printf("-----buffer2= %s-------\n", buffer); memset(buffer, 0, 256); ReadMessage(FD, buffer); printf("-----buffer3= %s-------\n", buffer); SendMessage(FD, "ACK"); SendMessage(FD, "temp"); SendMessage(FD, "raw_data"); ReadMessage(FD2, buffer); printf("-----buffer4= %s-------\n", buffer); ReadMessage(FD2, buffer); printf("-----buffer5= %s-------\n", buffer); ReadMessage(FD2, buffer); printf("-----buffer6= %s-------\n", buffer); SendMessage(FD2, "ACK"); ReadMessage(FD2, buffer); printf("-----buffer7= %s-------\n", buffer); ReadMessage(FD2, buffer); printf("-----buffer8= %s-------\n", buffer); ReadMessage(FD2, buffer); printf("-----buffer9= %s-------\n", buffer); SendMessage(FD2, "ACK"); SendMessage(FD2, "trans"); ReadMessage(temp, buffer); printf("-----buffer10= %s-------\n", buffer); SendMessage(temp, "ACK"); /*ReadMessage(FD, buffer); printf("-----buffer1= %s-------\n", buffer); ReadMessage(FD, buffer); printf("-----buffer2= %s-------\n", buffer); memset(buffer, 0, 256); ReadMessage(FD, buffer); printf("-----buffer3= %s-------\n", buffer); SendMessage(FD, "ACK"); SendMessage(FD, "true"); SendMessage(FD, "data"); ReadMessage(FD2, buffer); printf("-----buffer4= %s-------\n", buffer); ReadMessage(FD2, buffer); printf("-----buffer5= %s-------\n", buffer); memset(buffer, 0, 256); ReadMessage(FD2, buffer); printf("-----buffer6= %s-------\n", buffer); SendMessage(FD2, "ACK"); SendMessage(FD2, "trans"); ReadMessage(temp, buffer); printf("-----buffer7= %s-------\n", buffer); SendMessage(temp, "ACK");*/ //SendMessage(temp, "list_services"); while(true){ char buffer[256]; memset(buffer, 0, 256); ReadMessage(temp, buffer); printf("------%s------\n", buffer);} /*memset(buffer, 0, 256); ReadMessage(temp, buffer); printf("------%s------\n", buffer);*/ }