// Copyright 2012 The Rust Project Developers. See the COPYRIGHT
// file at the top-level directory of this distribution and at
// http://rust-lang.org/COPYRIGHT.
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.

// Tests of the runtime's scheduler interface

use core::comm::*;

pub type sched_id = int;
pub type task_id = *libc::c_void;

pub type task = *libc::c_void;
pub type closure = *libc::c_void;

mod rustrt {
    use super::{closure, sched_id, task, task_id};

    pub extern {
        pub fn rust_new_sched(num_threads: libc::uintptr_t) -> sched_id;
        pub fn rust_get_sched_id() -> sched_id;
        pub fn rust_new_task_in_sched(id: sched_id) -> task_id;
        pub fn start_task(id: task_id, f: closure);
    }
}

pub fn main() {
    unsafe {
        let (po, ch) = stream();
        let parent_sched_id = rustrt::rust_get_sched_id();
        error!("parent %?", parent_sched_id);
        let num_threads = 1u;
        let new_sched_id = rustrt::rust_new_sched(num_threads);
        error!("new_sched_id %?", new_sched_id);
        let new_task_id = rustrt::rust_new_task_in_sched(new_sched_id);
        assert!(!new_task_id.is_null());
        let f: ~fn() = || {
            unsafe {
                let child_sched_id = rustrt::rust_get_sched_id();
                error!("child_sched_id %?", child_sched_id);
                assert!(child_sched_id != parent_sched_id);
                assert!(child_sched_id == new_sched_id);
                ch.send(());
            }
        };
        let fptr = cast::transmute(&f);
        rustrt::start_task(new_task_id, fptr);
        cast::forget(f);
        po.recv();
    }
}