Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-05-21 14:49:17 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Cleanup and refactoring

Browse source
This commit is contained in:
Justin Ethier 2020-08-07 18:56:37 -04:00
parent 275fccd8a6
commit c4f65c993d
1 changed files with 19 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
examples/callbacks/sys.c
View file

@ -3,10 +3,17 @@
#include "sys.h" #include "sys.h"
#include <unistd.h> #include <unistd.h>
/**
* This variable corresponds to the Scheme function (in the generated C file)
* that we wish to call into.
*/
extern object __glo_signal_91done; extern object __glo_signal_91done;
// Scheme function calls into this when it is done. /**
// We store results and longjmp back to where we started. * Scheme function calls into this function when it is done.
* We store results and longjmp back to where we started, at the
* bottom of the trampoline (we only jump once).
*/
void after_call_scm(gc_thread_data *thd, int argc, object k, object result) void after_call_scm(gc_thread_data *thd, int argc, object k, object result)
{ {
// TODO: need to check this, does NOT work if result is a stack obj!! // TODO: need to check this, does NOT work if result is a stack obj!!
@ -14,20 +21,17 @@ void after_call_scm(gc_thread_data *thd, int argc, object k, object result)
longjmp(*(thd->jmp_start), 1); longjmp(*(thd->jmp_start), 1);
} }
// Call into Scheme function /**
* Call into Scheme function
*/
void call_scm(gc_thread_data *thd, object obj) void call_scm(gc_thread_data *thd, object obj)
{ {
mclosure0(after, (function_type)after_call_scm);
((closure)__glo_signal_91done)->fn(thd, 2, __glo_signal_91done, &after, obj);
}
void wait_and_signal(gc_thread_data *thd)
{
// print, wait couple secs, signal SCM side
printf("Hello from C thread\n"); printf("Hello from C thread\n");
sleep(1); sleep(1);
printf("C calling into SCM\n"); printf("C calling into SCM\n");
call_scm(thd, boolean_t);
mclosure0(after, (function_type)after_call_scm);
((closure)__glo_signal_91done)->fn(thd, 2, __glo_signal_91done, &after, obj);
} }
/** /**
@ -42,7 +46,7 @@ void wait_and_signal(gc_thread_data *thd)
* or re-allocated (EG: malloc) before returning it * or re-allocated (EG: malloc) before returning it
* to the C layer. * to the C layer.
*/ */
void c_trampoline(gc_thread_data *parent_thd) void c_trampoline(gc_thread_data *parent_thd, function_type fnc, object arg)
{ {
long stack_size = 100000; long stack_size = 100000;
char *stack_base = (char *)&stack_size; char *stack_base = (char *)&stack_size;
@ -90,7 +94,8 @@ void c_trampoline(gc_thread_data *parent_thd)
if (!setjmp(*(thd.jmp_start))) { if (!setjmp(*(thd.jmp_start))) {
wait_and_signal(&thd); //wait_and_signal(&thd);
fnc(&thd, arg);
} else { } else {
printf("Received: "); printf("Received: ");
Cyc_write(&thd, thd.gc_cont, stdout); Cyc_write(&thd, thd.gc_cont, stdout);
@ -106,7 +111,7 @@ void c_trampoline(gc_thread_data *parent_thd)
*/ */
void *c_thread(void *arg) void *c_thread(void *arg)
{ {
c_trampoline(arg); c_trampoline(arg, (function_type)call_scm, boolean_t);
return NULL; return NULL;
} }