source: src/libcfa/concurrency/kernel.c @ b4e1876

//
// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
//
// The contents of this file are covered under the licence agreement in the
// file "LICENCE" distributed with Cforall.
//
// kernel.c --
//
// Author           : Thierry Delisle
// Created On       : Tue Jan 17 12:27:26 2017
// Last Modified By : Peter A. Buhr
// Last Modified On : Mon Apr  9 16:11:46 2018
// Update Count     : 24
//

//C Includes
#include <stddef.h>
#include <errno.h>
extern "C" {
#include <stdio.h>
#include <fenv.h>
#include <sys/resource.h>
#include <signal.h>
#include <unistd.h>
}

//CFA Includes
#include "time"
#include "kernel_private.h"
#include "preemption.h"
#include "startup.h"

//Private includes
#define __CFA_INVOKE_PRIVATE__
#include "invoke.h"

//Start and stop routine for the kernel, declared first to make sure they run first
void kernel_startup(void)  __attribute__(( constructor( STARTUP_PRIORITY_KERNEL ) ));
void kernel_shutdown(void) __attribute__(( destructor ( STARTUP_PRIORITY_KERNEL ) ));

//-----------------------------------------------------------------------------
// Kernel storage
KERNEL_STORAGE(cluster,           mainCluster);
KERNEL_STORAGE(processor,         mainProcessor);
KERNEL_STORAGE(thread_desc,       mainThread);
KERNEL_STORAGE(machine_context_t, mainThreadCtx);

cluster     * mainCluster;
processor   * mainProcessor;
thread_desc * mainThread;

struct { __dllist_t(cluster) list; __spinlock_t lock; } global_clusters;

//-----------------------------------------------------------------------------
// Global state
thread_local struct KernelThreadData kernelTLS = {
        NULL,
        NULL,
        NULL,
        { 1, false, false }
};

//-----------------------------------------------------------------------------
// Struct to steal stack
struct current_stack_info_t {
        machine_context_t ctx;
        unsigned int size;              // size of stack
        void *base;                             // base of stack
        void *storage;                  // pointer to stack
        void *limit;                    // stack grows towards stack limit
        void *context;                  // address of cfa_context_t
        void *top;                              // address of top of storage
};

void ?{}( current_stack_info_t & this ) {
        CtxGet( this.ctx );
        this.base = this.ctx.FP;
        this.storage = this.ctx.SP;

        rlimit r;
        getrlimit( RLIMIT_STACK, &r);
        this.size = r.rlim_cur;

        this.limit = (void *)(((intptr_t)this.base) - this.size);
        this.context = &storage_mainThreadCtx;
        this.top = this.base;
}

//-----------------------------------------------------------------------------
// Main thread construction
void ?{}( coStack_t & this, current_stack_info_t * info) with( this ) {
        size      = info->size;
        storage   = info->storage;
        limit     = info->limit;
        base      = info->base;
        context   = info->context;
        top       = info->top;
        userStack = true;
}

void ?{}( coroutine_desc & this, current_stack_info_t * info) with( this ) {
        stack{ info };
        name = "Main Thread";
        errno_ = 0;
        state = Start;
        starter = NULL;
}

void ?{}( thread_desc & this, current_stack_info_t * info) with( this ) {
        self_cor{ info };
        curr_cor = &self_cor;
        curr_cluster = mainCluster;
        self_mon.owner = &this;
        self_mon.recursion = 1;
        self_mon_p = &self_mon;
        next = NULL;

        node.next = NULL;
        node.prev = NULL;
        doregister(curr_cluster, this);

        monitors{ &self_mon_p, 1, (fptr_t)0 };
}

//-----------------------------------------------------------------------------
// Processor coroutine
void ?{}(processorCtx_t & this) {

}

// Construct the processor context of non-main processors
void ?{}(processorCtx_t & this, processor * proc, current_stack_info_t * info) {
        (this.__cor){ info };
        this.proc = proc;
}

void ?{}(processor & this, const char * name, cluster & cltr) with( this ) {
        this.name = name;
        this.cltr = &cltr;
        terminated{ 0 };
        do_terminate = false;
        preemption_alarm = NULL;
        pending_preemption = false;
        runner.proc = &this;

        sem_init(&idleLock, 0, 0);

        start( &this );
}

