---

yaml
---
r: 143013
b: refs/heads/try2
c: 9bbec65
h: refs/heads/master
i:
  143011: d364bd4
v: v3

Author: bblum

[refs]

@@ -5,7 +5,7 @@ refs/heads/snap-stage3: 78a7676898d9f80ab540c6df5d4c9ce35bb50463
 refs/heads/try: 519addf6277dbafccbb4159db4b710c37eaa2ec5
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
 refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
-refs/heads/try2: e2a42416ddab88f7ed076cb9a4fd6ecc70be3278
+refs/heads/try2: 9bbec651dfff68c93d7213fceadecc21c324b0cb
 refs/heads/dist-snap: ba4081a5a8573875fed17545846f6f6902c8ba8d
 refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
 refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503

branches/try2/src/libstd/rt/kill.rs

@@ -16,6 +16,7 @@ use either::{Either, Left, Right};
 use option::{Option, Some, None};
 use prelude::*;
 use rt::task::Task;
+use to_bytes::IterBytes;
 use unstable::atomics::{AtomicUint, Acquire, SeqCst};
 use unstable::sync::{UnsafeAtomicRcBox, LittleLock};
 use util;
@@ -194,6 +195,17 @@ impl BlockedTask {
     }
 }
 
+// So that KillHandle can be hashed in the taskgroup bookkeeping code.
+impl IterBytes for KillHandle {
+    fn iter_bytes(&self, lsb0: bool, f: &fn(buf: &[u8]) -> bool) -> bool {
+        self.data.iter_bytes(lsb0, f)
+    }
+}
+impl Eq for KillHandle {
+    #[inline] fn eq(&self, other: &KillHandle) -> bool { self.data.eq(&other.data) }
+    #[inline] fn ne(&self, other: &KillHandle) -> bool { self.data.ne(&other.data) }
+}
+
 impl KillHandle {
     pub fn new() -> (KillHandle, KillFlagHandle) {
         let (flag, flag_clone) =

branches/try2/src/libstd/rt/task.rs

@@ -27,6 +27,7 @@ use super::local_heap::LocalHeap;
 use rt::sched::{Scheduler, SchedHandle};
 use rt::stack::{StackSegment, StackPool};
 use rt::context::Context;
+use task::spawn::TCB;
 use cell::Cell;
 
 pub struct Task {
@@ -36,6 +37,7 @@ pub struct Task {
     logger: StdErrLogger,
     unwinder: Unwinder,
     home: Option<SchedHome>,
+    taskgroup: Option<TCB>,
     death: Death,
     destroyed: bool,
     coroutine: Option<~Coroutine>
@@ -85,6 +87,7 @@ impl Task {
             logger: StdErrLogger,
             unwinder: Unwinder { unwinding: false },
             home: Some(home),
+            taskgroup: None,
             death: Death::new(),
             destroyed: false,
             coroutine: Some(~Coroutine::new(stack_pool, start))
@@ -102,6 +105,7 @@ impl Task {
             logger: StdErrLogger,
             home: Some(home),
             unwinder: Unwinder { unwinding: false },
+            taskgroup: None,
             // FIXME(#7544) make watching optional
             death: self.death.new_child(),
             destroyed: false,
@@ -121,6 +125,7 @@ impl Task {
         }
 
         self.unwinder.try(f);
+        { let _ = self.taskgroup.take(); }
         self.death.collect_failure(!self.unwinder.unwinding);
         self.destroy();
     }