Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-07-15 16:57:35 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added collector_cooperated flag

Browse source
This commit is contained in:
Justin Ethier 2015-12-22 22:49:55 -05:00
parent 6a2ed8ff23
commit cc36d6459d
2 changed files with 12 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
gc.c
View file

@ -1335,6 +1335,7 @@ void gc_thread_data_init(gc_thread_data *thd, int mut_num, char *stack_base, lon
thd->last_read = 0; thd->last_read = 0;
thd->mark_buffer_len = 128; thd->mark_buffer_len = 128;
thd->mark_buffer = vpbuffer_realloc(thd->mark_buffer, &(thd->mark_buffer_len)); thd->mark_buffer = vpbuffer_realloc(thd->mark_buffer, &(thd->mark_buffer_len));
thd->collector_cooperated = 0;
if (pthread_mutex_init(&(thd->lock), NULL) != 0) { if (pthread_mutex_init(&(thd->lock), NULL) != 0) {
fprintf(stderr, "Unable to initialize thread mutex\n"); fprintf(stderr, "Unable to initialize thread mutex\n");
exit(1); exit(1);
@ -1373,7 +1374,16 @@ void gc_mutator_thread_runnable(gc_thread_data *thd, object result)
ATOMIC_SET_IF_EQ(&(thd->thread_state), ATOMIC_SET_IF_EQ(&(thd->thread_state),
CYC_THREAD_STATE_BLOCKED, CYC_THREAD_STATE_BLOCKED,
CYC_THREAD_STATE_RUNNABLE); CYC_THREAD_STATE_RUNNABLE);
(((closure)(thd->gc_cont))->fn)(thd, 1, thd->gc_cont, result); if (ATOMIC_GET(&(thd->collector_cooperated))) {
// TODO:
// wait for thd->lock
// unset async flag
// transport result to heap, if necessary (IE, is not a value type)
// set gc_args[0] to result
// longjmp. assumes gc_cont already set by collector
} else {
(((closure)(thd->gc_cont))->fn)(thd, 1, thd->gc_cont, result);
}
} }
//// Unit testing: //// Unit testing:

1
include/cyclone/types.h
View file

@ -85,6 +85,7 @@ struct gc_thread_data_t {
void **mark_buffer; void **mark_buffer;
int mark_buffer_len; int mark_buffer_len;
pthread_mutex_t lock; pthread_mutex_t lock;
int collector_cooperated;
// Data needed for call history // Data needed for call history
char **stack_traces; char **stack_traces;
int stack_trace_idx; int stack_trace_idx;