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

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

Added verify macro for asserts only present in debug

  • Property mode set to 100644
File size: 2.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#include "alarm.h"
24
25#include "libhdr.h"
26
27//-----------------------------------------------------------------------------
28// Scheduler
29void ScheduleThread( thread_desc * );
30thread_desc * nextThread(cluster * this);
31
32void ScheduleInternal(void);
33void ScheduleInternal(spinlock * lock);
34void ScheduleInternal(thread_desc * thrd);
35void ScheduleInternal(spinlock * lock, thread_desc * thrd);
36void ScheduleInternal(spinlock ** locks, unsigned short count);
37void ScheduleInternal(spinlock ** locks, unsigned short count, thread_desc ** thrds, unsigned short thrd_count);
38
39//-----------------------------------------------------------------------------
40// Processor
41coroutine processorCtx_t {
42        processor * proc;
43};
44
45void main(processorCtx_t *);
46void start(processor * this);
47void runThread(processor * this, thread_desc * dst);
48void finishRunning(processor * this);
49void spin(processor * this, unsigned int * spin_count);
50
51struct system_proc_t {
52        processor proc;
53
54        alarm_list_t alarms;
55        spinlock alarm_lock;
56
57        bool pending_alarm;
58};
59
60extern cluster * systemCluster;
61extern system_proc_t * systemProcessor;
62extern thread_local processor * this_processor;
63
64static inline void disable_interrupts() {
65        __attribute__((unused)) unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, 1, __ATOMIC_SEQ_CST );
66        assert( prev != (unsigned short) -1 );
67}
68
69static inline void enable_interrupts_noRF() {
70        __attribute__((unused)) unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, -1, __ATOMIC_SEQ_CST );
71        verify( prev != (unsigned short) 0 );
72}
73
74static inline void enable_interrupts() {
75        __attribute__((unused)) unsigned short prev = __atomic_fetch_add_2( &this_processor->disable_preempt_count, -1, __ATOMIC_SEQ_CST );
76        verify( prev != (unsigned short) 0 );
77        if( prev == 1 && this_processor->pending_preemption ) {
78                ScheduleInternal( this_processor->current_thread );
79                this_processor->pending_preemption = false;
80        }
81}
82
83//-----------------------------------------------------------------------------
84// Threads
85extern "C" {
86      forall(dtype T | is_thread(T))
87      void CtxInvokeThread(T * this);
88}
89
90extern void ThreadCtxSwitch(coroutine_desc * src, coroutine_desc * dst);
91
92#endif //KERNEL_PRIVATE_H
93
94// Local Variables: //
95// mode: c //
96// tab-width: 4 //
97// End: //
Note: See TracBrowser for help on using the repository browser.