From 64ff82ecf98ceb4725f0f51c73e23d1efc2160bc Mon Sep 17 00:00:00 2001 From: Michael Bebenita Date: Tue, 24 Aug 2010 21:06:56 -0700 Subject: Implemented an lock free queue based on this paper http://www.cs.rochester.edu/~scott/papers/1996_PODC_queues.pdf, the "lock free queue" we had before wasn't lock free at all. --- src/rt/rust_dom.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/rt/rust_dom.h') diff --git a/src/rt/rust_dom.h b/src/rt/rust_dom.h index 34d8c694..44f56cc4 100644 --- a/src/rt/rust_dom.h +++ b/src/rt/rust_dom.h @@ -41,7 +41,7 @@ struct rust_dom hash_map *> _port_proxies; // Incoming messages from other domains. - lock_free_queue _incoming_message_queue; + lock_free_queue _incoming_message_queue; #ifndef __WIN32__ pthread_attr_t attr; @@ -71,7 +71,7 @@ struct rust_dom void free(void *mem, memory_region::memory_region_type type); void send_message(rust_message *message); - void drain_incoming_message_queue(); + void drain_incoming_message_queue(bool process); rust_proxy *get_task_proxy(rust_task *task); void delete_proxies(); rust_proxy *get_port_proxy_synchronized(rust_port *port); -- cgit v1.2.3