From 00d1465d13980fc3acf650f182ee0723fbda0e06 Mon Sep 17 00:00:00 2001 From: Michael Bebenita Date: Mon, 19 Jul 2010 14:05:18 -0700 Subject: Added a message passing system based on lock free queues for inter-thread communication. Channels now buffer on the sending side, and no longer require blocking when sending. Lots of other refactoring and bug fixes. --- src/rt/circular_buffer.h | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 src/rt/circular_buffer.h (limited to 'src/rt/circular_buffer.h') diff --git a/src/rt/circular_buffer.h b/src/rt/circular_buffer.h new file mode 100644 index 00000000..c0c0da5e --- /dev/null +++ b/src/rt/circular_buffer.h @@ -0,0 +1,30 @@ +/* + * + */ + +#ifndef CIRCULAR_BUFFER_H +#define CIRCULAR_BUFFER_H + +class +circular_buffer : public dom_owned { + static const size_t INITIAL_CIRCULAR_BUFFFER_SIZE_IN_UNITS = 8; + static const size_t MAX_CIRCULAR_BUFFFER_SIZE = 1 << 24; + +public: + rust_dom *dom; + circular_buffer(rust_dom *dom, size_t unit_sz); + ~circular_buffer(); + void transfer(void *dst); + void enqueue(void *src); + void dequeue(void *dst); + bool is_empty(); + +private: + size_t _buffer_sz; + size_t unit_sz; + size_t _next; + size_t _unread; + uint8_t *_buffer; +}; + +#endif /* CIRCULAR_BUFFER_H */ -- cgit v1.2.3