source: src/libcfa/concurrency/kernel_private.h @ f07e037

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since f07e037 was db6f06a, checked in by Thierry Delisle <tdelisle@…>, 7 years ago

Implemented better condition lock to solve race condition on thread/processor termination

  • Property mode set to 100644
File size: 1.5 KB
Line 
1//                              -*- Mode: CFA -*-
2//
3// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
4//
5// The contents of this file are covered under the licence agreement in the
6// file "LICENCE" distributed with Cforall.
7//
8// threads --
9//
10// Author           : Thierry Delisle
11// Created On       : Mon Feb 13 12:27:26 2017
12// Last Modified By : Thierry Delisle
13// Last Modified On : --
14// Update Count     : 0
15//
16
17#ifndef KERNEL_PRIVATE_H
18#define KERNEL_PRIVATE_H
19
20#include "kernel"
21#include "threads"
22
23//-----------------------------------------------------------------------------
24// Scheduler
25void ScheduleThread( thread * );
26thread * nextThread(cluster * this);
27
28void ScheduleInternal();
29void ScheduleInternal(spinlock * lock);
30void ScheduleInternal(thread * thrd);
31void ScheduleInternal(spinlock * lock, thread * thrd);
32
33//-----------------------------------------------------------------------------
34// Processor
35struct processorCtx_t {
36        processor * proc;
37        coroutine c;
38};
39
40DECL_COROUTINE(processorCtx_t);
41
42void main(processorCtx_t *);
43void start(processor * this);
44void runThread(processor * this, thread * dst);
45void finishRunning(processor * this);
46void spin(processor * this, unsigned int * spin_count);
47
48//-----------------------------------------------------------------------------
49// Threads
50extern "C" {
51      forall(dtype T | is_thread(T))
52      void CtxInvokeThread(T * this);
53}
54
55extern void ThreadCtxSwitch(coroutine * src, coroutine * dst);
56
57#endif //KERNEL_PRIVATE_H
58
59// Local Variables: //
60// mode: c //
61// tab-width: 4 //
62// End: //
Note: See TracBrowser for help on using the repository browser.