source: src/libcfa/concurrency/kernel_private.h @ 0c78741

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 0c78741 was 0c78741, checked in by Thierry Delisle <tdelisle@…>, 7 years ago

Implementation of internal scheduling in CFA

  • Property mode set to 100644
File size: 1.8 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// kernel_private.h --
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 "thread"
22
23//-----------------------------------------------------------------------------
24// Scheduler
25void ScheduleThread( thread_desc * );
26thread_desc * nextThread(cluster * this);
27
28void ScheduleInternal(void);
29void ScheduleInternal(spinlock * lock);
30void ScheduleInternal(thread_desc * thrd);
31void ScheduleInternal(spinlock * lock, thread_desc * thrd);
32void ScheduleInternal(spinlock ** locks, unsigned short count);
33void ScheduleInternal(spinlock ** locks, unsigned short count, thread_desc ** thrds, unsigned short thrd_count);
34
35//-----------------------------------------------------------------------------
36// Processor
37struct processorCtx_t {
38        processor * proc;
39        coroutine_desc __cor;
40};
41
42DECL_COROUTINE(processorCtx_t);
43
44void main(processorCtx_t *);
45void start(processor * this);
46void runThread(processor * this, thread_desc * dst);
47void finishRunning(processor * this);
48void spin(processor * this, unsigned int * spin_count);
49
50//-----------------------------------------------------------------------------
51// Threads
52extern "C" {
53      forall(dtype T | is_thread(T))
54      void CtxInvokeThread(T * this);
55}
56
57extern void ThreadCtxSwitch(coroutine_desc * src, coroutine_desc * dst);
58
59#endif //KERNEL_PRIVATE_H
60
61// Local Variables: //
62// mode: c //
63// tab-width: 4 //
64// End: //
Note: See TracBrowser for help on using the repository browser.