usart: Add client_server_without_response

It's a basic csp client & server topology.

With a server as a listener only and client as a sender only.

Signed-off-by: Gaetan Perrot <gaetan.perrot@spacecubics.com>

Author: moonlight83340

examples/usart/CMakeLists.txt

@@ -1,2 +1,3 @@
 # Add can examples directories
 add_subdirectory(client_server_with_server_response)
+add_subdirectory(client_server_without_server_response)

examples/usart/client_server_without_server_response/CMakeLists.txt

@@ -0,0 +1,11 @@
+# CAN node 1
+add_executable(csp_client_usart
+    csp_client_usart.c
+)
+target_link_libraries(csp_client_usart csp utils Threads::Threads)
+
+# CAN node 2
+add_executable(csp_server_usart
+    csp_server_usart.c
+)
+target_link_libraries(csp_server_usart csp utils Threads::Threads)

examples/usart/client_server_without_server_response/csp_client_usart.c

@@ -0,0 +1,94 @@
+#include <csp/csp_debug.h>
+#include <string.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <time.h>
+
+#include <csp/csp.h>
+#include <csp/drivers/usart.h>
+
+#include "csp_posix_helper.h"
+
+#define SERVER_PORT    10
+#define DEVICE_NAME    "/tmp/pty2"
+#define CLIENT_ADDRESS 1
+#define SERVER_ADDRESS 2
+
+int main(void) {
+	int ret = EXIT_SUCCESS;
+	struct timespec start_time, current_time;
+	unsigned int successful_ping = 0;
+	unsigned int run_duration_in_sec = 3;
+	unsigned int count = 'A';
+
+	/* Set CSP protocol version and address */
+	csp_conf.version = 2;
+
+	/* Initialize CSP */
+	csp_init();
+
+	/* Start CSP router */
+	router_start();
+
+	/* Add USART interface */
+	csp_iface_t * iface = NULL;
+	csp_usart_conf_t conf = {
+		.device = DEVICE_NAME,
+		.baudrate = 115200, /* supported on all platforms */
+		.databits = 8,
+		.stopbits = 1,
+		.paritysetting = 0,
+	};
+	if (csp_usart_open_and_add_kiss_interface(&conf, CSP_IF_KISS_DEFAULT_NAME,
+											  SERVER_ADDRESS,
+											  &iface) != CSP_ERR_NONE) {
+		csp_print("Failed to add KISS interface\n");
+		return -1;
+	}
+	iface->is_default = 1;
+
+	/* Print interface list */
+	csp_print("Available interfaces:\n");
+	csp_iflist_print();
+
+	csp_print("Client started\n");
+
+	while (1) {
+		/* Wait 200 ms between iterations */
+		usleep(200000);
+
+		/* Send a CSP ping to the server */
+		int result = csp_ping(SERVER_ADDRESS, 1000, 100, CSP_O_NONE);
+		csp_print("Ping to address %u, result %d [ms]\n", SERVER_ADDRESS, result);
+		if (result >= 0) {
+			++successful_ping;
+		}
+
+		/* Establish a connection to the server */
+		csp_conn_t * conn = csp_connect(CSP_PRIO_NORM, SERVER_ADDRESS, SERVER_PORT, 1000, CSP_O_NONE);
+		if (conn == NULL) {
+			csp_print("Connection failed\n");
+			ret = EXIT_FAILURE;
+			break;
+		}
+
+		/* Get a CSP packet buffer */
+		csp_packet_t * packet = csp_buffer_get(0);
+		if (packet == NULL) {
+			csp_print("Failed to obtain CSP buffer\n");
+			ret = EXIT_FAILURE;
+			break;
+		}
+
+		/* Fill the packet with data */
+		snprintf((char *)packet->data, CSP_BUFFER_SIZE, "Hello world %c", count++);
+		packet->length = strlen((char *)packet->data) + 1;
+
+		/* Send the packet and close the connection */
+		csp_send(conn, packet);
+		csp_close(conn);
+	}
+
+	return ret;
+}

examples/usart/client_server_without_server_response/csp_server_usart.c

@@ -0,0 +1,87 @@
+#include <csp/csp.h>
+#include <csp/csp_debug.h>
+#include <csp/drivers/usart.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <stdio.h>
+
+#include "csp_posix_helper.h"
+
+#define SERVER_ADDRESS 2
+#define CLIENT_ADDRESS 1
+#define SERVER_PORT    10
+#define DEVICE_NAME    "/tmp/pty1"
+
+void * server(void * param) {
+	(void)param;
+	csp_print("Server task started\n");
+
+	csp_socket_t sock = {0};
+	csp_bind(&sock, CSP_ANY);
+	csp_listen(&sock, 10);
+
+	while (1) {
+		csp_conn_t * conn = csp_accept(&sock, 10000);
+		if (!conn)
+			continue;
+
+		csp_packet_t * packet;
+		while ((packet = csp_read(conn, 50)) != NULL) {
+			if (csp_conn_dport(conn) == SERVER_PORT) {
+				csp_print("Received: %s\n", (char *)packet->data);
+				csp_buffer_free(packet);
+			} else {
+				csp_service_handler(packet);
+			}
+		}
+
+		csp_close(conn);
+	}
+
+	return NULL;
+}
+
+int main(void) {
+	csp_print("Initializing CSP with USART interface...\n");
+
+	/* Set protocol version and address */
+	csp_conf.version = 2;
+
+	/* Init CSP */
+	csp_init();
+
+	/* Start router */
+	router_start();
+
+	/* Add USART interface */
+	csp_iface_t * iface = NULL;
+	csp_usart_conf_t conf = {
+		.device = DEVICE_NAME,
+		.baudrate = 115200, /* supported on all platforms */
+		.databits = 8,
+		.stopbits = 1,
+		.paritysetting = 0,
+	};
+	if (csp_usart_open_and_add_kiss_interface(&conf, CSP_IF_KISS_DEFAULT_NAME,
+											  SERVER_ADDRESS,
+											  &iface) != CSP_ERR_NONE) {
+		csp_print("Failed to add KISS interface\n");
+		return -1;
+	}
+	iface->is_default = 1;
+
+	csp_print("Connection table\r\n");
+	csp_conn_print_table();
+
+	csp_print("Interfaces\r\n");
+	csp_iflist_print();
+
+	csp_pthread_create(server);
+
+	while (1) {
+		sleep(1);
+	}
+
+	return 0;
+}