| 3110 | } |
| 3111 | |
| 3112 | THREAD_FUNC cancel(void* arg) { |
| 3113 | threadSleep(0.1 * deterministicRandom()->random01()); |
| 3114 | try { |
| 3115 | ((ThreadSingleAssignmentVar<int>*)arg)->addref(); |
| 3116 | destroy(arg); |
| 3117 | } catch (Error& e) { |
| 3118 | printf("Caught error in cancel: %s\n", e.name()); |
| 3119 | ASSERT(false); |
| 3120 | } |
| 3121 | THREAD_RETURN; |
| 3122 | } |
| 3123 | |
| 3124 | ACTOR Future<Void> checkUndestroyedFutures(std::vector<ThreadSingleAssignmentVar<int>*> undestroyed) { |
| 3125 | state int fNum; |
no test coverage detected