0,0 → 1,122 |
/* |
* Copyright (c) 2007 Jan Hudecek |
* Copyright (c) 2006 Jakub Jermar |
* All rights reserved. |
* |
* Redistribution and use in source and binary forms, with or without |
* modification, are permitted provided that the following conditions |
* are met: |
* |
* - Redistributions of source code must retain the above copyright |
* notice, this list of conditions and the following disclaimer. |
* - Redistributions in binary form must reproduce the above copyright |
* notice, this list of conditions and the following disclaimer in the |
* documentation and/or other materials provided with the distribution. |
* - The name of the author may not be used to endorse or promote products |
* derived from this software without specific prior written permission. |
* |
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
*/ |
/** @addtogroup sync |
* @{ |
*/ |
/** @file |
*/ |
|
#include <synch/rcu.h> |
#include <synch/waitq.h> |
#include <arch.h> |
#include <config.h> |
#include <arch/types.h> |
#include <ddi/tasklet.h> |
#include <synch/spinlock.h> |
#include <time/delay.h> |
#include <panic.h> |
#include <print.h> |
|
typedef struct rcu_global |
{ |
uint32_t current_batch; |
uint32_t completed_batch; |
bool next_batch_waiting; |
} rcu_global_t; |
|
typedef struct rcu_callback_list |
{ |
struct rcu_callback_list* next; |
void (*func)(void*); |
void* data; |
bool* cpu_mask; |
} rcu_callback_list_t; |
|
|
typedef struct rcu_percpu |
{ |
uint32_t current_batch_number; |
uint32_t QS_passed; |
bool QS_pending; |
|
rcu_callback_list_t* next_batch, *current_batch, *done_batch; |
} rcu_percpu_t; |
|
rcu_global_t _rcu_global; |
rcu_percpu_t* _rcu_cpu_lists; |
|
void rcu_init(void) |
{ |
_rcu_cpu_lists = malloc(sizeof(rcu_percpu_t)*config.cpu_count,0); |
_rcu_global.completed_batch = -1; |
_rcu_global.current_batch = -1; |
_rcu_global.next_batch_waiting = -1; |
|
} |
|
void rcu_synchronize(void) |
{ |
waitq_t wq; |
waitq_initialize(&wq); |
rcu_sync_callback(rcu_synchronize_callback_function, &wq); |
waitq_sleep(&wq); |
} |
|
void rcu_synchronize_callback_function(void* waitq) |
{ |
waitq_wakeup(((waitq_t*)waitq), true); |
} |
|
void rcu_sync_callback(void (*func)(void* data), void* data) |
{ |
int i; |
rcu_callback_list_t *rd; |
rd = malloc(sizeof(rcu_desc), 0); |
rd->func = func; |
rd->data = data; |
rd->next = NULL; |
|
rd->cpu_mask = malloc (sizeof(bool)*config.cpu_count,0); |
for (i=0;i<config.cpu_count;i++) |
rd->cpu_mask[i]=false; |
|
i = ++(_rcu_global.current_batch); |
_rcu_global.next_batch_waiting = true; |
|
rd->next = _rcu_cpu_lists[0].next_batch; |
for (i=0;i<config.cpu_count;i++) |
{ |
_rcu_cpu_lists[i].next_batch = rd; |
_rcu_cpu_lists[i].QS_pending = true; |
|
} |
|
//TODO:tasklet, after_thread_ran, polishing |
} |
|