suzanne.soy/racket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[Places] Tag allocate channels.

Browse Source 
mark message array
This commit is contained in:
Kevin Tew 2010-04-29 15:03:08 -06:00
parent 5d804c65cb
commit 1991e9328f
2 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/racket/src/mzmarksrc.c
View File

@ -1379,6 +1379,7 @@ place_async_channel_val {
mark: mark:
Scheme_Place_Async_Channel *pac = (Scheme_Place_Async_Channel *)p; Scheme_Place_Async_Channel *pac = (Scheme_Place_Async_Channel *)p;
int i; int i;
gcMARK2(pac->msgs, gc);
for (i = pac->size; i--; ) for (i = pac->size; i--; )
gcMARK2(pac->msgs[i], gc); gcMARK2(pac->msgs[i], gc);

19
src/racket/src/places.c
View File

@ -909,11 +909,24 @@ static void* GC_master_malloc(size_t size) {
return ptr; return ptr;
} }
static void* GC_master_malloc_tagged(size_t size) {
void *ptr;
#ifdef MZ_PRECISE_GC
void *original_gc;
original_gc = GC_switch_to_master_gc();
#endif
ptr = scheme_malloc_small_tagged(size);
#ifdef MZ_PRECISE_GC
GC_switch_back_from_master(original_gc);
#endif
return ptr;
}
Scheme_Object *scheme_place_async_channel_create() { Scheme_Object *scheme_place_async_channel_create() {
Scheme_Object **msgs; Scheme_Object **msgs;
Scheme_Place_Async_Channel *ch; Scheme_Place_Async_Channel *ch;
ch = GC_master_malloc(sizeof(Scheme_Place_Async_Channel)); ch = GC_master_malloc_tagged(sizeof(Scheme_Place_Async_Channel));
msgs = GC_master_malloc(sizeof(Scheme_Object*) * 8); msgs = GC_master_malloc(sizeof(Scheme_Object*) * 8);
ch->so.type = scheme_place_async_channel_type; ch->so.type = scheme_place_async_channel_type;
@ -931,7 +944,7 @@ Scheme_Object *scheme_place_bi_channel_create() {
Scheme_Object *tmp; Scheme_Object *tmp;
Scheme_Place_Bi_Channel *ch; Scheme_Place_Bi_Channel *ch;
ch = GC_master_malloc(sizeof(Scheme_Place_Bi_Channel)); ch = GC_master_malloc_tagged(sizeof(Scheme_Place_Bi_Channel));
ch->so.type = scheme_place_bi_channel_type; ch->so.type = scheme_place_bi_channel_type;
tmp = scheme_place_async_channel_create(); tmp = scheme_place_async_channel_create();
@ -944,7 +957,7 @@ Scheme_Object *scheme_place_bi_channel_create() {
Scheme_Object *scheme_place_bi_peer_channel_create(Scheme_Object *orig) { Scheme_Object *scheme_place_bi_peer_channel_create(Scheme_Object *orig) {
Scheme_Place_Bi_Channel *ch; Scheme_Place_Bi_Channel *ch;
ch = GC_master_malloc(sizeof(Scheme_Place_Bi_Channel)); ch = GC_master_malloc_tagged(sizeof(Scheme_Place_Bi_Channel));
ch->so.type = scheme_place_bi_channel_type; ch->so.type = scheme_place_bi_channel_type;
ch->sendch = ((Scheme_Place_Bi_Channel *)orig)->recvch; ch->sendch = ((Scheme_Place_Bi_Channel *)orig)->recvch;