From 69a3d100ad6909a65c5df92ae2286cf14f46cdf6 Mon Sep 17 00:00:00 2001 From: Brendan Zabarauskas Date: Wed, 28 May 2014 15:27:53 -0700 Subject: [PATCH] Make some scary things in the workqueue module private --- src/components/util/workqueue.rs | 10 +++++----- 1 file 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 WorkerThread { /// 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 WorkerThread { /// A handle to the work queue that individual work units have. pub struct WorkerProxy<'a,QUD,WUD> { - pub worker: &'a mut Worker>, - pub ref_count: *mut AtomicUint, - pub queue_data: *QUD, + worker: &'a mut Worker>, + ref_count: *mut AtomicUint, + queue_data: *QUD, } impl<'a,QUD,WUD:Send> WorkerProxy<'a,QUD,WUD> { @@ -192,7 +192,7 @@ pub struct WorkQueue { /// A port on which deques can be received from the workers. port: Receiver>, /// The amount of work that has been enqueued. - pub work_count: uint, + work_count: uint, /// Arbitrary user data. pub data: QUD, }