diff options
author | Brendan Zabarauskas <bjzaba@yahoo.com.au> | 2014-05-28 15:27:53 -0700 |
---|---|---|
committer | Brendan Zabarauskas <bjzaba@yahoo.com.au> | 2014-05-28 15:27:53 -0700 |
commit | 69a3d100ad6909a65c5df92ae2286cf14f46cdf6 (patch) | |
tree | 759bb18c4c05fe25f41883d1d23496816201e6db /src/components/util/workqueue.rs | |
parent | 50c2af8ef19de31c4b41100f4278c937ced47c64 (diff) | |
download | servo-69a3d100ad6909a65c5df92ae2286cf14f46cdf6.tar.gz servo-69a3d100ad6909a65c5df92ae2286cf14f46cdf6.zip |
Make some scary things in the workqueue module private
Diffstat (limited to 'src/components/util/workqueue.rs')
-rw-r--r-- | src/components/util/workqueue.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/components/util/workqueue.rs b/src/components/util/workqueue.rs index b2b0f7d844e..a9eeacd63a8 100644 --- a/src/components/util/workqueue.rs +++ b/src/components/util/workqueue.rs @@ -77,7 +77,7 @@ static SPIN_COUNT: uint = 1000; impl<QUD:Send,WUD:Send> WorkerThread<QUD,WUD> { /// The main logic. This function starts up the worker and listens for /// messages. - pub fn start(&mut self) { + fn start(&mut self) { loop { // Wait for a start message. let (mut deque, ref_count, queue_data) = match self.port.recv() { @@ -161,9 +161,9 @@ impl<QUD:Send,WUD:Send> WorkerThread<QUD,WUD> { /// A handle to the work queue that individual work units have. pub struct WorkerProxy<'a,QUD,WUD> { - pub worker: &'a mut Worker<WorkUnit<QUD,WUD>>, - pub ref_count: *mut AtomicUint, - pub queue_data: *QUD, + worker: &'a mut Worker<WorkUnit<QUD,WUD>>, + ref_count: *mut AtomicUint, + queue_data: *QUD, } impl<'a,QUD,WUD:Send> WorkerProxy<'a,QUD,WUD> { @@ -192,7 +192,7 @@ pub struct WorkQueue<QUD,WUD> { /// A port on which deques can be received from the workers. port: Receiver<SupervisorMsg<QUD,WUD>>, /// The amount of work that has been enqueued. - pub work_count: uint, + work_count: uint, /// Arbitrary user data. pub data: QUD, } |