source: libcfa/src/concurrency/kernel_private.hfa@ 1a3040c

ADT arm-eh ast-experimental enum forall-pointer-decay jacob/cs343-translation jenkins-sandbox new-ast new-ast-unique-expr pthread-emulation qualifiedEnum
Last change on this file since 1a3040c was 1805b1b, checked in by Peter A. Buhr <pabuhr@…>, 6 years ago

refactor pthread_create into create_pthread, change NULL to 0p

  • Property mode set to 100644
File size: 3.5 KB
RevLine 
[75f3522]1//
2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
[73abe95]7// kernel_private.hfa --
[75f3522]8//
9// Author : Thierry Delisle
10// Created On : Mon Feb 13 12:27:26 2017
[6b0b624]11// Last Modified By : Peter A. Buhr
[1805b1b]12// Last Modified On : Sat Nov 30 19:25:02 2019
13// Update Count : 8
[75f3522]14//
15
[6b0b624]16#pragma once
[75f3522]17
[58b6d1b]18#include "kernel.hfa"
19#include "thread.hfa"
[75f3522]20
[73abe95]21#include "alarm.hfa"
[fa21ac9]22
[4aa2fb2]23
[75f3522]24//-----------------------------------------------------------------------------
25// Scheduler
[1c273d0]26
27extern "C" {
[2026bb6]28 void disable_interrupts() OPTIONAL_THREAD;
[969b3fe]29 void enable_interrupts_noPoll();
[36982fc]30 void enable_interrupts( __cfaabi_dbg_ctx_param );
[1c273d0]31}
32
[348006f]33void ScheduleThread( thread_desc * );
[1c273d0]34static inline void WakeThread( thread_desc * thrd ) {
35 if( !thrd ) return;
36
[722c0848]37 verify(thrd->state == Inactive);
38
[1c273d0]39 disable_interrupts();
40 ScheduleThread( thrd );
[36982fc]41 enable_interrupts( __cfaabi_dbg_ctx );
[1c273d0]42}
[348006f]43thread_desc * nextThread(cluster * this);
[75f3522]44
[e60e0dc]45//Block current thread and release/wake-up the following resources
[82ff5845]46void BlockInternal(void);
[ea7d2b0]47void BlockInternal(__spinlock_t * lock);
[82ff5845]48void BlockInternal(thread_desc * thrd);
[ea7d2b0]49void BlockInternal(__spinlock_t * lock, thread_desc * thrd);
50void BlockInternal(__spinlock_t * locks [], unsigned short count);
51void BlockInternal(__spinlock_t * locks [], unsigned short count, thread_desc * thrds [], unsigned short thrd_count);
[09800e9]52void BlockInternal(__finish_callback_fptr_t callback);
[ea7d2b0]53void LeaveThread(__spinlock_t * lock, thread_desc * thrd);
[db6f06a]54
[75f3522]55//-----------------------------------------------------------------------------
56// Processor
57void main(processorCtx_t *);
[85b1deb]58
[1805b1b]59void * create_pthread( pthread_t *, void * (*)(void *), void * );
60
[85b1deb]61static inline void wake_fast(processor * this) {
62 __cfaabi_dbg_print_safe("Kernel : Waking up processor %p\n", this);
63 post( this->idleLock );
64}
65
66static inline void wake(processor * this) {
67 disable_interrupts();
68 wake_fast(this);
69 enable_interrupts( __cfaabi_dbg_ctx );
70}
[75f3522]71
[e60e0dc]72struct event_kernel_t {
[fa21ac9]73 alarm_list_t alarms;
[ea7d2b0]74 __spinlock_t lock;
[fa21ac9]75};
76
[e60e0dc]77extern event_kernel_t * event_kernel;
78
[d8548e2]79struct __cfa_kernel_preemption_state_t {
[b69ea6b]80 bool enabled;
81 bool in_progress;
82 unsigned short disable_count;
83};
84
[afc2427]85extern volatile thread_local __cfa_kernel_preemption_state_t preemption_state __attribute__ ((tls_model ( "initial-exec" )));
[c81ebf9]86
[75f3522]87//-----------------------------------------------------------------------------
88// Threads
89extern "C" {
90 forall(dtype T | is_thread(T))
91 void CtxInvokeThread(T * this);
92}
93
[c3acb841]94extern void ThreadCtxSwitch(coroutine_desc * src, coroutine_desc * dst);
[75f3522]95
[f7d6bb0]96__cfaabi_dbg_debug_do(
97 extern void __cfaabi_dbg_thread_register ( thread_desc * thrd );
98 extern void __cfaabi_dbg_thread_unregister( thread_desc * thrd );
99)
100
[969b3fe]101//-----------------------------------------------------------------------------
102// Utils
103#define KERNEL_STORAGE(T,X) static char storage_##X[sizeof(T)]
104
[21184e3]105static inline uint32_t tls_rand() {
106 kernelTLS.rand_seed ^= kernelTLS.rand_seed << 6;
107 kernelTLS.rand_seed ^= kernelTLS.rand_seed >> 21;
108 kernelTLS.rand_seed ^= kernelTLS.rand_seed << 7;
109 return kernelTLS.rand_seed;
110}
111
[de94a60]112
[a1a17a74]113void doregister( struct cluster & cltr );
114void unregister( struct cluster & cltr );
[de94a60]115
[a1a17a74]116void doregister( struct cluster * cltr, struct thread_desc & thrd );
117void unregister( struct cluster * cltr, struct thread_desc & thrd );
[de94a60]118
119void doregister( struct cluster * cltr, struct processor * proc );
120void unregister( struct cluster * cltr, struct processor * proc );
121
[75f3522]122// Local Variables: //
123// mode: c //
124// tab-width: 4 //
[4aa2fb2]125// End: //
Note: See TracBrowser for help on using the repository browser.