pu driver tcp

Author: martinfjohansen

README.md

@@ -21,6 +21,7 @@ Device interfaces, drivers and compositions.
    * [Linux File Driver](drivers/disk-linux-file/)
  * processing unit
    * [Linux Socket Driver](drivers/pu-linux-socket/)
+   * [Linux TCP Driver](drivers/pu-linux-tcp/)
 
 
 ## Examples

drivers/pu-linux-tcp/pu-linux-tcp-client.c

@@ -0,0 +1,146 @@
+#include <string.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/tcp.h>
+#include <arpa/inet.h>
+#include <sys/un.h>
+#include <sys/ioctl.h>
+#include <errno.h>
+
+#include <ProcessingUnit.h>
+
+#include "pu-linux-tcp-client.h"
+
+struct ProcessingUnitStructureSocket{
+	int serverSockets;
+	struct sockaddr_in local;
+	int len;
+};
+
+typedef struct ProcessingUnitStructureSocket ProcessingUnitStructureSocket;
+
+_Bool CreateLinuxTCPClient(ProcessingUnitStructure **pu, char *ip, int port){
+	ProcessingUnitStructureSocket *puS;
+	bool success;
+	int ret;
+
+	success = true;
+
+	*pu = malloc(sizeof(ProcessingUnitStructure)); // Alloc #1
+	puS = malloc(sizeof(ProcessingUnitStructureSocket)); // Alloc #1
+	(*pu)->p = puS;
+
+	puS->serverSockets = socket(AF_INET, SOCK_STREAM, 0);
+
+	if(puS->serverSockets != -1){
+    bzero(&puS->local, sizeof(puS->local));
+
+    puS->local.sin_family = AF_INET;
+    puS->local.sin_addr.s_addr = inet_addr(ip);
+    puS->local.sin_port = htons(port);
+
+		puS->len = sizeof(puS->local);
+
+	  ret = connect(puS->serverSockets, (struct sockaddr *)&puS->local, puS->len);
+
+		if(ret == 0){
+		}else{
+			success = false;
+			printf("connect failed: %d\n", errno);
+		}
+	}else{
+		success = false;
+		printf("socket failed: %d\n", errno);
+	}
+
+	//printf("Client success: %d\n", success);
+
+	return success;
+}
+
+void CloseLinuxTCPClient(ProcessingUnitStructure *pu){
+	ProcessingUnitStructureSocket *puS;
+
+	puS = (ProcessingUnitStructureSocket*)pu->p;
+
+	close(puS->serverSockets);
+
+	free(pu); // Free #1
+	free(puS); // Free #2
+}
+
+#include "socklib.c"
+
+void Send(ProcessingUnitStructure *pu, uint8_t *message, size_t messageLength){
+	ProcessingUnitStructureSocket *puS;
+	double length = messageLength;
+	char lengthString[20];
+	uint8_t *buffer;
+	long i;
+
+	puS = (ProcessingUnitStructureSocket*)pu->p;
+
+	sprintf(lengthString, "%15Ld", (long long)messageLength);
+
+	sendAll(puS->serverSockets, (uint8_t*)lengthString, 15);
+	sendAll(puS->serverSockets, message, messageLength);
+}
+
+void Receive(ProcessingUnitStructure *pu, ByteArrayReference *message){
+	ProcessingUnitStructureSocket *puS;
+	double length;
+	char lengthStr[15];
+	_Bool success;
+	uint8_t *buffer;
+	long i;
+
+	puS = (ProcessingUnitStructureSocket*)pu->p;
+
+	success = recvAll(puS->serverSockets, (uint8_t*)lengthStr, 15);
+
+	if(success){
+		length = atof(lengthStr);
+	}
+
+	message->byteArrayLength = length;
+	message->byteArray = malloc(message->byteArrayLength);
+
+	recvAll(puS->serverSockets, message->byteArray, length);
+}
+
+bool Check(ProcessingUnitStructure *pu){
+	ProcessingUnitStructureSocket *puS = (ProcessingUnitStructureSocket*)pu->p;
+	int count;
+	ioctl(puS->serverSockets, FIONREAD, &count);
+	return count > 0;
+}
+
+void Call(ProcessingUnitStructure *pu, uint8_t *s, size_t sLength, ByteArrayReference *d){
+	Send(pu, s, sLength);
+	Receive(pu, d);
+}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

drivers/pu-linux-tcp/pu-linux-tcp-client.h

@@ -0,0 +1,3 @@
+_Bool CreateLinuxTCPClient(ProcessingUnitStructure **client, char *ip, int port);
+
+void CloseLinuxTCPClient(ProcessingUnitStructure *client);

examples/pu-client-demo1/build-linux/launcher.c renamed to examples/pu-client-demo1/build-linux-sockets/launcher.c

@@ -0,0 +1,36 @@
+#include <ProcessingUnit.h>
+
+#include "../../../drivers/pu-linux-tcp/pu-linux-tcp-client.h"
+
+#include <stdlib.h>
+#include <string.h>
+#include <stdio.h>
+#include <stdbool.h>
+#include <math.h>
+
+#include "../program.h"
+
+int main(){
+	int success;
+	int returnCode;
+	ProcessingUnitStructure *client;
+
+	success = CreateLinuxTCPClient(&client, "127.0.0.2", 32343);
+
+	if(success){
+		Program(client);
+
+		CloseLinuxTCPClient(client);
+	}
+
+	if(success){
+		returnCode = 0;
+	}else{
+		returnCode = 1;
+	}
+
+	return !success;
+}
+
+
+

examples/pu-client-demo1/build-linux/make.sh renamed to examples/pu-client-demo1/build-linux-sockets/make.sh

@@ -0,0 +1,12 @@
+# Program 1
+# - Devices
+gcc -c ../../../drivers/pu-linux-tcp/pu-linux-tcp-client.c -O3 -march=native -I ../../../devices/pu/
+
+# - Infrastructural Program
+gcc -c -O3 launcher.c -march=native -I ../../../devices/pu
+
+# Program
+gcc -c -O3 ../program.c -march=native -I ../../../devices/pu
+
+# - Combine the whole program
+gcc -o program program.o launcher.o pu-linux-tcp-client.o -lm -lrt -lpthread