sync

test/myconetwork.c

@@ -7,7 +7,19 @@
 #include "../src/myco-agent.c"
 #include "../src/myco-serialize.c"
 
+int myco_connect(const char* ip, int port) {
+	struct sockaddr_in address;
+	int mysocket = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, 0);
+	address.sin_family = AF_INET;
+	address.sin_port = htons (port);
+	inet_aton (ip, &address.sin_addr);
+	connect (mysocket, (struct sockaddr *) &address, sizeof (address));
+
+	return mysocket;
+}
+
 int main() {
+/*
     char *agent_name = "DOMAIN1_MYAGENT";
     int agent_message_queue_id = myco_agent_register(agent_name);
 
@@ -20,26 +32,22 @@ int main() {
     // View available resources
     myco_agent_request_resource_list(agent_message_queue_id);
 
-    printf("Sleeping for 10 seconds...\n");
-    sleep(10);
-
-    //TODO: Bandaid solution. This needs to be in the daemon later on.
-    struct sockaddr_in address;
-    int mysocket = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, 0);
-    address.sin_family = AF_INET;
-    address.sin_port = htons (15001);
-    inet_aton ("192.168.0.10", &address.sin_addr);
-    connect (mysocket, (struct sockaddr *) &address, sizeof (address));
-    // Handle indexer
-    char tcp_message[resource_size];
-    //myco_serialize(tcp_message, resource_pointer, resource_size);
-    //send(socket, tcp_message, strlen(tcp_message), 0);
-    printf("Sending data.\n");
-    send(socket, "hello world\n", strlen("hello world\n"), 0);
+    //printf("Sleeping for 10 seconds...\n");
+    //sleep(10);
+*/
 
+    int socket = myco_connect("192.168.0.10", 15001);
+
+    char tcp_message[1024];
+    sprintf(tcp_message, "Hello World!\n");
+    //myco_serialize(tcp_message, resource_pointer, resource_size);
+    send(socket, &tcp_message, strlen(tcp_message), 0);
 
+/*
     // At the end of its runtime the agent unregisters with the daemon.
     myco_agent_unregister(agent_name, agent_message_queue_id);
+*/
+    close (socket);
 
     return EXIT_SUCCESS;
 }