void ^?{}(processor & this) with( this ){
        if( ! do_terminate ) {
                __cfaabi_dbg_print_safe("Kernel : core %p signaling termination\n", &this);
                terminate(&this);
                verify(this.do_terminate);
                verify( kernelTLS.this_processor != &this);
                P( terminated );
                verify( kernelTLS.this_processor != &this);
                pthread_join( kernel_thread, NULL );
        }

        sem_destroy(&idleLock);
}

void ?{}(cluster & this, const char * name, Duration preemption_rate) with( this ) {
        this.name = name;
        this.preemption_rate = preemption_rate;
        ready_queue{};
        ready_queue_lock{};

        procs{ __get };
        idles{ __get };
        threads{ __get };

        doregister(this);
}

void ^?{}(cluster & this) {
        unregister(this);
}

//=============================================================================================
// Kernel Scheduling logic
//=============================================================================================
//Main of the processor contexts
void main(processorCtx_t & runner) {
        processor * this = runner.proc;
        verify(this);

        __cfaabi_dbg_print_safe("Kernel : core %p starting\n", this);

        doregister(this->cltr, this);

        {
                // Setup preemption data
                preemption_scope scope = { this };

                __cfaabi_dbg_print_safe("Kernel : core %p started\n", this);

                thread_desc * readyThread = NULL;
                for( unsigned int spin_count = 0; ! this->do_terminate; spin_count++ )
                {
                        readyThread = nextThread( this->cltr );

                        if(readyThread)
                        {
                                verify( ! kernelTLS.preemption_state.enabled );

                                runThread(this, readyThread);

                                verify( ! kernelTLS.preemption_state.enabled );

                                //Some actions need to be taken from the kernel
                                finishRunning(this);

                                spin_count = 0;
                        }
                        else
                        {
                                spin(this, &spin_count);
                        }
                }

                __cfaabi_dbg_print_safe("Kernel : core %p stopping\n", this);
        }

        unregister(this->cltr, this);

        V( this->terminated );

        __cfaabi_dbg_print_safe("Kernel : core %p terminated\n", this);
}

// KERNEL ONLY
// runThread runs a thread by context switching
// from the processor coroutine to the target thread
void runThread(processor * this, thread_desc * dst) {
        assert(dst->curr_cor);
        coroutine_desc * proc_cor = get_coroutine(this->runner);
        coroutine_desc * thrd_cor = dst->curr_cor;

        // Reset the terminating actions here
        this->finish.action_code = No_Action;

        // Update global state
        kernelTLS.this_thread = dst;

        // Context Switch to the thread
        ThreadCtxSwitch(proc_cor, thrd_cor);
        // when ThreadCtxSwitch returns we are back in the processor coroutine
}

// KERNEL_ONLY
void returnToKernel() {
        coroutine_desc * proc_cor = get_coroutine(kernelTLS.this_processor->runner);
        coroutine_desc * thrd_cor = kernelTLS.this_thread->curr_cor = kernelTLS.this_coroutine;
        ThreadCtxSwitch(thrd_cor, proc_cor);
}

// KERNEL_ONLY
// Once a thread has finished running, some of
// its final actions must be executed from the kernel
void finishRunning(processor * this) with( this->finish ) {
        verify( ! kernelTLS.preemption_state.enabled );
        choose( action_code ) {
        case No_Action:
                break;
        case Release:
                unlock( *lock );
        case Schedule:
                ScheduleThread( thrd );
        case Release_Schedule:
                unlock( *lock );
                ScheduleThread( thrd );
        case Release_Multi:
                for(int i = 0; i < lock_count; i++) {
                        unlock( *locks[i] );
                }
        case Release_Multi_Schedule:
                for(int i = 0; i < lock_count; i++) {
                        unlock( *locks[i] );
                }
                for(int i = 0; i < thrd_count; i++) {
                        ScheduleThread( thrds[i] );
                }
        case Callback:
                callback();
        default:
                abort("KERNEL ERROR: Unexpected action to run after thread");
        }
}

// Handles spinning logic
// TODO : find some strategy to put cores to sleep after some time
void spin(processor * this, unsigned int * spin_count) {
        // (*spin_count)++;
        halt(this);
}

