data flow

src/myco-modules-default.c

@@ -43,8 +43,8 @@ myco_network_fetch_resource(void *local_pointer, pid_t local_pid, int size) {
 	char *resource;
 
 	printf ("\e[2J");
-	create_socket=socket (AF_INET, SOCK_STREAM, 0);
-	setsockopt( create_socket, SOL_SOCKET,
+	create_socket = socket (AF_INET, SOCK_STREAM, 0);
+	setsockopt(create_socket, SOL_SOCKET,
 	    SO_REUSEADDR, &y, sizeof(int));
 	address.sin_family = AF_INET;
 	address.sin_addr.s_addr = INADDR_ANY;
@@ -56,9 +56,15 @@ myco_network_fetch_resource(void *local_pointer, pid_t local_pid, int size) {
 	}
 	listen (create_socket, 5);
 	addrlen = sizeof (struct sockaddr_in);
+
+	// Receive data
+	printf("Waiting to receive data.\n");
+	ssize_t received = recv(create_socket, buffer, size, 0);
+	printf("Received %s\n", buffer);
 	
 	// Read memory over network
 
+
 	// Write memory to Agent
 	if (myco_write_memory(local_pid, local_pointer, size, (void *)resource_pointer, size) == -1) {
 		printf("ERROR: %s\n", strerror(errno));

test/myconetwork.c

@@ -24,7 +24,6 @@ int main() {
     sleep(10);
 
     //TODO: Bandaid solution. This needs to be in the daemon later on.
-    printf("Sending data.\n");
     struct sockaddr_in address;
     int mysocket = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, 0);
     address.sin_family = AF_INET;
@@ -33,8 +32,11 @@ int main() {
     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);
+    //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);
+
 
     // At the end of its runtime the agent unregisters with the daemon.
     myco_agent_unregister(agent_name, agent_message_queue_id);

test/myconetwork2.c

@@ -13,8 +13,6 @@ int main() {
     // View available resources
     myco_agent_request_resource_list(agent_message_queue_id);
 
-    printf("Requesting Resource 1 from different node...\n");
-
     // MYCO fetch
     // #MYCO fetch("RESOURCE_1")
     char *resource_name = "RESOURCE_1";