koishi_test.c

#undef NDEBUG

#include <koishi.h>
#include <stdio.h>
#include <stdint.h>
#include <assert.h>
#include <string.h>
#include <stdlib.h>

void *cofunc1(void *data) {
	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);

	char *str = data;
	printf("C: start coroutine (got %s)\n", str);
	printf("C: yielding 1\n");
	str = koishi_yield("Reimu");
	printf("C: resumed 1 (got %s)\n", str);
	printf("C: yielding 2\n");
	str = koishi_yield("Marisa");
	printf("C: resumed 2 (got %s)\n", str);
	printf("C: yielding 3\n");
	str = koishi_yield("Youmu");
	printf("C: resumed 3 (got %s)\n", str);
	printf("C: done\n");
	koishi_die("Bye");
	// return "Bye";
}

void *cofunc_nested(void *data) {
	koishi_coroutine_t *caller = data;
	assert(koishi_state(caller) == KOISHI_IDLE);
	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
	return (void*)42;
}

void *cofunc2(void *data) {
	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
	koishi_coroutine_t co, *c2 = &co;
	koishi_init(c2, 0, cofunc_nested);
	int nested_return = (intptr_t)koishi_resume(c2, koishi_active());
	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
	assert(nested_return == 42);
	koishi_deinit(c2);

	intptr_t i = 0;
	printf("C: start coroutine\n");
	while(1) {
		i += (intptr_t)data;
		i = (2 * i) * (3 * i);
		printf("C: yielding %zi\n", (size_t)i);
		assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
		koishi_yield((void*)i);
		assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
	}

	return NULL;
}

void test1(koishi_coroutine_t *c) {
	char *str;
	koishi_init(c, 128 * 1024, cofunc1);
	printf("O: created coroutine\n");
	printf("O: resume 1\n");
	str = koishi_resume(c, "Hello");
	printf("O: post yield 1 (got %s)\n", str);
	assert(!strcmp(str, "Reimu"));
}

void test2(koishi_coroutine_t *c) {
	intptr_t i;
	koishi_recycle(c, cofunc2);
	assert(koishi_state(c) == KOISHI_SUSPENDED);
	printf("O: recycled coroutine\n");
	printf("O: resume 1\n");
	i = (intptr_t)koishi_resume(c, (void*)1);
	printf("O: post yield 1 (got %zi)\n", (size_t)i);
	printf("O: resume 2\n");
	i = (intptr_t)koishi_resume(c, (void*)2);
	printf("O: post yield 2 (got %zi)\n", (size_t)i);
	assert(koishi_state(c) == KOISHI_SUSPENDED);
}

void *cancelled_caller_test_inner(void *data) {
	koishi_coroutine_t *outer = data;
	koishi_kill(outer, (void*)42);
	koishi_yield(NULL);
	return NULL;
}

void *cancelled_caller_test_outer(void *data) {
	koishi_coroutine_t *inner = data;
	koishi_resume(inner, koishi_active());
	abort();  // unreachable
}

void cancelled_caller_test(int *result) {
	koishi_coroutine_t inner, outer;
	koishi_init(&inner, 0, cancelled_caller_test_inner);
	koishi_init(&outer, 0, cancelled_caller_test_outer);
	*result = (intptr_t)koishi_resume(&outer, &inner);
	koishi_deinit(&inner);
	koishi_deinit(&outer);
}

int main(int argc, char **argv) {
	if(argc != 1) {
		printf("%s takes no arguments.\n", argv[0]);
		return 1;
	}

	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);

	char *str;
	koishi_coroutine_t co, *c = &co;
	test1(&co);
	printf("O: resume 2\n");
	str = koishi_resume(c, "Hakurei");
	printf("O: post yield 2 (got %s)\n", str);
	assert(!strcmp(str, "Marisa"));
	printf("O: resume 3\n");
	str = koishi_resume(c, "Kirisame");
	printf("O: post yield 3 (got %s)\n", str);
	assert(!strcmp(str, "Youmu"));
	printf("O: resume 4\n");
	str = koishi_resume(c, "Konpaku");
	printf("O: done (got %s)\n", str);
	assert(koishi_state(c) == KOISHI_DEAD);

	assert(koishi_state(koishi_active()) == KOISHI_RUNNING);
	test2(&co);
	koishi_deinit(c);

	int result = 0;
	cancelled_caller_test(&result);
	assert(result == 42);

	printf("Done\n");
	return 0;
}