src/os_list.c

-// SPDX-License-Identifier: BSD-3-Clause
-
-#include "os_list.h"
-#include <stdlib.h>
-#include <unistd.h>
-#include <stdio.h>
-
-os_queue_t *queue_create(void)
-{
-	os_queue_t *queue;
-
-	queue = malloc(sizeof(*queue));
-	if (queue == NULL) {
-		perror("malloc");
-		return NULL;
-	}
-	pthread_mutex_init(&queue->lock, NULL);
-	queue->first =  NULL;
-	queue->last = NULL;
-
-	return queue;
-}
-
-void queue_add(os_queue_t *queue, void *info)
-{
-	os_list_node_t *node;
-
-	node = malloc(sizeof(*node));
-	if (node == NULL) {
-		fprintf(stderr, "[ERROR] %s: Not enough memory\n", __func__);
-		return;
-	}
-
-	node->next = NULL;
-	node->info = info;
-
-	if (queue->last == NULL && queue->first == NULL) {
-		queue->first = node;
-		queue->last = node;
-	} else {
-		queue->last->next = node;
-		queue->last = node;
-	}
-}
-
-os_list_node_t *queue_get(os_queue_t *queue)
-{
-	os_list_node_t *target;
-
-	if (queue == NULL)
-		return NULL;
-	if (queue->first == NULL && queue->last == NULL)
-		return NULL;
-
-	target = queue->first;
-	queue->first = queue->first->next;
-
-	return target;
-}

tests/checker.py

@@ -22,11 +22,23 @@ def check(testname):
     """
     with subprocess.Popen([os.path.join(src, "serial"), testname],
             stdout=subprocess.PIPE) as proc_serial_res:
-        serial_out = str(proc_serial_res.stdout.read()).strip("\n")
+        try:
+            outs, _ = proc_serial_res.communicate(timeout=3)
+            serial_out = str(outs).strip("\n")
+        except subprocess.TimeoutExpired:
+            proc_serial_res.kill()
+            outs, _ = proc_serial_res.communicate()
+            serial_out = ""
     for _ in range(0, 100):
         with subprocess.Popen([os.path.join(src, "parallel"), testname],
                 stdout=subprocess.PIPE) as proc_parallel_res:
-            parallel_out = str(proc_parallel_res.stdout.read()).strip("\n")
+            try:
+                outs, _ = proc_parallel_res.communicate(timeout=3)
+                parallel_out = str(outs).strip("\n")
+            except subprocess.TimeoutExpired:
+                proc_parallel_res.kill()
+                outs, _ = proc_parallel_res.communicate()
+                parallel_out = ""
             if serial_out != parallel_out:
                 return False