Skip to content

Commit

Permalink
Move default stack min size to thread implementations
Browse files Browse the repository at this point in the history
The default min stack size value is smaller on l4re and therefore
this value has to be different depending on the platform.
  • Loading branch information
Tobias Schaffner authored and humenda committed Sep 13, 2017
1 parent 5d1a9d7 commit b2b5063
Show file tree
Hide file tree
Showing 7 changed files with 31 additions and 25 deletions.
2 changes: 2 additions & 0 deletions src/libstd/sys/redox/thread.rs
Expand Up @@ -16,6 +16,8 @@ use sys_common::thread::start_thread;
use sys::{cvt, syscall};
use time::Duration;

pub const DEFAULT_MIN_STACK_SIZE: usize = 2 * 1024 * 1024;

pub struct Thread {
id: usize,
}
Expand Down
4 changes: 2 additions & 2 deletions src/libstd/sys/unix/l4re.rs
Expand Up @@ -104,11 +104,11 @@ pub mod net {
impl AsInner<libc::c_int> for Socket {
fn as_inner(&self) -> &libc::c_int { self.0.as_inner() }
}

impl FromInner<libc::c_int> for Socket {
fn from_inner(fd: libc::c_int) -> Socket { Socket(FileDesc::new(fd)) }
}

impl IntoInner<libc::c_int> for Socket {
fn into_inner(self) -> libc::c_int { self.0.into_raw() }
}
Expand Down
5 changes: 5 additions & 0 deletions src/libstd/sys/unix/thread.rs
Expand Up @@ -20,6 +20,11 @@ use time::Duration;

use sys_common::thread::*;

#[cfg(not(target_os = "l4re"))]
pub const DEFAULT_MIN_STACK_SIZE: usize = 2 * 1024 * 1024;
#[cfg(target_os = "l4re")]
pub const DEFAULT_MIN_STACK_SIZE: usize = 1024 * 1024;

pub struct Thread {
id: libc::pthread_t,
}
Expand Down
2 changes: 2 additions & 0 deletions src/libstd/sys/windows/thread.rs
Expand Up @@ -19,6 +19,8 @@ use sys::handle::Handle;
use sys_common::thread::*;
use time::Duration;

pub const DEFAULT_MIN_STACK_SIZE: usize = 2 * 1024 * 1024;

pub struct Thread {
handle: Handle
}
Expand Down
18 changes: 18 additions & 0 deletions src/libstd/sys_common/thread.rs
Expand Up @@ -8,9 +8,12 @@
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use env;
use alloc::boxed::FnBox;
use libc;
use sync::atomic::{self, Ordering};
use sys::stack_overflow;
use sys::thread as imp;

pub unsafe fn start_thread(main: *mut libc::c_void) {
// Next, set up our stack overflow handler which may get triggered if we run
Expand All @@ -20,3 +23,18 @@ pub unsafe fn start_thread(main: *mut libc::c_void) {
// Finally, let's run some code.
Box::from_raw(main as *mut Box<FnBox()>)()
}

pub fn min_stack() -> usize {
static MIN: atomic::AtomicUsize = atomic::AtomicUsize::new(0);
match MIN.load(Ordering::SeqCst) {
0 => {}
n => return n - 1,
}
let amt = env::var("RUST_MIN_STACK").ok().and_then(|s| s.parse().ok());
let amt = amt.unwrap_or(imp::DEFAULT_MIN_STACK_SIZE);

// 0 is our sentinel value, so ensure that we'll never see 0 after
// initialization has run
MIN.store(amt + 1, Ordering::SeqCst);
amt
}
21 changes: 0 additions & 21 deletions src/libstd/sys_common/util.rs
Expand Up @@ -8,32 +8,11 @@
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use env;
use fmt;
use io::prelude::*;
use sync::atomic::{self, Ordering};
use sys::stdio::Stderr;
use thread;

pub fn min_stack() -> usize {
static MIN: atomic::AtomicUsize = atomic::AtomicUsize::new(0);
match MIN.load(Ordering::SeqCst) {
0 => {}
n => return n - 1,
}
let amt = env::var("RUST_MIN_STACK").ok().and_then(|s| s.parse().ok());
#[cfg(not(target_os = "l4re"))]
let amt = amt.unwrap_or(2 * 1024 * 1024);
// L4Re only supports a maximum of 1Mb per default.
#[cfg(target_os = "l4re")]
let amt = amt.unwrap_or(1024 * 1024);

// 0 is our sentinel value, so ensure that we'll never see 0 after
// initialization has run
MIN.store(amt + 1, Ordering::SeqCst);
amt
}

pub fn dumb_print(args: fmt::Arguments) {
let _ = Stderr::new().map(|mut stderr| stderr.write_fmt(args));
}
Expand Down
4 changes: 2 additions & 2 deletions src/libstd/thread/mod.rs
Expand Up @@ -174,7 +174,7 @@ use sync::{Mutex, Condvar, Arc};
use sys::thread as imp;
use sys_common::mutex;
use sys_common::thread_info;
use sys_common::util;
use sys_common::thread;
use sys_common::{AsInner, IntoInner};
use time::Duration;

Expand Down Expand Up @@ -374,7 +374,7 @@ impl Builder {
{
let Builder { name, stack_size } = self;

let stack_size = stack_size.unwrap_or_else(util::min_stack);
let stack_size = stack_size.unwrap_or_else(thread::min_stack);

let my_thread = Thread::new(name);
let their_thread = my_thread.clone();
Expand Down

0 comments on commit b2b5063

Please sign in to comment.