// KERNEL_ONLY
// Context invoker for processors
// This is the entry point for processors (kernel threads)
// It effectively constructs a coroutine by stealing the pthread stack
void * CtxInvokeProcessor(void * arg) {
        processor * proc = (processor *) arg;
        kernelTLS.this_processor = proc;
        kernelTLS.this_coroutine = NULL;
        kernelTLS.this_thread    = NULL;
        kernelTLS.preemption_state.[enabled, disable_count] = [false, 1];
        // SKULLDUGGERY: We want to create a context for the processor coroutine
        // which is needed for the 2-step context switch. However, there is no reason
        // to waste the perfectly valid stack create by pthread.
        current_stack_info_t info;
        machine_context_t ctx;
        info.context = &ctx;
        (proc->runner){ proc, &info };

        __cfaabi_dbg_print_safe("Coroutine : created stack %p\n", get_coroutine(proc->runner)->stack.base);

        //Set global state
        kernelTLS.this_coroutine = get_coroutine(proc->runner);
        kernelTLS.this_thread    = NULL;

        //We now have a proper context from which to schedule threads
        __cfaabi_dbg_print_safe("Kernel : core %p created (%p, %p)\n", proc, &proc->runner, &ctx);

        // SKULLDUGGERY: Since the coroutine doesn't have its own stack, we can't
        // resume it to start it like it normally would, it will just context switch
        // back to here. Instead directly call the main since we already are on the
        // appropriate stack.
        get_coroutine(proc->runner)->state = Active;
        main( proc->runner );
        get_coroutine(proc->runner)->state = Halted;

        // Main routine of the core returned, the core is now fully terminated
        __cfaabi_dbg_print_safe("Kernel : core %p main ended (%p)\n", proc, &proc->runner);

        return NULL;
}

void start(processor * this) {
        __cfaabi_dbg_print_safe("Kernel : Starting core %p\n", this);

        pthread_create( &this->kernel_thread, NULL, CtxInvokeProcessor, (void*)this );

        __cfaabi_dbg_print_safe("Kernel : core %p started\n", this);
}

// KERNEL_ONLY
void kernel_first_resume(processor * this) {
        coroutine_desc * src = kernelTLS.this_coroutine;
        coroutine_desc * dst = get_coroutine(this->runner);

        verify( ! kernelTLS.preemption_state.enabled );

        create_stack(&dst->stack, dst->stack.size);
        CtxStart(&this->runner, CtxInvokeCoroutine);

        verify( ! kernelTLS.preemption_state.enabled );

        dst->last = src;
        dst->starter = dst->starter ? dst->starter : src;

        // set state of current coroutine to inactive
        src->state = src->state == Halted ? Halted : Inactive;

        // set new coroutine that task is executing
        kernelTLS.this_coroutine = dst;

        // SKULLDUGGERY normally interrupts are enable before leaving a coroutine ctxswitch.
        // Therefore, when first creating a coroutine, interrupts are enable before calling the main.
        // This is consistent with thread creation. However, when creating the main processor coroutine,
        // we wan't interrupts to be disabled. Therefore, we double-disable interrupts here so they will
        // stay disabled.
        disable_interrupts();

        // context switch to specified coroutine
        assert( src->stack.context );
        CtxSwitch( src->stack.context, dst->stack.context );
        // when CtxSwitch returns we are back in the src coroutine

        // set state of new coroutine to active
        src->state = Active;

        verify( ! kernelTLS.preemption_state.enabled );
}

//-----------------------------------------------------------------------------
// Scheduler routines

// KERNEL ONLY
void ScheduleThread( thread_desc * thrd ) {
        verify( thrd );
        verify( thrd->self_cor.state != Halted );

        verify( ! kernelTLS.preemption_state.enabled );

        verifyf( thrd->next == NULL, "Expected null got %p", thrd->next );

        with( *thrd->curr_cluster ) {
                lock  ( ready_queue_lock __cfaabi_dbg_ctx2 );
                bool was_empty = !(ready_queue != 0);
                append( ready_queue, thrd );
                unlock( ready_queue_lock );

                if( was_empty ) {
                        lock      (proc_list_lock __cfaabi_dbg_ctx2);
                        if(idles) {
                                wake(idles.head);
                        }
                        unlock    (proc_list_lock);
                }
        }

        verify( ! kernelTLS.preemption_state.enabled );
}

