msg: create tests for host msg implementation

Makefile

@@ -25,7 +25,7 @@ include $(ALL_MAKES)
 # by default compile all tests, but allow custom values on per-TARGET_FAMILY basys
 # TODO: prepare tool which will read YAML files and return the components which should be compiled for a given platform
 # for now getting all components and removing tests working only on certain targets
-DEFAULT_COMPONENTS := $(filter-out test_meterfs_% test_virtio test-grlib-multi test-grspw2, $(ALL_COMPONENTS))
+DEFAULT_COMPONENTS := $(filter-out test_meterfs_% test_virtio test-grlib-multi test-grspw2 test-msg, $(ALL_COMPONENTS))
 -include Makefile.$(TARGET_FAMILY)
 
 # create generic targets

Makefile.host

@@ -4,3 +4,4 @@ DEFAULT_COMPONENTS += $(LIBC_UNIT_TESTS)
 DEFAULT_COMPONENTS += test-mprotect
 DEFAULT_COMPONENTS += test-libtinyaes
 DEFAULT_COMPONENTS += test-libalgo
+DEFAULT_COMPONENTS += test-msg

msg/Makefile

@@ -0,0 +1,14 @@
+NAME := msg-server
+LOCAL_SRCS := msg_server.c
+LIBS := libphoenix
+DEP_LIBS := unity
+
+include $(binary.mk)
+
+NAME := test-msg
+LOCAL_SRCS := test_msg.c
+LIBS := libphoenix
+DEP_LIBS := unity
+DEPS := msg-server
+
+include $(binary.mk)

msg/msg_server.c

@@ -0,0 +1,161 @@
+/*
+ * Phoenix-RTOS
+ *
+ * Message (PC version) tests utility
+ *
+ * Copyright 2025 Phoenix Systems
+ * Author: Mateusz Piasecki
+ *
+ *
+ * %LICENSE%
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include <pthread.h>
+
+#include <sys/msg.h>
+
+
+void *echoPortThread(void *arg)
+{
+	char *name = (char *)arg;
+	msg_rid_t rid;
+	uint32_t port;
+	oid_t oid;
+	msg_t msg;
+
+	portCreate(&port);
+
+	oid = (oid_t) { port, 1 };
+	portRegister(port, name, &oid);
+
+	while (1) {
+		if (msgRecv(port, &msg, &rid) < 0) {
+			printf("Error in msgRecv occurred\n");
+			continue;
+		}
+
+		if (msgRespond(port, &msg, rid) < 0) {
+			printf("Error in msgRespond occurred\n");
+			continue;
+		}
+	}
+
+	return NULL;
+}
+
+
+void *dataGreetPortThread(void *arg)
+{
+	char *name = (char *)arg;
+	char *message;
+	char *greeting = "Hello from ";
+	size_t messageSize;
+	msg_rid_t rid;
+	uint32_t port;
+	oid_t oid;
+	msg_t msg;
+
+	messageSize = strlen(greeting) + strlen(name) + 1;
+	message = malloc(messageSize);
+
+	if (message == NULL) {
+		perror("malloc");
+		exit(1);
+	}
+
+	strcpy(message, greeting);
+	strcpy(message + strlen(greeting), name);
+
+	portCreate(&port);
+
+	oid = (oid_t) { port, 1 };
+	portRegister(port, name, &oid);
+
+	while (1) {
+		if (msgRecv(port, &msg, &rid) < 0) {
+			printf("Error in msgRecv occurred\n");
+			continue;
+		}
+
+		if (msg.o.size >= messageSize) {
+			strcpy(msg.o.data, message);
+		}
+
+		if (msgRespond(port, &msg, rid) < 0) {
+			printf("Error in msgRespond occurred\n");
+			continue;
+		}
+	}
+
+	return NULL;
+}
+
+void *rawGreetPortThread(void *arg)
+{
+	char *name = (char *)arg;
+	char *message;
+	char *greeting = "Hello from ";
+	size_t messageSize;
+	msg_rid_t rid;
+	uint32_t port;
+	oid_t oid;
+	msg_t msg;
+
+	messageSize = strlen(greeting) + strlen(name) + 1;
+	message = malloc(messageSize);
+
+	if (message == NULL) {
+		perror("malloc");
+		exit(1);
+	}
+
+	strcpy(message, greeting);
+	strcpy(message + strlen(greeting), name);
+
+	portCreate(&port);
+
+	oid = (oid_t) { port, 1 };
+	portRegister(port, name, &oid);
+
+	while (1) {
+		if (msgRecv(port, &msg, &rid) < 0) {
+			printf("Error in msgRecv occurred\n");
+			continue;
+		}
+
+		strcpy((char *)msg.o.raw, message);
+
+		if (msgRespond(port, &msg, rid) < 0) {
+			printf("Error in msgRespond occurred\n");
+			continue;
+		}
+	}
+
+	return NULL;
+}
+
+
+int main(void)
+{
+	pthread_t thread[5];
+
+	setbuf(stdout, NULL);
+
+	pthread_create(&thread[0], NULL, echoPortThread, "/testport");
+	pthread_create(&thread[1], NULL, echoPortThread, "testport");
+	pthread_create(&thread[2], NULL, echoPortThread, "/");
+	pthread_create(&thread[3], NULL, dataGreetPortThread, "greetport");
+	pthread_create(&thread[3], NULL, rawGreetPortThread, "rawTinker");
+
+	pthread_join(thread[0], NULL);
+	pthread_join(thread[1], NULL);
+	pthread_join(thread[2], NULL);
+	pthread_join(thread[3], NULL);
+	pthread_join(thread[4], NULL);
+
+	return 0;
+}