1 // Copyright 2013-2014 The Rust Project Developers. See the COPYRIGHT
2 // file at the top-level directory of this distribution and at
3 // http://rust-lang.org/COPYRIGHT.
5 // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
6 // http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
7 // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
8 // option. This file may not be copied, modified, or distributed
9 // except according to those terms.
11 //! The native I/O and threading crate
13 //! This crate contains an implementation of 1:1 scheduling for a "native"
14 //! runtime. In addition, all I/O provided by this crate is the thread blocking
17 //! # Starting with libnative
20 //! extern crate native;
23 //! fn start(argc: int, argv: *const *const u8) -> int {
24 //! native::start(argc, argv, main)
28 //! // this code is running on the main OS thread
32 //! # Force spawning a native task
35 //! extern crate native;
37 //! use std::task::TaskBuilder;
38 //! use native::NativeTaskBuilder;
41 //! // We're not sure whether this main function is run in 1:1 or M:N mode.
43 //! TaskBuilder::new().native().spawn(proc() {
44 //! // this code is guaranteed to be run on a native thread
49 #![crate_name = "native"]
51 #![license = "MIT/ASL2"]
52 #![crate_type = "rlib"]
53 #![crate_type = "dylib"]
54 #![doc(html_logo_url = "http://www.rust-lang.org/logos/rust-logo-128x128-blk-v2.png",
55 html_favicon_url = "http://www.rust-lang.org/favicon.ico",
56 html_root_url = "http://doc.rust-lang.org/master/")]
58 #![deny(unused_result, unused_must_use)]
59 #![allow(non_camel_case_types, deprecated)]
60 #![feature(default_type_params, lang_items)]
62 // NB this crate explicitly does *not* allow glob imports, please seriously
63 // consider whether they're needed before adding that feature here (the
64 // answer is that you don't need them)
65 #![feature(macro_rules, unsafe_destructor, default_type_params)]
69 #[cfg(test)] extern crate debug;
75 pub use task::NativeTaskBuilder;
82 static OS_DEFAULT_STACK_ESTIMATE: uint = 1 << 20;
83 #[cfg(unix, not(android))]
84 static OS_DEFAULT_STACK_ESTIMATE: uint = 2 * (1 << 20);
88 pub fn lang_start(main: *const u8, argc: int, argv: *const *const u8) -> int {
90 start(argc, argv, proc() {
91 let main: extern "Rust" fn() = unsafe { mem::transmute(main) };
96 /// Executes the given procedure after initializing the runtime with the given
99 /// This procedure is guaranteed to run on the thread calling this function, but
100 /// the stack bounds for this rust task will *not* be set. Care must be taken
101 /// for this function to not overflow its stack.
103 /// This function will only return once *all* native threads in the system have
105 pub fn start(argc: int, argv: *const *const u8, main: proc()) -> int {
106 let something_around_the_top_of_the_stack = 1;
107 let addr = &something_around_the_top_of_the_stack as *const int;
108 let my_stack_top = addr as uint;
110 // FIXME #11359 we just assume that this thread has a stack of a
111 // certain size, and estimate that there's at most 20KB of stack
112 // frames above our current position.
113 let my_stack_bottom = my_stack_top + 20000 - OS_DEFAULT_STACK_ESTIMATE;
115 // When using libgreen, one of the first things that we do is to turn off
116 // the SIGPIPE signal (set it to ignore). By default, some platforms will
117 // send a *signal* when a EPIPE error would otherwise be delivered. This
118 // runtime doesn't install a SIGPIPE handler, causing it to kill the
119 // program, which isn't exactly what we want!
121 // Hence, we set SIGPIPE to ignore when the program starts up in order to
122 // prevent this problem.
123 #[cfg(windows)] fn ignore_sigpipe() {}
124 #[cfg(unix)] fn ignore_sigpipe() {
126 use libc::funcs::posix01::signal::signal;
128 assert!(signal(libc::SIGPIPE, libc::SIG_IGN) != -1);
133 rt::init(argc, argv);
134 let mut exit_code = None;
135 let mut main = Some(main);
136 let mut task = task::new((my_stack_bottom, my_stack_top));
137 task.name = Some(str::Slice("<main>"));
140 rt::stack::record_os_managed_stack_bounds(my_stack_bottom, my_stack_top);
142 exit_code = Some(run(main.take().unwrap()));
144 unsafe { rt::cleanup(); }
145 // If the exit code wasn't set, then the task block must have failed.
146 return exit_code.unwrap_or(rt::DEFAULT_ERROR_CODE);
149 /// Executes a procedure on the current thread in a Rust task context.
151 /// This function has all of the same details as `start` except for a different
152 /// number of arguments.
153 pub fn run(main: proc()) -> int {
155 os::get_exit_status()