// KERNEL ONLY
thread_desc * nextThread(cluster * this) with( *this ) {
        verify( ! kernelTLS.preemption_state.enabled );
        lock( ready_queue_lock __cfaabi_dbg_ctx2 );
        thread_desc * head = pop_head( ready_queue );
        unlock( ready_queue_lock );
        verify( ! kernelTLS.preemption_state.enabled );
        return head;
}

void BlockInternal() {
        disable_interrupts();
        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );
        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal( __spinlock_t * lock ) {
        disable_interrupts();
        with( *kernelTLS.this_processor ) {
                finish.action_code = Release;
                finish.lock        = lock;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal( thread_desc * thrd ) {
        disable_interrupts();
        with( * kernelTLS.this_processor ) {
                finish.action_code = Schedule;
                finish.thrd        = thrd;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal( __spinlock_t * lock, thread_desc * thrd ) {
        assert(thrd);
        disable_interrupts();
        with( * kernelTLS.this_processor ) {
                finish.action_code = Release_Schedule;
                finish.lock        = lock;
                finish.thrd        = thrd;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal(__spinlock_t * locks [], unsigned short count) {
        disable_interrupts();
        with( * kernelTLS.this_processor ) {
                finish.action_code = Release_Multi;
                finish.locks       = locks;
                finish.lock_count  = count;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal(__spinlock_t * locks [], unsigned short lock_count, thread_desc * thrds [], unsigned short thrd_count) {
        disable_interrupts();
        with( *kernelTLS.this_processor ) {
                finish.action_code = Release_Multi_Schedule;
                finish.locks       = locks;
                finish.lock_count  = lock_count;
                finish.thrds       = thrds;
                finish.thrd_count  = thrd_count;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

void BlockInternal(__finish_callback_fptr_t callback) {
        disable_interrupts();
        with( *kernelTLS.this_processor ) {
                finish.action_code = Callback;
                finish.callback    = callback;
        }

        verify( ! kernelTLS.preemption_state.enabled );
        returnToKernel();
        verify( ! kernelTLS.preemption_state.enabled );

        enable_interrupts( __cfaabi_dbg_ctx );
}

// KERNEL ONLY
void LeaveThread(__spinlock_t * lock, thread_desc * thrd) {
        verify( ! kernelTLS.preemption_state.enabled );
        with( * kernelTLS.this_processor ) {
                finish.action_code = thrd ? Release_Schedule : Release;
                finish.lock        = lock;
                finish.thrd        = thrd;
        }

        returnToKernel();
}

//=============================================================================================
// Kernel Setup logic
//=============================================================================================
//-----------------------------------------------------------------------------
// Kernel boot procedures
void kernel_startup(void) {
        verify( ! kernelTLS.preemption_state.enabled );
        __cfaabi_dbg_print_safe("Kernel : Starting\n");

        global_clusters.list{ __get };
        global_clusters.lock{};

        // Initialize the main cluster
        mainCluster = (cluster *)&storage_mainCluster;
        (*mainCluster){"Main Cluster"};

        __cfaabi_dbg_print_safe("Kernel : Main cluster ready\n");

        // Start by initializing the main thread
        // SKULLDUGGERY: the mainThread steals the process main thread
        // which will then be scheduled by the mainProcessor normally
        mainThread = (thread_desc *)&storage_mainThread;
        current_stack_info_t info;
        (*mainThread){ &info };

        __cfaabi_dbg_print_safe("Kernel : Main thread ready\n");



        // Construct the processor context of the main processor
        void ?{}(processorCtx_t & this, processor * proc) {
                (this.__cor){ "Processor" };
                this.__cor.starter = NULL;
                this.proc = proc;
        }

        void ?{}(processor & this) with( this ) {
                name = "Main Processor";
                cltr = mainCluster;
                terminated{ 0 };
                do_terminate = false;
                preemption_alarm = NULL;
                pending_preemption = false;
                kernel_thread = pthread_self();

                runner{ &this };
                __cfaabi_dbg_print_safe("Kernel : constructed main processor context %p\n", &runner);
        }

        // Initialize the main processor and the main processor ctx
        // (the coroutine that contains the processing control flow)
        mainProcessor = (processor *)&storage_mainProcessor;
        (*mainProcessor){};

        //initialize the global state variables
        kernelTLS.this_processor = mainProcessor;
        kernelTLS.this_thread    = mainThread;
        kernelTLS.this_coroutine = &mainThread->self_cor;

        // Enable preemption
        kernel_start_preemption();

        // Add the main thread to the ready queue
        // once resume is called on mainProcessor->runner the mainThread needs to be scheduled like any normal thread
        ScheduleThread(mainThread);

        // SKULLDUGGERY: Force a context switch to the main processor to set the main thread's context to the current UNIX
        // context. Hence, the main thread does not begin through CtxInvokeThread, like all other threads. The trick here is that
        // mainThread is on the ready queue when this call is made.
        kernel_first_resume( kernelTLS.this_processor );



        // THE SYSTEM IS NOW COMPLETELY RUNNING
        __cfaabi_dbg_print_safe("Kernel : Started\n--------------------------------------------------\n\n");

        verify( ! kernelTLS.preemption_state.enabled );
        enable_interrupts( __cfaabi_dbg_ctx );
        verify( TL_GET( preemption_state.enabled ) );
}

void kernel_shutdown(void) {
        __cfaabi_dbg_print_safe("\n--------------------------------------------------\nKernel : Shutting down\n");

        verify( TL_GET( preemption_state.enabled ) );
        disable_interrupts();
        verify( ! kernelTLS.preemption_state.enabled );

        // SKULLDUGGERY: Notify the mainProcessor it needs to terminates.
        // When its coroutine terminates, it return control to the mainThread
        // which is currently here
        mainProcessor->do_terminate = true;
        returnToKernel();

        // THE SYSTEM IS NOW COMPLETELY STOPPED

        // Disable preemption
        kernel_stop_preemption();

        // Destroy the main processor and its context in reverse order of construction
        // These were manually constructed so we need manually destroy them
        ^(mainProcessor->runner){};
        ^(mainProcessor){};

        // Final step, destroy the main thread since it is no longer needed
        // Since we provided a stack to this taxk it will not destroy anything
        ^(mainThread){};

        ^(global_clusters.list){};
        ^(global_clusters.lock){};

        __cfaabi_dbg_print_safe("Kernel : Shutdown complete\n");
}

//=============================================================================================
// Kernel Quiescing
//=============================================================================================

void halt(processor * this) with( *this ) {
        with( *cltr ) {
                lock      (proc_list_lock __cfaabi_dbg_ctx2);
                remove    (procs, *this);
                push_front(idles, *this);
                unlock    (proc_list_lock);
        }

        __cfaabi_dbg_print_safe("Kernel : Processor %p ready to sleep\n", this);

        verify( ({int sval = 0; sem_getvalue(&this->idleLock, &sval); sval; }) < 200);
        int __attribute__((unused)) ret = sem_wait(&idleLock);
        verify(ret > 0 || errno == EINTR);

        __cfaabi_dbg_print_safe("Kernel : Processor %p woke up and ready to run\n", this);

        with( *cltr ) {
                lock      (proc_list_lock __cfaabi_dbg_ctx2);
                remove    (idles, *this);
                push_front(procs, *this);
                unlock    (proc_list_lock);
        }
}

void wake(processor * this) {
        __cfaabi_dbg_print_safe("Kernel : Waking up processor %p\n", this);
        int __attribute__((unused)) ret = sem_post(&this->idleLock);
        verify(ret > 0 || errno == EINTR);
        verify( ({int sval = 0; sem_getvalue(&this->idleLock, &sval); sval; }) < 200);
}

//=============================================================================================
// Unexpected Terminating logic
//=============================================================================================


static __spinlock_t kernel_abort_lock;
static bool kernel_abort_called = false;

void * kernel_abort(void) __attribute__ ((__nothrow__)) {
        // abort cannot be recursively entered by the same or different processors because all signal handlers return when
        // the globalAbort flag is true.
        lock( kernel_abort_lock __cfaabi_dbg_ctx2 );

        // first task to abort ?
        if ( kernel_abort_called ) {                    // not first task to abort ?
                unlock( kernel_abort_lock );

                sigset_t mask;
                sigemptyset( &mask );
                sigaddset( &mask, SIGALRM );            // block SIGALRM signals
                sigsuspend( &mask );                    // block the processor to prevent further damage during abort
                _exit( EXIT_FAILURE );                  // if processor unblocks before it is killed, terminate it
        }
        else {
                kernel_abort_called = true;
                unlock( kernel_abort_lock );
        }

        return kernelTLS.this_thread;
}

void kernel_abort_msg( void * kernel_data, char * abort_text, int abort_text_size ) {
        thread_desc * thrd = kernel_data;

        if(thrd) {
                int len = snprintf( abort_text, abort_text_size, "Error occurred while executing thread %.256s (%p)", thrd->self_cor.name, thrd );
                __cfaabi_dbg_bits_write( abort_text, len );

                if ( get_coroutine(thrd) != kernelTLS.this_coroutine ) {
                        len = snprintf( abort_text, abort_text_size, " in coroutine %.256s (%p).\n", kernelTLS.this_coroutine->name, kernelTLS.this_coroutine );
                        __cfaabi_dbg_bits_write( abort_text, len );
                }
                else {
                        __cfaabi_dbg_bits_write( ".\n", 2 );
                }
        }
        else {
                int len = snprintf( abort_text, abort_text_size, "Error occurred outside of any thread.\n" );
                __cfaabi_dbg_bits_write( abort_text, len );
        }
}

int kernel_abort_lastframe( void ) __attribute__ ((__nothrow__)) {
        return get_coroutine(kernelTLS.this_thread) == get_coroutine(mainThread) ? 4 : 2;
}

static __spinlock_t kernel_debug_lock;

extern "C" {
        void __cfaabi_dbg_bits_acquire() {
                lock( kernel_debug_lock __cfaabi_dbg_ctx2 );
        }

        void __cfaabi_dbg_bits_release() {
                unlock( kernel_debug_lock );
        }
}

//=============================================================================================
// Kernel Utilities
//=============================================================================================
//-----------------------------------------------------------------------------
// Locks
void  ?{}( semaphore & this, int count = 1 ) {
        (this.lock){};
        this.count = count;
        (this.waiting){};
}
void ^?{}(semaphore & this) {}

void P(semaphore & this) with( this ){
        lock( lock __cfaabi_dbg_ctx2 );
        count -= 1;
        if ( count < 0 ) {
                // queue current task
                append( waiting, kernelTLS.this_thread );

                // atomically release spin lock and block
                BlockInternal( &lock );
        }
        else {
            unlock( lock );
        }
}

void V(semaphore & this) with( this ) {
        thread_desc * thrd = NULL;
        lock( lock __cfaabi_dbg_ctx2 );
        count += 1;
        if ( count <= 0 ) {
                // remove task at head of waiting list
                thrd = pop_head( waiting );
        }

        unlock( lock );

        // make new owner
        WakeThread( thrd );
}

//-----------------------------------------------------------------------------
// Global Queues
void doregister( cluster     & cltr ) {
        lock      ( global_clusters.lock __cfaabi_dbg_ctx2);
        push_front( global_clusters.list, cltr );
        unlock    ( global_clusters.lock );
}

void unregister( cluster     & cltr ) {
        lock  ( global_clusters.lock __cfaabi_dbg_ctx2);
        remove( global_clusters.list, cltr );
        unlock( global_clusters.lock );
}

void doregister( cluster * cltr, thread_desc & thrd ) {
        lock      (cltr->thread_list_lock __cfaabi_dbg_ctx2);
        push_front(cltr->threads, thrd);
        unlock    (cltr->thread_list_lock);
}

void unregister( cluster * cltr, thread_desc & thrd ) {
        lock  (cltr->thread_list_lock __cfaabi_dbg_ctx2);
        remove(cltr->threads, thrd );
        unlock(cltr->thread_list_lock);
}

void doregister( cluster * cltr, processor * proc ) {
        lock      (cltr->proc_list_lock __cfaabi_dbg_ctx2);
        push_front(cltr->procs, *proc);
        unlock    (cltr->proc_list_lock);
}

void unregister( cluster * cltr, processor * proc ) {
        lock  (cltr->proc_list_lock __cfaabi_dbg_ctx2);
        remove(cltr->procs, *proc );
        unlock(cltr->proc_list_lock);
}

//-----------------------------------------------------------------------------
// Debug
__cfaabi_dbg_debug_do(
        void __cfaabi_dbg_record(__spinlock_t & this, const char * prev_name) {
                this.prev_name = prev_name;
                this.prev_thrd = kernelTLS.this_thread;
        }
)
// Local Variables: //
// mode: c //
// tab-width: 4 //
// End: //